Uses of Class
io.clonecloudstore.common.database.utils.exception.CcsDbException

Packages that use CcsDbException

Package	Description
io.clonecloudstore.accessor.server.database.model
io.clonecloudstore.accessor.server.database.mongodb
io.clonecloudstore.administration.database.model
io.clonecloudstore.administration.database.mongodb
io.clonecloudstore.common.database.mongo
io.clonecloudstore.common.database.postgre
io.clonecloudstore.common.database.utils
io.clonecloudstore.reconciliator.database.model
io.clonecloudstore.reconciliator.database.mongodb

Uses of CcsDbException in io.clonecloudstore.accessor.server.database.model

Methods in io.clonecloudstore.accessor.server.database.model that throw CcsDbException

Modifier and Type	Method	Description
default AccessorBucket	DaoAccessorBucketRepository.findBucketById(String bucketName)	Return the associated bucket
default DaoAccessorObject	DaoAccessorObjectRepository.getObject(String bucket, String objectName)	Get the Object
default DaoAccessorObject	DaoAccessorObjectRepository.getObject(String bucket, String objectName, AccessorStatus status)	Get the Object with same status
default Iterator<DaoAccessorObject>	DaoAccessorObjectRepository.getObjectPrefix(String bucket, String objectNamePrefix, AccessorStatus status)	Get Stream of Objects using prefix on name
default AccessorBucket	DaoAccessorBucketRepository.insertBucket(AccessorBucket bucket)	Insert the given Bucket, returning the modified DTO
default List<AccessorBucket>	DaoAccessorBucketRepository.listBuckets(String clientId)	List all buckets from clientId
default AccessorBucket	DaoAccessorBucketRepository.updateBucketStatus(AccessorBucket bucket, AccessorStatus status, Instant creation)	Update the given Bucket, creation might be null to ignore
default void	DaoAccessorObjectRepository.updateFromDto(DaoAccessorObject daoAccessorObject, AccessorObject accessorObject)	Update if needed Object from DTO
default void	DaoAccessorObjectRepository.updateObjectStatus(String bucketName, String objectName, AccessorStatus status, Instant creation)	Update the Object, creation time might be null to ignore
default void	DaoAccessorObjectRepository.updateObjectStatusHashLen(String bucketName, String objectName, AccessorStatus status, String hash, long len)	Update the Object

Uses of CcsDbException in io.clonecloudstore.accessor.server.database.mongodb

Methods in io.clonecloudstore.accessor.server.database.mongodb that throw CcsDbException

Modifier and Type	Method	Description
void	MgDaoAccessorBucketRepository.createIndex()
void	MgDaoAccessorObjectRepository.createIndex()

Uses of CcsDbException in io.clonecloudstore.administration.database.model

Methods in io.clonecloudstore.administration.database.model that throw CcsDbException

Modifier and Type	Method	Description
default boolean	DaoOwnershipRepository.deleteOwnership(String client, String bucket)
default boolean	DaoOwnershipRepository.deleteOwnerships(String bucket)
default boolean	DaoTopologyRepository.deleteTopology(String site)
default List<ClientBucketAccess>	DaoOwnershipRepository.findAllOwnerships(String client)
default List<Topology>	DaoTopologyRepository.findAllTopologies()
default ClientOwnership	DaoOwnershipRepository.findByBucket(String client, String bucket)
default Topology	DaoTopologyRepository.findBySite(String site)
default List<ClientBucketAccess>	DaoOwnershipRepository.findOwnerships(String client, ClientOwnership ownership)
default List<Topology>	DaoTopologyRepository.findTopologies(TopologyStatus status)
default ClientOwnership	DaoOwnershipRepository.insertOwnership(String client, String bucket, ClientOwnership ownership)
default Topology	DaoTopologyRepository.insertTopology(Topology topology)
default ClientOwnership	DaoOwnershipRepository.updateOwnership(String client, String bucket, ClientOwnership ownership)
default Topology	DaoTopologyRepository.updateTopology(Topology topology)
default Topology	DaoTopologyRepository.updateTopologyStatus(Topology topology, TopologyStatus status)

Uses of CcsDbException in io.clonecloudstore.administration.database.mongodb

Methods in io.clonecloudstore.administration.database.mongodb that throw CcsDbException

Modifier and Type	Method	Description
void	MgDaoOwnershipRepository.createIndex()
void	MgDaoTopologyRepository.createIndex()

Uses of CcsDbException in io.clonecloudstore.common.database.mongo

Methods in io.clonecloudstore.common.database.mongo that throw CcsDbException

Modifier and Type	Method	Description
ExtendedPanacheMongoRepositoryBase<F,E>	ExtendedPanacheMongoRepositoryBase.addToInsertBulk(F so)
ExtendedPanacheMongoRepositoryBase<F,E>	ExtendedPanacheMongoRepositoryBase.addToUpdateBulk(org.bson.Document find, org.bson.Document update)
ExtendedPanacheMongoRepositoryBase<F,E>	ExtendedPanacheMongoRepositoryBase.addToUpsertBulk(org.bson.Document find, F update)
MongoBulkInsertHelper<F,E>	MongoBulkInsertHelper.bulkPersist()	Persist all elements using bulk operation
MongoBulkInsertHelper<F,E>	MongoBulkInsertHelper.bulkUpsert()	Upsert Persist all elements using bulk operation
long	ExtendedPanacheMongoRepositoryBase.count(DbQuery query)
long	ExtendedPanacheMongoRepositoryBase.countAll()
long	ExtendedPanacheMongoRepositoryBase.delete(DbQuery query)
long	ExtendedPanacheMongoRepositoryBase.deleteAllDb()
void	ExtendedPanacheMongoRepositoryBase.deleteWithPk(String pk)
ClosingIterator<F>	ExtendedPanacheMongoRepositoryBase.findIterator(DbQuery query)
ClosingIterator<F>	ExtendedPanacheMongoRepositoryBase.findIterator(org.bson.Document query)
ClosingIterator<E>	MongoStreamHelper.findIterator(ExtendedPanacheMongoRepositoryBase<F,E> repositoryBase, org.bson.Document document)
ClosingIterator<E>	MongoStreamHelper.findIterator(RepositoryBaseInterface<E> repositoryBase, DbQuery query)
F	ExtendedPanacheMongoRepositoryBase.findOne(DbQuery query)
Stream<F>	ExtendedPanacheMongoRepositoryBase.findStream(DbQuery query)
Stream<E>	MongoStreamHelper.findStream(RepositoryBaseInterface<E> repositoryBase, DbQuery query)
F	ExtendedPanacheMongoRepositoryBase.findWithPk(String pk)
void	ExtendedPanacheMongoRepositoryBase.flushAll()
void	ExtendedPanacheMongoRepositoryBase.insert(F item)
long	ExtendedPanacheMongoRepositoryBase.update(DbQuery query, DbUpdate update)
boolean	ExtendedPanacheMongoRepositoryBase.updateFull(F item)

Uses of CcsDbException in io.clonecloudstore.common.database.postgre

Methods in io.clonecloudstore.common.database.postgre that throw CcsDbException

Modifier and Type	Method	Description
ExtendedPanacheRepositoryBase<F,E>	ExtendedPanacheRepositoryBase.addToInsertBulk(F so)	SHall be in an enclosing Transactional to enforce bulk effects
ExtendedPanacheRepositoryBase<F,E>	ExtendedPanacheRepositoryBase.addToUpdateBulk(F so)	SHall be in an enclosing Transactional to enforce bulk effects
long	ExtendedPanacheRepositoryBase.count(DbQuery query)
long	ExtendedPanacheRepositoryBase.countAll()
long	ExtendedPanacheRepositoryBase.delete(DbQuery query)
long	ExtendedPanacheRepositoryBase.deleteAllDb()
void	ExtendedPanacheRepositoryBase.deleteWithPk(String pk)
ClosingIterator<F>	ExtendedPanacheRepositoryBase.findIterator(DbQuery query)
ClosingIterator<E>	PostgreStreamHelper.findIterator(RepositoryBaseInterface<E> repositoryBase, DbQuery query)
F	ExtendedPanacheRepositoryBase.findOne(DbQuery query)
org.hibernate.query.Query<E>	ExtendedPanacheRepositoryBase.findQuery(DbQuery query)	Build the SELECT Hibernate Query from the DbQuery
Stream<F>	ExtendedPanacheRepositoryBase.findStream(DbQuery query)
Stream<E>	PostgreStreamHelper.findStream(RepositoryBaseInterface<E> repositoryBase, DbQuery query)
F	ExtendedPanacheRepositoryBase.findWithPk(String pk)
void	ExtendedPanacheRepositoryBase.flushAll()
org.hibernate.query.Query<E>	ExtendedPanacheRepositoryBase.getSelectQuery(DbQuery dbQuery)	Build the SELECT Hibernate Query from the DbQuery
void	ExtendedPanacheRepositoryBase.insert(F item)
long	ExtendedPanacheRepositoryBase.update(DbQuery query, DbUpdate update)
boolean	ExtendedPanacheRepositoryBase.updateFull(F item)

Uses of CcsDbException in io.clonecloudstore.common.database.utils

Methods in io.clonecloudstore.common.database.utils that throw CcsDbException

Modifier and Type	Method	Description
RepositoryBaseInterface<E>	RepositoryBaseInterface.addToInsertBulk(E so)	Add one element to an insert bulk operation
long	RepositoryBaseInterface.count(DbQuery query)
long	RepositoryBaseInterface.countAll()
long	RepositoryBaseInterface.delete(DbQuery query)
long	RepositoryBaseInterface.deleteAllDb()
void	RepositoryBaseInterface.deleteWithPk(String pk)	Delete the item according to the Primary Key
ClosingIterator<E>	RepositoryBaseInterface.findIterator(DbQuery query)
ClosingIterator<E>	StreamHelperInterface.findIterator(RepositoryBaseInterface<E> repositoryBase, DbQuery query)
E	RepositoryBaseInterface.findOne(DbQuery query)
Stream<E>	RepositoryBaseInterface.findStream(DbQuery query)
Stream<E>	StreamHelperInterface.findStream(RepositoryBaseInterface<E> repositoryBase, DbQuery query)
E	RepositoryBaseInterface.findWithPk(String pk)
void	RepositoryBaseInterface.flushAll()	Force flush of all remaining bulk items, and if supported other items
void	RepositoryBaseInterface.insert(E item)
long	RepositoryBaseInterface.update(DbQuery query, DbUpdate update)
boolean	RepositoryBaseInterface.updateFull(E e)	Update fully this E

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

Methods in io.clonecloudstore.reconciliator.database.model that throw CcsDbException

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	PurgeService.purgeObjectsOnExpiredDate(String clientId, String bucketForReadyExpired, long futureExpireAddSeconds)
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)
DaoRequest	InitializationService.syncFromExistingSite(String clientId, String bucket, String remoteSite, AccessorFilter filter)
void	CentralReconciliationService.updateRequestFromRemoteListing(DaoRequest daoRequest)

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

Method parameters in io.clonecloudstore.reconciliator.database.mongodb with type arguments of type CcsDbException

Modifier and Type	Method	Description
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	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)

Methods in io.clonecloudstore.reconciliator.database.mongodb that throw CcsDbException

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.countFinalActions(DaoRequest daoRequest)
void	MgDaoNativeListingRepository.createIndex()
void	MgDaoRequestRepository.createIndex()
void	MgDaoSitesActionRepository.createIndex()
void	MgDaoSitesListingRepository.createIndex()
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	MgPurgeService.purgeObjectsOnExpiredDate(String clientId, String bucketForReadyExpired, long futureExpireAddSeconds)	INDEX : bucket, status, expired
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.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
DaoRequest	MgInitializationService.syncFromExistingSite(String clientId, String bucket, String remoteSite, AccessorFilter filter)
void	MgCentralReconciliationService.updateRequestFromRemoteListing(DaoRequest daoRequest)