Uses of Class
io.clonecloudstore.common.standard.exception.CcsWithStatusException

Packages that use CcsWithStatusException

Package	Description
io.clonecloudstore.accessor.apache.client
io.clonecloudstore.accessor.client
io.clonecloudstore.accessor.client.internal
io.clonecloudstore.administration.client
io.clonecloudstore.common.quarkus.client
io.clonecloudstore.common.quarkus.client.utils
io.clonecloudstore.common.standard.stream
io.clonecloudstore.reconciliator.database.model
io.clonecloudstore.reconciliator.database.mongodb
io.clonecloudstore.replicator.client
io.clonecloudstore.replicator.server.local.application
io.clonecloudstore.replicator.server.remote.client
io.clonecloudstore.replicator.server.remote.client.api

Uses of CcsWithStatusException in io.clonecloudstore.accessor.apache.client

Methods in io.clonecloudstore.accessor.apache.client that throw CcsWithStatusException

Modifier and Type	Method	Description
StorageType	AccessorClient.checkBucket(String bucketName)
StorageType	AccessorClient.checkObjectOrDirectory(String bucketName, String pathDirectoryOrObject)	Check if object or directory exist
AccessorBucket	AccessorClient.createBucket(String bucketName)
AccessorObject	AccessorClient.createObject(AccessorObject accessorObject, InputStream body)
AccessorObject	AccessorClient.createObject(AccessorObject accessorObject, InputStream body, boolean useCompression)
boolean	AccessorClient.deleteBucket(String bucketName)
boolean	AccessorClient.deleteObject(String bucketName, String objectName)
AccessorBucket	AccessorClient.getBucket(String bucketName)
Collection<AccessorBucket>	AccessorClient.getBuckets()
InputStreamBusinessOut<AccessorObject>	AccessorClient.getObject(String bucketName, String objectName)
InputStreamBusinessOut<AccessorObject>	AccessorClient.getObject(String bucketName, String objectName, boolean compressed)	Note: Compression is only between client and server, result InputStream is uncompressed
AccessorObject	AccessorClient.getObjectInfo(String bucketName, String objectName)
Iterator<AccessorObject>	AccessorClient.listObjects(String bucketName, AccessorFilter filter)	Returns an Iterator containing AccessorObjects

Uses of CcsWithStatusException in io.clonecloudstore.accessor.client

Methods in io.clonecloudstore.accessor.client that throw CcsWithStatusException

Modifier and Type	Method	Description
StorageType	AccessorBucketApiClient.checkBucket(String bucketName, String clientId)
StorageType	AccessorObjectApiClient.checkObjectOrDirectory(String bucketName, String pathDirectoryOrObject, String clientId)	Check if object or directory exist
AccessorBucket	AccessorBucketApiClient.createBucket(String bucketName, String clientId)
AccessorObject	AccessorObjectApiClient.createObject(AccessorObject accessorObject, String clientId, InputStream body)
AccessorObject	AccessorObjectApiClient.createObject(AccessorObject accessorObject, String clientId, InputStream body, boolean compressed)
boolean	AccessorBucketApiClient.deleteBucket(String bucketName, String clientId)
boolean	AccessorObjectApiClient.deleteObject(String bucketName, String objectName, String clientId)
AccessorBucket	AccessorBucketApiClient.getBucket(String bucketName, String clientId)
Collection<AccessorBucket>	AccessorBucketApiClient.getBuckets(String clientId)
InputStreamBusinessOut<AccessorObject>	AccessorObjectApiClient.getObject(String bucketName, String objectName, String clientId)
InputStreamBusinessOut<AccessorObject>	AccessorObjectApiClient.getObject(String bucketName, String objectName, String clientId, boolean compressed)	Note: Compression is only between client and server, result InputStream is uncompressed
AccessorObject	AccessorObjectApiClient.getObjectInfo(String bucketName, String objectName, String clientId)
Iterator<AccessorObject>	AccessorObjectApiClient.listObjects(String bucketName, String clientId, AccessorFilter filter)	Returns an Iterator containing AccessorObjects

Uses of CcsWithStatusException in io.clonecloudstore.accessor.client.internal

Methods in io.clonecloudstore.accessor.client.internal that throw CcsWithStatusException

Modifier and Type	Method	Description
StorageType	AccessorBucketInternalApiClient.checkBucket(String bucketName, String clientId, boolean fullCheck)
StorageType	AccessorObjectInternalApiClient.checkObjectOrDirectory(String bucketName, String pathDirectoryOrObject, String clientId, boolean fullCheck)	Check if object or directory exist
AccessorBucket	AccessorBucketInternalApiClient.getBucket(String bucketName, String clientId)
Collection<AccessorBucket>	AccessorBucketInternalApiClient.getBuckets(String clientId)
InputStreamBusinessOut<AccessorObject>	AccessorObjectInternalApiClient.getObject(String bucketName, String objectName, String clientId)
InputStreamBusinessOut<AccessorObject>	AccessorObjectInternalApiClient.getObject(String bucketName, String objectName, String clientId, boolean decompress)	Returns the InputStream and the AccessorObject
AccessorObject	AccessorObjectInternalApiClient.getObjectInfo(String bucketName, String objectName, String clientId)
Iterator<AccessorObject>	AccessorObjectInternalApiClient.listObjects(String bucketName, String clientId, AccessorFilter filter)	Returns an Iterator containing AccessorObjects

Uses of CcsWithStatusException in io.clonecloudstore.administration.client

Methods in io.clonecloudstore.administration.client that throw CcsWithStatusException

Modifier and Type	Method	Description
ClientOwnership	OwnershipApiClient.add(String clientId, String bucket, ClientOwnership ownership)	Invalidate Cache
Topology	TopologyApiClient.add(Topology topology)	Invalidate Cache
boolean	OwnershipApiClient.delete(String clientId, String bucket)	Invalidate Cache
boolean	TopologyApiClient.delete(String site)	Invalidate Cache
ClientOwnership	OwnershipApiClient.findByBucket(String clientId, String bucket)	Cache if possible
Topology	TopologyApiClient.findBySite(String site)	Cache if possible
boolean	OwnershipApiClient.getBooleanFromAsync(CompletableFuture<jakarta.ws.rs.core.Response> completableFuture)
ClientOwnership	OwnershipApiClient.getClientOwnershipFromAsync(CompletableFuture<ClientOwnership> completableFuture)
Collection<ClientBucketAccess>	OwnershipApiClient.listAll(String clientId)	Cache on ALL_FROM + clientId
Collection<Topology>	TopologyApiClient.listAll()	No cache
Collection<ClientBucketAccess>	OwnershipApiClient.listWithOwnership(String clientId, ClientOwnership ownership)	Cache if possible
Collection<Topology>	TopologyApiClient.listWithStatus(TopologyStatus status)	Cache on ALL_UP_KEY
ClientOwnership	OwnershipApiClient.update(String clientId, String bucket, ClientOwnership ownership)	Invalidate Cache
Topology	TopologyApiClient.update(Topology topology)	Invalidate Cache

Uses of CcsWithStatusException in io.clonecloudstore.common.quarkus.client

Methods in io.clonecloudstore.common.quarkus.client that throw CcsWithStatusException

Modifier and Type	Method	Description
protected InputStreamBusinessOut<O>	ClientAbstract.getInputStreamBusinessOutFromUni(boolean shallDecompress, io.smallrye.mutiny.Uni<InputStream> inputStreamUni)
protected O	ClientAbstract.getResultFromPostInputStreamUni(io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> uni, InputStream sendInputStream)

Uses of CcsWithStatusException in io.clonecloudstore.common.quarkus.client.utils

Methods in io.clonecloudstore.common.quarkus.client.utils that return CcsWithStatusException

Modifier and Type	Method	Description
static CcsWithStatusException	ClientResponseExceptionMapper.getBusinessException(jakarta.ws.rs.WebApplicationException e)	Web Application Exception (Runtime) to Ccs With Status Exception (Exception)

Methods in io.clonecloudstore.common.quarkus.client.utils that throw CcsWithStatusException

Modifier and Type	Method	Description
Object	ClientResponseExceptionMapper.handleCompletableObject(SimpleClientAbstract<?> simpleClientAbstract, CompletableFuture<?> completableFuture)
jakarta.ws.rs.core.Response	ClientResponseExceptionMapper.handleCompletableResponse(CompletableFuture<jakarta.ws.rs.core.Response> completableFuture)
Object	ClientResponseExceptionMapper.handleUniObject(SimpleClientAbstract<?> simpleClientAbstract, io.smallrye.mutiny.Uni<?> uni)
Object	ClientResponseExceptionMapper.handleUniObject(SimpleClientAbstract<?> simpleClientAbstract, io.smallrye.mutiny.Uni<?> uni, InputStream inputStreamOptional)
jakarta.ws.rs.core.Response	ClientResponseExceptionMapper.handleUniResponse(io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> uni)	Default handling for Uni Response (not for InputStream)
void	ClientResponseExceptionMapper.responseToExceptionIfError(jakarta.ws.rs.core.Response response)	Generate a CcsWithStatusException if needed

Uses of CcsWithStatusException in io.clonecloudstore.common.standard.stream

Methods in io.clonecloudstore.common.standard.stream that throw CcsWithStatusException

Modifier and Type	Method	Description
static <E> Stream<E>	StreamIteratorUtils.getStreamFromInputStream(InputStream inputStream, Class<E> forClass)

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

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

Modifier and Type	Method	Description
void	InitializationService.importFromExistingBucket(String clientId, String bucket, String prefix, Instant from, Instant to, long futureExpireAddSeconds, Map<String,String> defaultMetadata)

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

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

Modifier and Type	Method	Description
void	MgInitializationService.importFromExistingBucket(String clientId, String bucket, String prefix, Instant from, Instant to, long futureExpireAddSeconds, Map<String,String> defaultMetadata)

Uses of CcsWithStatusException in io.clonecloudstore.replicator.client

Methods in io.clonecloudstore.replicator.client that throw CcsWithStatusException

Modifier and Type	Method	Description
ReplicatorResponse<StorageType>	LocalReplicatorApiClient.checkBucket(String bucket, boolean fullCheck, String clientId, String opId)
ReplicatorResponse<StorageType>	LocalReplicatorApiClient.checkBucket(String bucket, boolean fullCheck, String clientId, String targetId, String opId)
ReplicatorResponse<StorageType>	LocalReplicatorApiClient.checkObjectOrDirectory(String bucket, String pathDirectoryOrObject, boolean fullCheck, String clientId, String opId)
ReplicatorResponse<StorageType>	LocalReplicatorApiClient.checkObjectOrDirectory(String bucket, String pathDirectoryOrObject, boolean fullCheck, String clientId, String targetId, String opId)
ReplicatorResponse<AccessorBucket>	LocalReplicatorApiClient.getBucket(String bucket, String clientId, String opId)
ReplicatorResponse<AccessorBucket>	LocalReplicatorApiClient.getBucket(String bucket, String clientId, String targetId, String opId)
InputStreamBusinessOut<AccessorObject>	LocalReplicatorApiClient.readRemoteObject(String bucket, String object, String clientId, String targetId, String opId)
InputStreamBusinessOut<AccessorObject>	LocalReplicatorApiClient.readRemoteObject(String bucket, String object, String clientId, String targetId, String opId, boolean decompress)

Uses of CcsWithStatusException in io.clonecloudstore.replicator.server.local.application

Methods in io.clonecloudstore.replicator.server.local.application that throw CcsWithStatusException

Modifier and Type	Method	Description
Optional<Topology>	LocalReplicatorService.findValidTopologyBucket(String bucket, boolean fullCheck, String clientId, String topologyId, String opId)
Optional<Topology>	LocalReplicatorService.findValidTopologyObject(String bucket, String objectName, boolean fullCheck, String clientId, String topologyId, String opId)
AccessorBucket	LocalReplicatorService.getBucket(String bucket, String clientId, Topology topology, String opId)
Collection<Topology>	LocalReplicatorService.getTopologies(String topologyId)

Uses of CcsWithStatusException in io.clonecloudstore.replicator.server.remote.client

Methods in io.clonecloudstore.replicator.server.remote.client that throw CcsWithStatusException

Modifier and Type	Method	Description
StorageType	RemoteReplicatorApiClient.checkBucket(String bucket, boolean fullCheck, String clientId, String opId)	Not Cached
StorageType	RemoteReplicatorApiClient.checkBucketCache(String bucket, boolean fullCheck, String clientId, String opId)	Cached response
StorageType	RemoteReplicatorApiClient.checkObjectOrDirectory(String bucket, String pathDirectoryOrObject, boolean fullCheck, String clientId, String opId)	Not Cached
StorageType	RemoteReplicatorApiClient.checkObjectOrDirectoryCache(String bucket, String pathDirectoryOrObject, boolean fullCheck, String clientId, String opId)	Cached response
AccessorBucket	RemoteReplicatorApiClient.getBucket(String bucket, String clientId, String opId)	Not Cached
InputStreamBusinessOut<AccessorObject>	RemoteReplicatorApiClient.readRemoteObject(String bucket, String object, String clientId, String opId, long len)

Uses of CcsWithStatusException in io.clonecloudstore.replicator.server.remote.client.api

Methods in io.clonecloudstore.replicator.server.remote.client.api that throw CcsWithStatusException

Modifier and Type	Method	Description
StorageType	RemoteReplicatorClientApiService.checkBucket(RemoteReplicatorApi client, String bucket, boolean fullCheck, String clientId, String opId)
StorageType	RemoteReplicatorClientApiService.checkBucketCache(RemoteReplicatorApi client, URI uri, String bucket, boolean fullCheck, String clientId, String opId)
StorageType	RemoteReplicatorClientApiService.checkObjectOrDirectory(RemoteReplicatorApi client, String bucket, String pathDirectoryOrObject, boolean fullCheck, String clientId, String opId)
StorageType	RemoteReplicatorClientApiService.checkObjectOrDirectoryCache(RemoteReplicatorApi client, URI uri, String bucket, String pathDirectoryOrObject, boolean fullCheck, String clientId, String opId)
AccessorBucket	RemoteReplicatorClientApiService.getBucket(RemoteReplicatorApiClient upperClient, RemoteReplicatorApi client, String bucket, String clientId, String opId)