Interface CrudIngestionProcessRepository
-
- All Known Implementing Classes:
DefaultIngestionProcessRepository
public interface CrudIngestionProcessRepositoryA repository for basic storage of the ingestion processes. UnlikeIngestionProcessRepositorythis 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.voidsave(IngestionProcess ingestionProcess)Saves the specified ingestion process.voidsave(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
-
-