Package org.linuxforhealth.fhir.bucket.reindex

Class ServerDrivenReindexOperation

  • public class ServerDrivenReindexOperation
extends DriveReindexOperation
    Drives the $reindex custom operation in parallel. Each thread keeps running until the OperationOutcome indicates that no work remains to be processed.

    • Constructor Summary

      Constructors 
      Constructor Description
      ServerDrivenReindexOperation​(FHIRBucketClient fhirClient, int maxConcurrentRequests, java.lang.String tstampParam, int resourceCountParam, boolean force)
      Public constructor

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void init()
      Start the main loop
      void monitorLoop()
      The main monitor loop.
      void signalStop()
      Program is stopping, so tell the threads they can stop too
      void waitForStop()
      Wait until things are stopped

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • ServerDrivenReindexOperation

        public ServerDrivenReindexOperation​(FHIRBucketClient fhirClient,
                                    int maxConcurrentRequests,
                                    java.lang.String tstampParam,
                                    int resourceCountParam,
                                    boolean force)
        Public constructor
        Parameters:
        client - the FHIR client
        maxConcurrentRequests - the number of threads to spin up
        tstampParam -
        resourceCountParam -
        force -