Package io.clonecloudstore.reconciliator.database.mongodb

Class MgInitializationService

java.lang.Object

io.clonecloudstore.reconciliator.database.mongodb.MgInitializationService

All Implemented Interfaces:

InitializationService

@ApplicationScoped
public class MgInitializationService
extends Object
implements InitializationService

Field Summary

Fields

Modifier and Type	Field	Description
static final String	INITIALIZATION_SERVICE

Constructor Summary

Constructors

Constructor	Description
MgInitializationService(MgDaoAccessorBucketRepository bucketRepository, MgDaoAccessorObjectRepository objectRepository, MgDaoRequestRepository requestRepository, MgDaoSitesActionRepository sitesActionRepository, BulkMetrics bulkMetrics)

Method Summary

Modifier and Type	Method	Description
void	importFromExistingBucket(String clientId, String bucket, String prefix, Instant from, Instant to, long futureExpireAddSeconds, Map<String,String> defaultMetadata)
DaoRequest	syncFromExistingSite(String clientId, String bucket, String remoteSite, AccessorFilter filter)

Methods inherited from class java.lang.Object

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

Field Details

INITIALIZATION_SERVICE

public static final String INITIALIZATION_SERVICE

See Also:

• Constant Field Values

Constructor Details

MgInitializationService

public MgInitializationService(MgDaoAccessorBucketRepository bucketRepository,
 MgDaoAccessorObjectRepository objectRepository,
 MgDaoRequestRepository requestRepository,
 MgDaoSitesActionRepository sitesActionRepository,
 BulkMetrics bulkMetrics)

Method Details

importFromExistingBucket

public void importFromExistingBucket(String clientId,
 String bucket,
 String prefix,
 Instant from,
 Instant to,
 long futureExpireAddSeconds,
 Map<String,String> defaultMetadata)
                              throws CcsWithStatusException

Specified by:

importFromExistingBucket in interface InitializationService

Parameters:

bucket - Which bucket to look into

futureExpireAddSeconds - number of seconds greather than 0 to set a future expiration, or none if less or equals than 0

defaultMetadata - Default Metadata to apply to each found object

Throws:

CcsWithStatusException

syncFromExistingSite

public DaoRequest syncFromExistingSite(String clientId,
 String bucket,
 String remoteSite,
 AccessorFilter filter)
                                throws CcsDbException

Specified by:

syncFromExistingSite in interface InitializationService

Parameters:

bucket - Which bucket to fully synchronized

remoteSite - Which site to fully synchronized from

filter -

Returns:

Throws:

CcsDbException