Package io.clonecloudstore.replicator.server.remote.client

Class RemoteReplicatorApiClient

java.lang.Object

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

io.clonecloudstore.common.quarkus.client.ClientAbstract<ReplicatorOrder,AccessorObject,RemoteReplicatorApi>

io.clonecloudstore.replicator.server.remote.client.RemoteReplicatorApiClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class RemoteReplicatorApiClient
extends ClientAbstract<ReplicatorOrder,AccessorObject,RemoteReplicatorApi>

Field Summary

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

CONTEXT_RECEIVE, CONTEXT_SENDING

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	RemoteReplicatorApiClient(RemoteReplicatorApiClientFactory factory)	Constructor used by the Factory

Method Summary

Modifier and Type	Method	Description
StorageType	checkBucket(String bucket, boolean fullCheck, String clientId, String opId)	Not Cached
StorageType	checkBucketCache(String bucket, boolean fullCheck, String clientId, String opId)	Cached response
StorageType	checkObjectOrDirectory(String bucket, String pathDirectoryOrObject, boolean fullCheck, String clientId, String opId)	Not Cached
StorageType	checkObjectOrDirectoryCache(String bucket, String pathDirectoryOrObject, boolean fullCheck, String clientId, String opId)	Cached response
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	createOrder(ReplicatorOrder replicatorOrder)
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	createOrders(List<ReplicatorOrder> replicatorOrders)
protected AccessorObject	getApiBusinessOutFromResponseForCreate(jakarta.ws.rs.core.Response response)
AccessorBucket	getBucket(String bucket, String clientId, String opId)	Not Cached
protected Map<String,String>	getHeadersFor(ReplicatorOrder businessIn, int context)
InputStreamBusinessOut<AccessorObject>	readRemoteObject(String bucket, String object, String clientId, String opId, long len)

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

getFactory, getInputStreamBusinessOutFromUni, getResultFromPostInputStreamUni, prepareInputStreamToReceive, prepareInputStreamToSend

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

acceptCompression, bodyCompressed, close, getCompressionStatusFromHeaders, getDtoFromHeaders, 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

RemoteReplicatorApiClient

protected RemoteReplicatorApiClient(RemoteReplicatorApiClientFactory factory)

Constructor used by the Factory

Method Details

checkBucketCache

public StorageType checkBucketCache(String bucket,
 boolean fullCheck,
 String clientId,
 String opId)
                             throws CcsWithStatusException

Cached response

Throws:

CcsWithStatusException

checkObjectOrDirectoryCache

public StorageType checkObjectOrDirectoryCache(String bucket,
 String pathDirectoryOrObject,
 boolean fullCheck,
 String clientId,
 String opId)
                                        throws CcsWithStatusException

Cached response

Throws:

CcsWithStatusException

checkBucket

public StorageType checkBucket(String bucket,
 boolean fullCheck,
 String clientId,
 String opId)
                        throws CcsWithStatusException

Not Cached

Throws:

CcsWithStatusException

getBucket

public AccessorBucket getBucket(String bucket,
 String clientId,
 String opId)
                         throws CcsWithStatusException

Not Cached

Throws:

CcsWithStatusException

checkObjectOrDirectory

public StorageType checkObjectOrDirectory(String bucket,
 String pathDirectoryOrObject,
 boolean fullCheck,
 String clientId,
 String opId)
                                   throws CcsWithStatusException

Not Cached

Throws:

CcsWithStatusException

readRemoteObject

public InputStreamBusinessOut<AccessorObject> readRemoteObject(String bucket,
 String object,
 String clientId,
 String opId,
 long len)
                                                        throws CcsWithStatusException

Throws:

CcsWithStatusException

createOrder

public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> createOrder(ReplicatorOrder replicatorOrder)

createOrders

public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> createOrders(List<ReplicatorOrder> replicatorOrders)

getApiBusinessOutFromResponseForCreate

protected AccessorObject getApiBusinessOutFromResponseForCreate(jakarta.ws.rs.core.Response response)

Specified by:

getApiBusinessOutFromResponseForCreate in class ClientAbstract<ReplicatorOrder,AccessorObject,RemoteReplicatorApi>

Returns:

the BusinessOut from the response content and/or headers for Create Operation

getHeadersFor

protected Map<String,String> getHeadersFor(ReplicatorOrder businessIn,
 int context)

Specified by:

getHeadersFor in class ClientAbstract<ReplicatorOrder,AccessorObject,RemoteReplicatorApi>

Parameters:

context - 1 for sending InputStream, -1 for receiving InputStream, or anything else

Returns:

the headers map