Interface CrudIngestionProcessRepository
-
- All Known Implementing Classes:
DefaultIngestionProcessRepository
public interface CrudIngestionProcessRepository
A repository for basic storage of the ingestion processes. UnlikeIngestionProcessRepository
this repository should only provide simple CRUD operations, treating the provided/fetched data as is, without any additional logic.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Optional<IngestionProcess>
fetch(String processId)
Fetches an ingestion process by the specified id.List<IngestionProcess>
fetchAll(String status)
Fetches all ingestion processes with the specified status.List<IngestionProcess>
fetchAll(List<String> resourceIngestionDefinitionIds)
Fetches all ingestion processes with resource ingestion definition id contained within the specified list of ids.void
save(IngestionProcess ingestionProcess)
Saves the specified ingestion process.void
save(Collection<IngestionProcess> ingestionProcesses)
Saves the specified ingestion processes.
-
-
-
Method Detail
-
save
void save(IngestionProcess ingestionProcess)
Saves the specified ingestion process.- Parameters:
ingestionProcess
- ingestion process
-
save
void save(Collection<IngestionProcess> ingestionProcesses)
Saves the specified ingestion processes.- Parameters:
ingestionProcesses
- ingestion processes
-
fetch
Optional<IngestionProcess> fetch(String processId)
Fetches an ingestion process by the specified id.- Parameters:
processId
- process id- Returns:
- ingestion process with the specified id
-
fetchAll
List<IngestionProcess> fetchAll(List<String> resourceIngestionDefinitionIds)
Fetches all ingestion processes with resource ingestion definition id contained within the specified list of ids.- Parameters:
resourceIngestionDefinitionIds
- resource ingestion definition ids- Returns:
- a list containing processes matching the specified criteria
-
fetchAll
List<IngestionProcess> fetchAll(String status)
Fetches all ingestion processes with the specified status.- Parameters:
status
- process status- Returns:
- a list containing all the processes matching the specified criteria
-
-