Package io.clonecloudstore.reconciliator.database.mongodb

Class MgPurgeService

java.lang.Object

io.clonecloudstore.reconciliator.database.mongodb.MgPurgeService

All Implemented Interfaces:

PurgeService

@ApplicationScoped
public class MgPurgeService
extends Object
implements PurgeService

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PURGE_SERVICE

Constructor Summary

Constructors

Constructor	Description
MgPurgeService(MgDaoAccessorBucketRepository bucketRepository, MgDaoAccessorObjectRepository objectRepository, LocalBrokerService localBrokerService, BulkMetrics bulkMetrics)

Method Summary

Modifier and Type	Method	Description
void	purgeObjectsOnExpiredDate(String clientId, String bucketForReadyExpired, long futureExpireAddSeconds)	INDEX : bucket, status, expired

Methods inherited from class java.lang.Object

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

Field Details

PURGE_SERVICE

public static final String PURGE_SERVICE

See Also:

• Constant Field Values

Constructor Details

MgPurgeService

public MgPurgeService(MgDaoAccessorBucketRepository bucketRepository,
 MgDaoAccessorObjectRepository objectRepository,
 LocalBrokerService localBrokerService,
 BulkMetrics bulkMetrics)

Method Details

purgeObjectsOnExpiredDate

public void purgeObjectsOnExpiredDate(String clientId,
 String bucketForReadyExpired,
 long futureExpireAddSeconds)
                               throws CcsDbException

INDEX : bucket, status, expired

Specified by:

purgeObjectsOnExpiredDate in interface PurgeService

Parameters:

bucketForReadyExpired - if null, means delete, else move to this bucket. If the object is already in this archive bucket, it will then be purged

futureExpireAddSeconds - number of seconds > 0 to set a future expiration on archival process if any or 0 to keep it forever

Throws:

CcsDbException