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

Class OfferSyncProcess

java.lang.Object

fr.gouv.vitam.storage.engine.server.offersynchronization.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)

Method Summary

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)

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()

getOfferSyncStatus

public OfferSyncStatus getOfferSyncStatus()

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)