Interface CrudIngestionProcessRepository

  • All Known Implementing Classes:
    DefaultIngestionProcessRepository

    public interface CrudIngestionProcessRepository
    A repository for basic storage of the ingestion processes. Unlike IngestionProcessRepository this repository should only provide simple CRUD operations, treating the provided/fetched data as is, without any additional logic.
    • 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