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

Class OfferSyncProcess

java.lang.Object

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

public class OfferSyncProcess
extends Object

Synchronization of a storage offer from another one.

Constructor Summary

Constructors

Constructor and Description
OfferSyncProcess(RestoreOfferBackupService restoreOfferBackupService, StorageDistribution distribution, int bulkSize, int offerSyncThreadPoolSize, int offerSyncNumberOfRetries, int offerSyncFirstAttemptWaitingTime, int offerSyncWaitingTime)

Method Summary

Modifier and Type	Method and Description
OfferSyncStatus	getOfferSyncStatus()
boolean	isRunning()
void	synchronize(String sourceOffer, String targetOffer, String strategyId, DataCategory dataCategory, Long offset) Synchronize an offer from another using the offset.

Methods inherited from class java.lang.Object

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

Constructor Detail

OfferSyncProcess

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

Method Detail

synchronize

public void synchronize(String sourceOffer,
                        String targetOffer,
                        String strategyId,
                        DataCategory dataCategory,
                        Long offset)

Synchronize an offer from another using the offset.

Parameters:

sourceOffer - the identifier of the source offer

targetOffer - the identifier of the target offer

strategyId - the strategy containing the two offers

offset - the offset of the process of the synchronisation

isRunning

public boolean isRunning()

getOfferSyncStatus

public OfferSyncStatus getOfferSyncStatus()