Package io.clonecloudstore.reconciliator.database.mongodb

Class MgCentralReconciliationService

java.lang.Object

io.clonecloudstore.reconciliator.database.mongodb.MgCentralReconciliationService

All Implemented Interfaces:

CentralReconciliationService

@ApplicationScoped
public class MgCentralReconciliationService
extends Object
implements CentralReconciliationService

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CENTRAL_RECONCILIATION

Constructor Summary

Constructors

Constructor	Description
MgCentralReconciliationService(MgDaoSitesListingRepository sitesListingRepository, MgDaoSitesActionRepository sitesActionRepository, MgDaoRequestRepository requestRepository, BulkMetrics bulkMetrics)

Method Summary

Modifier and Type	Method	Description
void	cleanSitesAction(DaoRequest daoRequest)	Once all pushed into topic
void	computeActions(DaoRequest daoRequest)	Compute actions from sites listing Step8: in 2 steps, all sites declared, not all sites declared Index Sites: requestId, bucket, local.nstatus Index Actions: requestId, bucket, name
void	computeActionsInvalidUpload(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference)
void	computeActionsReadyLike(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference)
void	computeActionsStepDelete(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference)	Index: REQUESTID, BUCKET, LOCAL.NSTATUS
void	computeActionsUpload(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference)
void	countFinalActions(DaoRequest daoRequest)
ClosingIterator<DaoSitesAction>	getSitesActon(DaoRequest daoRequest)	Step9: return iterator of actions to populate topic Index Actions: requestId, bucket
void	saveRemoteNativeListing(DaoRequest daoRequest, Iterator<ReconciliationSitesListing> iterator)	Add the remote sites listing to local aggregate one Step7: add all remote sites listing Index Sites: requestId, bucket, name
void	updateRequestFromRemoteListing(DaoRequest daoRequest)

Methods inherited from class java.lang.Object

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

Field Details

CENTRAL_RECONCILIATION

public static final String CENTRAL_RECONCILIATION

See Also:

• Constant Field Values

Constructor Details

MgCentralReconciliationService

public MgCentralReconciliationService(MgDaoSitesListingRepository sitesListingRepository,
 MgDaoSitesActionRepository sitesActionRepository,
 MgDaoRequestRepository requestRepository,
 BulkMetrics bulkMetrics)

Method Details

saveRemoteNativeListing

public void saveRemoteNativeListing(DaoRequest daoRequest,
 Iterator<ReconciliationSitesListing> iterator)
                             throws CcsDbException

Add the remote sites listing to local aggregate one
Step7: add all remote sites listing
Index Sites: requestId, bucket, name

Specified by:

saveRemoteNativeListing in interface CentralReconciliationService

Throws:

CcsDbException

computeActions

public void computeActions(DaoRequest daoRequest)
                    throws CcsDbException

Compute actions from sites listing
Step8: in 2 steps, all sites declared, not all sites declared Index Sites: requestId, bucket, local.nstatus Index Actions: requestId, bucket, name

Specified by:

computeActions in interface CentralReconciliationService

Throws:

CcsDbException

computeActionsStepDelete

public void computeActionsStepDelete(DaoRequest daoRequest,
 AtomicReference<CcsDbException> exceptionAtomicReference)

Index: REQUESTID, BUCKET, LOCAL.NSTATUS

computeActionsReadyLike

public void computeActionsReadyLike(DaoRequest daoRequest,
 AtomicReference<CcsDbException> exceptionAtomicReference)

computeActionsUpload

public void computeActionsUpload(DaoRequest daoRequest,
 AtomicReference<CcsDbException> exceptionAtomicReference)

computeActionsInvalidUpload

public void computeActionsInvalidUpload(DaoRequest daoRequest,
 AtomicReference<CcsDbException> exceptionAtomicReference)

countFinalActions

public void countFinalActions(DaoRequest daoRequest)
                       throws CcsDbException

Specified by:

countFinalActions in interface CentralReconciliationService

Throws:

CcsDbException

updateRequestFromRemoteListing

public void updateRequestFromRemoteListing(DaoRequest daoRequest)
                                    throws CcsDbException

Specified by:

updateRequestFromRemoteListing in interface CentralReconciliationService

Throws:

CcsDbException

getSitesActon

public ClosingIterator<DaoSitesAction> getSitesActon(DaoRequest daoRequest)
                                              throws CcsDbException

Step9: return iterator of actions to populate topic
Index Actions: requestId, bucket

Specified by:

getSitesActon in interface CentralReconciliationService

Throws:

CcsDbException

cleanSitesAction

public void cleanSitesAction(DaoRequest daoRequest)
                      throws CcsDbException

Once all pushed into topic

Specified by:

cleanSitesAction in interface CentralReconciliationService

Throws:

CcsDbException