Package org.linuxforhealth.fhir.persistence.blob.app

Class BlobResourceScanner

  • public class BlobResourceScanner
extends java.lang.Object
    Scans resource payload records which have been stored in the blob store. Used by the reconciliation process to identify records existing in the blob store which do not have a corresponding record in the RDBMS.

    • Constructor Summary

      Constructors 
      Constructor Description
      BlobResourceScanner​(java.lang.String continuationToken, java.util.function.Consumer<java.util.List<ResourceRecord>> pageHandler)
      Public constructor

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.lang.String getContinuationToken()
      Get the latest continuationToken which can be used to checkpoint processing of the container
      protected void processPage​(com.azure.core.http.rest.PagedResponse<com.azure.storage.blob.models.BlobItem> page)
      Process a page of entries, which is a useful boundary for a database transaction.
      void run​(BlobManagedContainer bmc, int maxScanSeconds)
      Start scanning using the given BlobManagedContainer

      • Methods inherited from class java.lang.Object

        clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • BlobResourceScanner

        public BlobResourceScanner​(java.lang.String continuationToken,
                           java.util.function.Consumer<java.util.List<ResourceRecord>> pageHandler)
        Public constructor
        Parameters:
        continuationToken - the Azure Blob continuation token to mark the scan start point
        pageHandler -

    • Method Detail

      • getContinuationToken

        public java.lang.String getContinuationToken()
        Get the latest continuationToken which can be used to checkpoint processing of the container
        Returns:

      • processPage

        protected void processPage​(com.azure.core.http.rest.PagedResponse<com.azure.storage.blob.models.BlobItem> page)
        Process a page of entries, which is a useful boundary for a database transaction.
        Parameters:
        page -