Package io.clonecloudstore.replicator.client

Class LocalReplicatorApiClient

java.lang.Object

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

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

io.clonecloudstore.replicator.client.LocalReplicatorApiClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class LocalReplicatorApiClient
extends ClientAbstract<ReplicatorOrder,AccessorObject,LocalReplicatorApi>

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

Method Summary

Modifier and Type	Method	Description
ReplicatorResponse<StorageType>	checkBucket(String bucket, boolean fullCheck, String clientId, String opId)
ReplicatorResponse<StorageType>	checkBucket(String bucket, boolean fullCheck, String clientId, String targetId, String opId)
ReplicatorResponse<StorageType>	checkObjectOrDirectory(String bucket, String pathDirectoryOrObject, boolean fullCheck, String clientId, String opId)
ReplicatorResponse<StorageType>	checkObjectOrDirectory(String bucket, String pathDirectoryOrObject, boolean fullCheck, String clientId, String targetId, String opId)
protected AccessorObject	getApiBusinessOutFromResponseForCreate(jakarta.ws.rs.core.Response response)
ReplicatorResponse<AccessorBucket>	getBucket(String bucket, String clientId, String opId)
ReplicatorResponse<AccessorBucket>	getBucket(String bucket, String clientId, String targetId, String opId)
protected Map<String,String>	getHeadersFor(ReplicatorOrder businessIn, int context)
InputStreamBusinessOut<AccessorObject>	readRemoteObject(String bucket, String object, String clientId, String targetId, String opId)
InputStreamBusinessOut<AccessorObject>	readRemoteObject(String bucket, String object, String clientId, String targetId, String opId, boolean decompress)

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

LocalReplicatorApiClient

protected LocalReplicatorApiClient(LocalReplicatorApiClientFactory factory)

Constructor used by the Factory

Method Details

getBucket

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

Throws:

CcsWithStatusException

getBucket

public ReplicatorResponse<AccessorBucket> getBucket(String bucket,
 String clientId,
 String targetId,
 String opId)
                                             throws CcsWithStatusException

Throws:

CcsWithStatusException

checkBucket

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

Throws:

CcsWithStatusException

checkBucket

public ReplicatorResponse<StorageType> checkBucket(String bucket,
 boolean fullCheck,
 String clientId,
 String targetId,
 String opId)
                                            throws CcsWithStatusException

Throws:

CcsWithStatusException

checkObjectOrDirectory

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

Throws:

CcsWithStatusException

checkObjectOrDirectory

public ReplicatorResponse<StorageType> checkObjectOrDirectory(String bucket,
 String pathDirectoryOrObject,
 boolean fullCheck,
 String clientId,
 String targetId,
 String opId)
                                                       throws CcsWithStatusException

Throws:

CcsWithStatusException

readRemoteObject

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

Throws:

CcsWithStatusException

readRemoteObject

public InputStreamBusinessOut<AccessorObject> readRemoteObject(String bucket,
 String object,
 String clientId,
 String targetId,
 String opId,
 boolean decompress)
                                                        throws CcsWithStatusException

Throws:

CcsWithStatusException

getApiBusinessOutFromResponseForCreate

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

Specified by:

getApiBusinessOutFromResponseForCreate in class ClientAbstract<ReplicatorOrder,AccessorObject,LocalReplicatorApi>

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,LocalReplicatorApi>

Parameters:

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

Returns:

the headers map