Package io.clonecloudstore.administration.client

Class OwnershipApiClient

java.lang.Object

io.clonecloudstore.common.quarkus.client.SimpleClientAbstract<OwnershipApi>

io.clonecloudstore.administration.client.OwnershipApiClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class OwnershipApiClient
extends SimpleClientAbstract<OwnershipApi>

Field Summary

Fields inherited from class io.clonecloudstore.common.quarkus.client.SimpleClientAbstract

exceptionMapper, MDC_COMPRESSED_CONTENT, MDC_COMPRESSED_RESPONSE, MDC_QUERY_HEADERS

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	OwnershipApiClient(OwnershipApiClientFactory factory)	Constructor used by the Factory

Method Summary

Modifier and Type	Method	Description
ClientOwnership	add(String clientId, String bucket, ClientOwnership ownership)	Invalidate Cache
CompletableFuture<ClientOwnership>	addAsync(String clientId, String bucket, ClientOwnership ownership)	Invalidate Cache and async method
boolean	delete(String clientId, String bucket)	Invalidate Cache
CompletableFuture<jakarta.ws.rs.core.Response>	deleteAllClientsAsync(String bucket)	Invalidate Cache and async method
ClientOwnership	findByBucket(String clientId, String bucket)	Cache if possible
boolean	getBooleanFromAsync(CompletableFuture<jakarta.ws.rs.core.Response> completableFuture)
ClientOwnership	getClientOwnershipFromAsync(CompletableFuture<ClientOwnership> completableFuture)
Collection<ClientBucketAccess>	listAll(String clientId)	Cache on ALL_FROM + clientId
Collection<ClientBucketAccess>	listWithOwnership(String clientId, ClientOwnership ownership)	Cache if possible
ClientOwnership	update(String clientId, String bucket, ClientOwnership ownership)	Invalidate Cache

Methods inherited from class io.clonecloudstore.common.quarkus.client.SimpleClientAbstract

acceptCompression, bodyCompressed, close, getCompressionStatusFromHeaders, getDtoFromHeaders, getFactory, getHeadersMap, getMdcOpId, getOpId, getService, getUri, isAcceptCompression, isBodyCompressed, reopen, resetMdcOpId, resetQueryContext, setCompressionStatusFromHeaders, setDtoFromHeaders, setHeadersMap, setMdcOpId, setOpId

Methods inherited from class java.lang.Object

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

Constructor Details

OwnershipApiClient

protected OwnershipApiClient(OwnershipApiClientFactory factory)

Constructor used by the Factory

Method Details

listAll

public Collection<ClientBucketAccess> listAll(String clientId)
                                       throws io.clonecloudstore.common.standard.exception.CcsWithStatusException

Cache on ALL_FROM + clientId

Throws:

io.clonecloudstore.common.standard.exception.CcsWithStatusException

listWithOwnership

public Collection<ClientBucketAccess> listWithOwnership(String clientId,
 ClientOwnership ownership)
                                                 throws io.clonecloudstore.common.standard.exception.CcsWithStatusException

Cache if possible

Throws:

io.clonecloudstore.common.standard.exception.CcsWithStatusException

findByBucket

public ClientOwnership findByBucket(String clientId,
 String bucket)
                             throws io.clonecloudstore.common.standard.exception.CcsWithStatusException

Cache if possible

Throws:

io.clonecloudstore.common.standard.exception.CcsWithStatusException

add

public ClientOwnership add(String clientId,
 String bucket,
 ClientOwnership ownership)
                    throws io.clonecloudstore.common.standard.exception.CcsWithStatusException

Invalidate Cache

Throws:

io.clonecloudstore.common.standard.exception.CcsWithStatusException

addAsync

public CompletableFuture<ClientOwnership> addAsync(String clientId,
 String bucket,
 ClientOwnership ownership)

Invalidate Cache and async method

getClientOwnershipFromAsync

public ClientOwnership getClientOwnershipFromAsync(CompletableFuture<ClientOwnership> completableFuture)
                                            throws io.clonecloudstore.common.standard.exception.CcsWithStatusException

Returns:

the final result

Throws:

io.clonecloudstore.common.standard.exception.CcsWithStatusException - if any error occurs

update

public ClientOwnership update(String clientId,
 String bucket,
 ClientOwnership ownership)
                       throws io.clonecloudstore.common.standard.exception.CcsWithStatusException

Invalidate Cache

Throws:

io.clonecloudstore.common.standard.exception.CcsWithStatusException

delete

public boolean delete(String clientId,
 String bucket)
               throws io.clonecloudstore.common.standard.exception.CcsWithStatusException

Invalidate Cache

Throws:

io.clonecloudstore.common.standard.exception.CcsWithStatusException

deleteAllClientsAsync

public CompletableFuture<jakarta.ws.rs.core.Response> deleteAllClientsAsync(String bucket)

Invalidate Cache and async method

getBooleanFromAsync

public boolean getBooleanFromAsync(CompletableFuture<jakarta.ws.rs.core.Response> completableFuture)
                            throws io.clonecloudstore.common.standard.exception.CcsWithStatusException

Returns:

the final result

Throws:

io.clonecloudstore.common.standard.exception.CcsWithStatusException - if any error occurs