Package io.clonecloudstore.accessor.client.internal

Class AccessorObjectInternalApiClient

java.lang.Object

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

io.clonecloudstore.common.quarkus.client.ClientAbstract<AccessorObject,AccessorObject,AccessorObjectInternalApi>

io.clonecloudstore.accessor.client.internal.AccessorObjectInternalApiClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class AccessorObjectInternalApiClient
extends ClientAbstract<AccessorObject,AccessorObject,AccessorObjectInternalApi>

Client for Accessor Object

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

Method Summary

Modifier and Type	Method	Description
StorageType	checkObjectOrDirectory(String bucketName, String pathDirectoryOrObject, String clientId, boolean fullCheck)	Check if object or directory exist
protected AccessorObject	getApiBusinessOutFromResponseForCreate(jakarta.ws.rs.core.Response response)
protected Map<String,String>	getHeadersFor(AccessorObject businessIn, int context)
InputStreamBusinessOut<AccessorObject>	getObject(String bucketName, String objectName, String clientId)
InputStreamBusinessOut<AccessorObject>	getObject(String bucketName, String objectName, String clientId, boolean decompress)	Returns the InputStream and the AccessorObject
AccessorObject	getObjectInfo(String bucketName, String objectName, String clientId)
Iterator<AccessorObject>	listObjects(String bucketName, String clientId, AccessorFilter filter)	Returns an Iterator containing AccessorObjects

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

AccessorObjectInternalApiClient

protected AccessorObjectInternalApiClient(AccessorObjectInternalApiFactory factory)

Constructor used by the Factory

Method Details

checkObjectOrDirectory

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

Check if object or directory exist

Parameters:

pathDirectoryOrObject - may contain only directory, not full path (as prefix)

fullCheck - if True, will check on Object Storage if Object only

Returns:

the associated StorageType

Throws:

CcsWithStatusException

getObjectInfo

public AccessorObject getObjectInfo(String bucketName,
 String objectName,
 String clientId)
                             throws CcsWithStatusException

Returns:

the associated DTO

Throws:

CcsWithStatusException

getObject

public InputStreamBusinessOut<AccessorObject> getObject(String bucketName,
 String objectName,
 String clientId)
                                                 throws CcsWithStatusException

Throws:

CcsWithStatusException

getObject

public InputStreamBusinessOut<AccessorObject> getObject(String bucketName,
 String objectName,
 String clientId,
 boolean decompress)
                                                 throws CcsWithStatusException

Returns the InputStream and the AccessorObject

Throws:

CcsWithStatusException

listObjects

public Iterator<AccessorObject> listObjects(String bucketName,
 String clientId,
 AccessorFilter filter)
                                     throws CcsWithStatusException

Returns an Iterator containing AccessorObjects

Throws:

CcsWithStatusException

getApiBusinessOutFromResponseForCreate

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

Specified by:

getApiBusinessOutFromResponseForCreate in class ClientAbstract<AccessorObject,AccessorObject,AccessorObjectInternalApi>

Returns:

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

getHeadersFor

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

Specified by:

getHeadersFor in class ClientAbstract<AccessorObject,AccessorObject,AccessorObjectInternalApi>

Parameters:

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

Returns:

the headers map