Uses of Class
io.clonecloudstore.reconciliator.database.model.DaoRequest

Packages that use DaoRequest

Package	Description
io.clonecloudstore.reconciliator.database.model
io.clonecloudstore.reconciliator.database.mongodb

Uses of DaoRequest in io.clonecloudstore.reconciliator.database.model

Methods in io.clonecloudstore.reconciliator.database.model that return DaoRequest

Modifier and Type	Method	Description
DaoRequest	DaoRequest.fromDto(ReconciliationRequest dto)
DaoRequest	DaoRequest.setActions(long actions)
DaoRequest	DaoRequest.setBucket(String bucket)
DaoRequest	DaoRequest.setChecked(long checked)
DaoRequest	DaoRequest.setCheckedDb(long checkedDb)
DaoRequest	DaoRequest.setCheckedDriver(long checkedDriver)
DaoRequest	DaoRequest.setCheckedRemote(long checkedRemote)
DaoRequest	DaoRequest.setClientId(String clientId)
DaoRequest	DaoRequest.setContextSites(List<String> contextSites)
DaoRequest	DaoRequest.setContextSitesDone(List<String> contextSitesDone)
DaoRequest	DaoRequest.setCurrentSite(String currentSite)
DaoRequest	DaoRequest.setDryRun(boolean dryRun)
DaoRequest	DaoRequest.setFilter(AccessorFilter filter)
DaoRequest	DaoRequest.setFromSite(String fromSite)
abstract DaoRequest	DaoRequest.setId(String id)
DaoRequest	DaoRequest.setStart(Instant start)
DaoRequest	DaoRequest.setStop(Instant stop)
DaoRequest	InitializationService.syncFromExistingSite(String clientId, String bucket, String remoteSite, AccessorFilter filter)

Methods in io.clonecloudstore.reconciliator.database.model with parameters of type DaoRequest

Modifier and Type	Method	Description
void	LocalReconciliationService.cleanNativeListing(DaoRequest daoRequest)
void	CentralReconciliationService.cleanSitesAction(DaoRequest daoRequest)
void	LocalReconciliationService.cleanSitesListing(DaoRequest daoRequest)
void	CentralReconciliationService.computeActions(DaoRequest daoRequest)
void	CentralReconciliationService.countFinalActions(DaoRequest daoRequest)
ClosingIterator<DaoSitesListing>	LocalReconciliationService.getSiteListing(DaoRequest daoRequest)
ClosingIterator<DaoSitesAction>	CentralReconciliationService.getSitesActon(DaoRequest daoRequest)
void	CentralReconciliationService.saveRemoteNativeListing(DaoRequest daoRequest, Iterator<ReconciliationSitesListing> stream)
void	LocalReconciliationService.step1CleanUpObjectsNativeListings(DaoRequest daoPreviousRequest)
void	LocalReconciliationService.step2ContinueFromPreviousRequest(String requestId, DaoRequest daoRequest, boolean replaceOldRequest)
void	LocalReconciliationService.step3SaveNativeListingDb(DaoRequest daoRequest)
void	LocalReconciliationService.step4SaveNativeListingDriver(DaoRequest daoRequest)
void	LocalReconciliationService.step5CompareNativeListingDbDriver(DaoRequest daoRequest)
void	CentralReconciliationService.updateRequestFromRemoteListing(DaoRequest daoRequest)

Uses of DaoRequest in io.clonecloudstore.reconciliator.database.mongodb

Subclasses of DaoRequest in io.clonecloudstore.reconciliator.database.mongodb

Modifier and Type	Class	Description
class	MgDaoRequest	MongoDB DAO for Bucket

Methods in io.clonecloudstore.reconciliator.database.mongodb that return DaoRequest

Modifier and Type	Method	Description
DaoRequest	MgDaoRequestRepository.createEmptyItem()
DaoRequest	MgInitializationService.syncFromExistingSite(String clientId, String bucket, String remoteSite, AccessorFilter filter)

Methods in io.clonecloudstore.reconciliator.database.mongodb with parameters of type DaoRequest

Modifier and Type	Method	Description
void	MgLocalReconciliationService.cleanNativeListing(DaoRequest daoRequest)	Used only if NativeListing is not to be kept
void	MgCentralReconciliationService.cleanSitesAction(DaoRequest daoRequest)	Once all pushed into topic
void	MgLocalReconciliationService.cleanSitesListing(DaoRequest daoRequest)	Used only if SitesListing is not to be kept
void	MgCentralReconciliationService.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	MgCentralReconciliationService.computeActionsInvalidUpload(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference)
void	MgCentralReconciliationService.computeActionsReadyLike(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference)
void	MgCentralReconciliationService.computeActionsStepDelete(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference)	Index: REQUESTID, BUCKET, LOCAL.NSTATUS
void	MgCentralReconciliationService.computeActionsUpload(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference)
void	MgCentralReconciliationService.countFinalActions(DaoRequest daoRequest)
ClosingIterator<DaoSitesListing>	MgLocalReconciliationService.getSiteListing(DaoRequest daoRequest)	Get the local sites listing to send through network Step6: get all local sites listing Index Sites: requestId
ClosingIterator<DaoSitesAction>	MgCentralReconciliationService.getSitesActon(DaoRequest daoRequest)	Step9: return iterator of actions to populate topic Index Actions: requestId, bucket
void	MgCentralReconciliationService.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	MgLocalReconciliationService.step1CleanUpObjectsNativeListings(DaoRequest daoPreviousRequest)	Clean Up Native Listing and Objects from status Object Index Objects: Bucket, Site, Status, creation
void	MgLocalReconciliationService.step1SubStep1CleanUpStatusUnknownObjectsNativeListings(DaoRequest daoPreviousRequest)	Clean Up Native Listing and Objects from status Object Remove UNKNOWN status Index Objects: Bucket, Site, Status
void	MgLocalReconciliationService.step1SubStep2CleanUpStatusOlderUploadDeleteCheckObjectsNativeListings(DaoRequest daoPreviousRequest)	Clean Up Objects ReconciliationStatus from status Object Index Objects: Bucket, Site, Status, creation
void	MgLocalReconciliationService.step1SubStep3CleanUpPreviousErrorUploadAndDeletedNativeListing(DaoRequest daoPreviousRequest)	Clean Up Native Listing from status Object Remove UNKNOWN, UPLOAD, ERR_UPL, DELETED, ERR_DEL items Index Objects: Bucket, Site, Status
void	MgLocalReconciliationService.step2ContinueFromPreviousRequest(String requestId, DaoRequest daoRequest, boolean replaceOldRequest)	Get Old listing to restart from (for each site): Optional step (if accepting eventual mistakes on old data) Index Native: requestId, bucket Step2: Copy NativeListing with new RequestId (or Replace requestId)
void	MgLocalReconciliationService.step3SaveNativeListingDb(DaoRequest daoRequest)	Listing according to filter such as now > dateFrom (DB), updating existing info Step3: From Db Objects into NativeListing local step Index Objects: site, bucket, event Index Native: requestId, bucket, name
void	MgLocalReconciliationService.step4SaveNativeListingDriver(DaoRequest daoRequest)	Listing according to filter such as now > dateFrom (DRIVER), updating existing info Step4: From Driver to Native Index Native: requestId, bucket, name
void	MgLocalReconciliationService.step51InsertMissingObjectsFromExistingDriverIntoObjects(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference)
void	MgLocalReconciliationService.step52UpsertMissingObjectsFromExistingDriverIntoSiteListing(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference, BlockingQueue<List<DaoSitesListing>> blockingQueue)
void	MgLocalReconciliationService.step53UpdateWhereNoDriverIntoObjects(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference)
void	MgLocalReconciliationService.step54UpsertWhereNoDriverIntoSiteListing(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference)
void	MgLocalReconciliationService.step55UpdateBothDbDriverIntoObjects(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference)
void	MgLocalReconciliationService.step56UpdateBothDbDriverIntoSiteListing(DaoRequest daoRequest, AtomicReference<CcsDbException> exceptionAtomicReference, BlockingQueue<List<DaoSitesListing>> blockingQueue)
void	MgLocalReconciliationService.step58CountFinalSiteListing(DaoRequest daoRequest)
void	MgLocalReconciliationService.step5CompareNativeListingDbDriver(DaoRequest daoRequest)	Compare Native listing with DB and DRIVER (both or only one) Step5: Complete DB without Driver from NativeListing into SitesListing Local step Index Native: requestId, bucket, db, driver.event (optional) Index Objects: site, bucket, name Index Native: requestId, bucket, db.site, driver (optional) Index Native: requestId, bucket, db.site, driver.site Index Sites: requestId, bucket, name
void	MgCentralReconciliationService.updateRequestFromRemoteListing(DaoRequest daoRequest)