Index (ccs-reconciliator-server 0.8.0-SNAPSHOT API)

A B C D E F G H I L M N P R S T U
All Classes and Interfaces|All Packages|Constant Field Values

A

ACTIONS - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository

B

BUCKET - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoNativeListingRepository
BUCKET - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository
BUCKET - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoSitesActionRepository
BUCKET - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoSitesListingRepository

C

CCS_FIRST - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
CENTRAL_RECONCILIATION - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgCentralReconciliationService
CentralReconciliationService - Interface in io.clonecloudstore.reconciliator.database.model
CHECKED - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository
CHECKED_DB - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository
CHECKED_DRIVER - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository
CHECKED_REMOTE - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository
cleanNativeListing(DaoRequest) - Method in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
cleanNativeListing(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService: Used only if NativeListing is not to be kept
cleanSitesAction(DaoRequest) - Method in interface io.clonecloudstore.reconciliator.database.model.CentralReconciliationService
cleanSitesAction(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgCentralReconciliationService: Once all pushed into topic
cleanSitesListing(DaoRequest) - Method in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
cleanSitesListing(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService: Used only if SitesListing is not to be kept
CLIENTID - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository
computeActions(DaoRequest) - Method in interface io.clonecloudstore.reconciliator.database.model.CentralReconciliationService
computeActions(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgCentralReconciliationService: 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
computeActionsInvalidUpload(DaoRequest, AtomicReference<CcsDbException>) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgCentralReconciliationService
computeActionsReadyLike(DaoRequest, AtomicReference<CcsDbException>) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgCentralReconciliationService
computeActionsStepDelete(DaoRequest, AtomicReference<CcsDbException>) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgCentralReconciliationService: Index: REQUESTID, BUCKET, LOCAL.NSTATUS
computeActionsUpload(DaoRequest, AtomicReference<CcsDbException>) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgCentralReconciliationService
COND - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
CONTEXTSITES - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository
CONTEXTSITESDONE - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository
countFinalActions(DaoRequest) - Method in interface io.clonecloudstore.reconciliator.database.model.CentralReconciliationService
countFinalActions(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgCentralReconciliationService
createEmptyItem() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoNativeListingRepository
createEmptyItem() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoRequestRepository
createEmptyItem() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesActionRepository
createEmptyItem() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesListingRepository
createIndex() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoNativeListingRepository
createIndex() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoRequestRepository
createIndex() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesActionRepository
createIndex() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesListingRepository
createRequestCentral(ReconciliationRequest) - Method in class io.clonecloudstore.reconciliator.server.resource.ReconciliatorResource: Initial creation of Reconciliation Request
createRequestLocal(ReconciliationRequest) - Method in class io.clonecloudstore.reconciliator.server.resource.ReconciliatorResource: Local creation of Reconciliation Request from existing one in Central.
CURRENTSITE - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository

D

DaoNativeListing - Class in io.clonecloudstore.reconciliator.database.model: SingleSiteObject uses AccessorStatus rank
DaoNativeListing() - Constructor for class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
DaoNativeListingRepository - Interface in io.clonecloudstore.reconciliator.database.model
DaoRequest - Class in io.clonecloudstore.reconciliator.database.model
DaoRequest() - Constructor for class io.clonecloudstore.reconciliator.database.model.DaoRequest
DaoRequestRepository - Interface in io.clonecloudstore.reconciliator.database.model
DaoSitesAction - Class in io.clonecloudstore.reconciliator.database.model: NeedAction uses ReconciliationAction rank
DaoSitesAction() - Constructor for class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
DaoSitesActionRepository - Interface in io.clonecloudstore.reconciliator.database.model
DaoSitesListing - Class in io.clonecloudstore.reconciliator.database.model: SingleSiteObject uses ReconciliationAction rank
DaoSitesListing() - Constructor for class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
DaoSitesListingRepository - Interface in io.clonecloudstore.reconciliator.database.model
DB - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoNativeListingRepository
DB_EVENT - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
DB_NSTATUS - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
DB_SITE - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
DEFAULT_PK - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
DELETED_RANK - Static variable in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
DELETING_RANK - Static variable in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
DRIVER - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoNativeListingRepository
DRIVER_EVENT - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
DRIVER_SITE - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
DRY_RUN - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository

E

equals(Object) - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
equals(Object) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
equals(Object) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
equals(Object) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
ERR_DEL_RANK - Static variable in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
ERR_UPL_RANK - Static variable in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
EVENT - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoNativeListingRepository

F

FILTER - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository
fromDto(ReconciliationRequest) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
fromDto(ReconciliationRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoRequest
fromDto(ReconciliationSitesAction) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
fromDto(ReconciliationSitesAction) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesAction
fromDto(ReconciliationSitesListing) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
fromDto(ReconciliationSitesListing) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesListing
FROMSITE - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository

G

getActions() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getActionsListing(String, String) - Method in class io.clonecloudstore.reconciliator.server.resource.ReconciliatorResource: Once all listing are done, Central will compute Actions and then inform through Replicator remote sites.
getBucket() - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
getBucket() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getBucket() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
getBucket() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
getChecked() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getCheckedDb() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getCheckedDriver() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getCheckedRemote() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getClientId() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getContextSites() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getContextSitesDone() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getCurrentSite() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getDb() - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
getDb() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoNativeListing
getDriver() - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
getDriver() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoNativeListing
getDto() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getDto() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
getDto() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
getDto() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoRequest
getDto() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesAction
getDto() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesListing
getFilter() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getFromSite() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getId() - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
getId() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getId() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
getId() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
getId() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoNativeListing
getId() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoRequest
getId() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesAction
getId() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesListing
getImportStatus(String, String) - Method in class io.clonecloudstore.reconciliator.server.resource.ReconciliatorResource: Once all is done for an Import, can have its full status (statistic or whatever).
getLocal() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
getLocal() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesListing
getLocalRequestStatus(String) - Method in class io.clonecloudstore.reconciliator.server.resource.ReconciliatorResource: Once all is done for a Local Request, can have its full status (statistic or whatever).
getName() - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
getName() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
getName() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
getNeedAction() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
getNeedActionFrom() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
getPurgeStatus(String) - Method in class io.clonecloudstore.reconciliator.server.resource.ReconciliatorResource: Once all is done for a Purge, can have its full status (statistic or whatever).
getRequestId() - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
getRequestId() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
getRequestId() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
getRequestStatus(String) - Method in class io.clonecloudstore.reconciliator.server.resource.ReconciliatorResource: Once all is done for a Request, can have its full status (statistic or whatever).
getSiteListing(DaoRequest) - Method in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
getSiteListing(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService: Get the local sites listing to send through network
Step6: get all local sites listing
Index Sites: requestId
getSites() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
getSitesActon(DaoRequest) - Method in interface io.clonecloudstore.reconciliator.database.model.CentralReconciliationService
getSitesActon(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgCentralReconciliationService: Step9: return iterator of actions to populate topic
Index Actions: requestId, bucket
getSitesListing(String) - Method in class io.clonecloudstore.reconciliator.server.resource.ReconciliatorResource: Once Local sites listing is ready, inform through Replicator and topic event the Central, then Central will request the listing from remote Local.
getStart() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getStop() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
getTable() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoNativeListingRepository
getTable() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoRequestRepository
getTable() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesActionRepository
getTable() - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesListingRepository
GG_THIS - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils

H

hashCode() - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
hashCode() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
hashCode() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
hashCode() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing

I

importFromExistingBucket(String, String, String, Instant, Instant, long, Map<String, String>) - Method in interface io.clonecloudstore.reconciliator.database.model.InitializationService
importFromExistingBucket(String, String, String, Instant, Instant, long, Map<String, String>) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgInitializationService
IN - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
INITIALIZATION_SERVICE - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgInitializationService
InitializationService - Interface in io.clonecloudstore.reconciliator.database.model
io.clonecloudstore.reconciliator.database.model - package io.clonecloudstore.reconciliator.database.model
io.clonecloudstore.reconciliator.database.mongodb - package io.clonecloudstore.reconciliator.database.mongodb
io.clonecloudstore.reconciliator.server - package io.clonecloudstore.reconciliator.server
io.clonecloudstore.reconciliator.server.resource - package io.clonecloudstore.reconciliator.server.resource
isDryRun() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest

L

launchImport(String, String, long, String) - Method in class io.clonecloudstore.reconciliator.server.resource.ReconciliatorResource: Perform local import actions.
launchPurge(String, long) - Method in class io.clonecloudstore.reconciliator.server.resource.ReconciliatorResource: Perform local purge actions.
launchSync(String, String, long) - Method in class io.clonecloudstore.reconciliator.server.resource.ReconciliatorResource: Perform Sync actions for an "empty" remote Site.
LOCAL - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoSitesListingRepository
LOCAL_NSTATUS - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
LOCAL_O_EVENT - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
LOCAL_RECONCILIATOR - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService
LOCAL_SITE - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
LocalReconciliationService - Interface in io.clonecloudstore.reconciliator.database.model

M

MG_ADD_FIELDS - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_ALL - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_AND - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_ARRAY_ELEM_AT - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_CONCAT - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_CONCAT_ARRAYS - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_COND - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_DISCARD - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_EACH - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_ELEM_MATCH - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_ELSE - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_EQ - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_EXISTS - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_FILTER - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_FROM - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_GTE - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_IF - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_IF_NULL - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_IN - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_INDEX_OF_ARRAY - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_INPUT - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_INSERT - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_INTO - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_KEEP_EXISTING - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_LET - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_LTE - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_MATCH - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_MAX - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_MERGE - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_MERGE_MATCHED - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_MULTIPLY - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_NE - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_NEW - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_NIN - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_NOT - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_ON - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_OR - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_PROJECT - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_PULL - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_PUSH - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_RAND - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_REPLACE - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_SET - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_SET_UNION - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_SIZE - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_SORT - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_THEN - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_THIS - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_TO_LONG - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_TO_STRING - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_UNSET - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_VARS - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_WHEN_MATCHED - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MG_WHEN_NOT_MATCHED - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoReconciliationUtils
MgCentralReconciliationService - Class in io.clonecloudstore.reconciliator.database.mongodb
MgCentralReconciliationService(MgDaoSitesListingRepository, MgDaoSitesActionRepository, MgDaoRequestRepository, BulkMetrics) - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgCentralReconciliationService
MgDaoNativeListing - Class in io.clonecloudstore.reconciliator.database.mongodb: MongoDB DAO for Native (local) listing
MgDaoNativeListing() - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgDaoNativeListing
MgDaoNativeListingRepository - Class in io.clonecloudstore.reconciliator.database.mongodb: MongoDB DAO Bucket Repository
MgDaoNativeListingRepository() - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgDaoNativeListingRepository
MgDaoReconciliationUtils - Class in io.clonecloudstore.reconciliator.database.mongodb
MgDaoRequest - Class in io.clonecloudstore.reconciliator.database.mongodb: MongoDB DAO for Bucket
MgDaoRequest() - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgDaoRequest
MgDaoRequest(ReconciliationRequest) - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgDaoRequest
MgDaoRequestRepository - Class in io.clonecloudstore.reconciliator.database.mongodb: MongoDB DAO Bucket Repository
MgDaoRequestRepository() - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgDaoRequestRepository
MgDaoSitesAction - Class in io.clonecloudstore.reconciliator.database.mongodb: MongoDB DAO for Bucket
MgDaoSitesAction() - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesAction
MgDaoSitesAction(ReconciliationSitesAction) - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesAction
MgDaoSitesActionRepository - Class in io.clonecloudstore.reconciliator.database.mongodb: MongoDB DAO Bucket Repository
MgDaoSitesActionRepository() - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesActionRepository
MgDaoSitesListing - Class in io.clonecloudstore.reconciliator.database.mongodb: MongoDB DAO for Bucket
MgDaoSitesListing() - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesListing
MgDaoSitesListing(ReconciliationSitesListing) - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesListing
MgDaoSitesListingRepository - Class in io.clonecloudstore.reconciliator.database.mongodb: MongoDB DAO Bucket Repository
MgDaoSitesListingRepository() - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesListingRepository
MgInitializationService - Class in io.clonecloudstore.reconciliator.database.mongodb
MgInitializationService(MgDaoAccessorBucketRepository, MgDaoAccessorObjectRepository, MgDaoRequestRepository, MgDaoSitesActionRepository, BulkMetrics) - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgInitializationService
MgLocalReconciliationService - Class in io.clonecloudstore.reconciliator.database.mongodb
MgLocalReconciliationService(MgDaoAccessorObjectRepository, MgDaoNativeListingRepository, MgDaoSitesListingRepository, MgDaoRequestRepository, BulkMetrics) - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService
MgPurgeService - Class in io.clonecloudstore.reconciliator.database.mongodb
MgPurgeService(MgDaoAccessorBucketRepository, MgDaoAccessorObjectRepository, LocalBrokerService, BulkMetrics) - Constructor for class io.clonecloudstore.reconciliator.database.mongodb.MgPurgeService

N

NAME - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoNativeListingRepository
NAME - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoSitesActionRepository
NAME - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoSitesListingRepository
NEED_ACTION - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoSitesActionRepository
NEED_ACTION_FROM - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoSitesActionRepository
NSTATUS - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoNativeListingRepository

P

PURGE_SERVICE - Static variable in class io.clonecloudstore.reconciliator.database.mongodb.MgPurgeService
purgeObjectsOnExpiredDate(String, String, long) - Method in interface io.clonecloudstore.reconciliator.database.model.PurgeService
purgeObjectsOnExpiredDate(String, String, long) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgPurgeService: INDEX : bucket, status, expired
PurgeService - Interface in io.clonecloudstore.reconciliator.database.model

R

READY_RANK - Static variable in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
ReconciliatorResource - Class in io.clonecloudstore.reconciliator.server.resource
ReconciliatorResource(PurgeService, LocalReconciliationService, CentralReconciliationService, InitializationService) - Constructor for class io.clonecloudstore.reconciliator.server.resource.ReconciliatorResource
ReconciliatorServer - Class in io.clonecloudstore.reconciliator.server
REQUESTID - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoNativeListingRepository
REQUESTID - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoSitesActionRepository
REQUESTID - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoSitesListingRepository

S

saveRemoteNativeListing(DaoRequest, Iterator<ReconciliationSitesListing>) - Method in interface io.clonecloudstore.reconciliator.database.model.CentralReconciliationService
saveRemoteNativeListing(DaoRequest, Iterator<ReconciliationSitesListing>) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgCentralReconciliationService: Add the remote sites listing to local aggregate one
Step7: add all remote sites listing
Index Sites: requestId, bucket, name
setActions(long) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setBucket(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
setBucket(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setBucket(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
setBucket(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
setChecked(long) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setCheckedDb(long) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setCheckedDriver(long) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setCheckedRemote(long) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setClientId(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setContextSites(List<String>) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setContextSitesDone(List<String>) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setCurrentSite(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setDb(SingleSiteObject) - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
setDb(SingleSiteObject) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoNativeListing
setDriver(SingleSiteObject) - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
setDriver(SingleSiteObject) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoNativeListing
setDryRun(boolean) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setFilter(AccessorFilter) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setFromSite(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setId(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
setId(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setId(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
setId(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
setId(String) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoNativeListing
setId(String) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoRequest
setId(String) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesAction
setId(String) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesListing
setLocal(List<SingleSiteObject>) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
setLocal(List<SingleSiteObject>) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgDaoSitesListing
setName(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
setName(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
setName(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
setNeedAction(short) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
setNeedActionFrom(List<String>) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
setRequestId(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
setRequestId(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
setRequestId(String) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing
setSites(List<String>) - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
setStart(Instant) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
setStop(Instant) - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
SITE - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoNativeListingRepository
SITES - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoSitesActionRepository
START - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository
STATUS_NAME_ORDERED - Static variable in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
step1CleanUpObjectsNativeListings(DaoRequest) - Method in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
step1CleanUpObjectsNativeListings(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService: Clean Up Native Listing and Objects from status Object
Index Objects: Bucket, Site, Status, creation
step1SubStep1CleanUpStatusUnknownObjectsNativeListings(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService: Clean Up Native Listing and Objects from status Object
Remove UNKNOWN status
Index Objects: Bucket, Site, Status
step1SubStep2CleanUpStatusOlderUploadDeleteCheckObjectsNativeListings(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService: Clean Up Objects ReconciliationStatus from status Object
Index Objects: Bucket, Site, Status, creation
step1SubStep3CleanUpPreviousErrorUploadAndDeletedNativeListing(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService: Clean Up Native Listing from status Object
Remove UNKNOWN, UPLOAD, ERR_UPL, DELETED, ERR_DEL items
Index Objects: Bucket, Site, Status
step2ContinueFromPreviousRequest(String, DaoRequest, boolean) - Method in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
step2ContinueFromPreviousRequest(String, DaoRequest, boolean) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService: 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)
step3SaveNativeListingDb(DaoRequest) - Method in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
step3SaveNativeListingDb(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService: 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
step4SaveNativeListingDriver(DaoRequest) - Method in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
step4SaveNativeListingDriver(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService: Listing according to filter such as now > dateFrom (DRIVER), updating existing info Step4: From Driver to Native
Index Native: requestId, bucket, name
step51InsertMissingObjectsFromExistingDriverIntoObjects(DaoRequest, AtomicReference<CcsDbException>) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService
step52UpsertMissingObjectsFromExistingDriverIntoSiteListing(DaoRequest, AtomicReference<CcsDbException>, BlockingQueue<List<DaoSitesListing>>) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService
step53UpdateWhereNoDriverIntoObjects(DaoRequest, AtomicReference<CcsDbException>) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService
step54UpsertWhereNoDriverIntoSiteListing(DaoRequest, AtomicReference<CcsDbException>) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService
step55UpdateBothDbDriverIntoObjects(DaoRequest, AtomicReference<CcsDbException>) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService
step56UpdateBothDbDriverIntoSiteListing(DaoRequest, AtomicReference<CcsDbException>, BlockingQueue<List<DaoSitesListing>>) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService
step58CountFinalSiteListing(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService
step5CompareNativeListingDbDriver(DaoRequest) - Method in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
step5CompareNativeListingDbDriver(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgLocalReconciliationService: 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
STOP - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository
syncFromExistingSite(String, String, String, AccessorFilter) - Method in interface io.clonecloudstore.reconciliator.database.model.InitializationService
syncFromExistingSite(String, String, String, AccessorFilter) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgInitializationService

T

TABLE_NAME - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoNativeListingRepository
TABLE_NAME - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoRequestRepository
TABLE_NAME - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoSitesActionRepository
TABLE_NAME - Static variable in interface io.clonecloudstore.reconciliator.database.model.DaoSitesListingRepository
TO_UPDATE_RANK - Static variable in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
toString() - Method in class io.clonecloudstore.reconciliator.database.model.DaoNativeListing
toString() - Method in class io.clonecloudstore.reconciliator.database.model.DaoRequest
toString() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesAction
toString() - Method in class io.clonecloudstore.reconciliator.database.model.DaoSitesListing

U

UNKNOWN_RANK - Static variable in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService
updateRequestFromRemoteListing(DaoRequest) - Method in interface io.clonecloudstore.reconciliator.database.model.CentralReconciliationService
updateRequestFromRemoteListing(DaoRequest) - Method in class io.clonecloudstore.reconciliator.database.mongodb.MgCentralReconciliationService
UPLOAD_RANK - Static variable in interface io.clonecloudstore.reconciliator.database.model.LocalReconciliationService

A B C D E F G H I L M N P R S T U
All Classes and Interfaces|All Packages|Constant Field Values