Package fr.gouv.vitam.storage.engine.server.offersynchronization

Class OfferSyncProcess

  • public class OfferSyncProcess
extends java.lang.Object
    Synchronization of a storage offer from another one.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static java.lang.String OFFER_SYNC_ORIGIN  

    • Constructor Summary

      Constructors 
      Constructor Description
      OfferSyncProcess​(RestoreOfferBackupService restoreOfferBackupService, StorageDistribution distribution, int bulkSize, int offerSyncNumberOfRetries, int offerSyncFirstAttemptWaitingTime, int offerSyncWaitingTime, int accessRequestCheckWaitingTime)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      OfferSyncStatus getOfferSyncStatus()  
      boolean isRunning()  
      void synchronize​(java.util.concurrent.Executor executor, java.lang.String sourceOffer, java.lang.String targetOffer, java.lang.String strategyId, java.util.List<OfferPartialSyncItem> items)  
      void synchronize​(java.util.concurrent.ExecutorService executor, java.lang.String sourceOffer, java.lang.String targetOffer, java.lang.String strategyId, DataCategory dataCategory, java.lang.Long startOffset)  

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • OFFER_SYNC_ORIGIN

        public static final java.lang.String OFFER_SYNC_ORIGIN
        See Also:
        Constant Field Values

    • Constructor Detail

      • OfferSyncProcess

        public OfferSyncProcess​(RestoreOfferBackupService restoreOfferBackupService,
                        StorageDistribution distribution,
                        int bulkSize,
                        int offerSyncNumberOfRetries,
                        int offerSyncFirstAttemptWaitingTime,
                        int offerSyncWaitingTime,
                        int accessRequestCheckWaitingTime)

    • Method Detail

      • synchronize

        public void synchronize​(java.util.concurrent.ExecutorService executor,
                        java.lang.String sourceOffer,
                        java.lang.String targetOffer,
                        java.lang.String strategyId,
                        DataCategory dataCategory,
                        java.lang.Long startOffset)

      • isRunning

        public boolean isRunning()

      • synchronize

        public void synchronize​(java.util.concurrent.Executor executor,
                        java.lang.String sourceOffer,
                        java.lang.String targetOffer,
                        java.lang.String strategyId,
                        java.util.List<OfferPartialSyncItem> items)