Package io.clonecloudstore.accessor.server.commons

Class AbstractPublicObjectHelper<H extends StreamHandlerAbstract<AccessorObject,AccessorObject>>

java.lang.Object

io.clonecloudstore.common.quarkus.server.service.StreamServiceAbstract<AccessorObject,AccessorObject,H>

io.clonecloudstore.accessor.server.commons.AbstractPublicObjectHelper<H>

Direct Known Subclasses:

AbstractAccessorPublicObjectResource

public abstract class AbstractPublicObjectHelper<H extends StreamHandlerAbstract<AccessorObject,AccessorObject>>
extends StreamServiceAbstract<AccessorObject,AccessorObject,H>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractPublicObjectHelper(AccessorObjectServiceInterface service)

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	checkObjectOrDirectory(String bucketName, String pathDirectoryOrObject, String clientId, String opId)
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	createObject(io.vertx.core.http.HttpServerRequest request, io.quarkus.resteasy.reactive.server.Closer closer, String bucketName, String objectName, String contentTypeHeader, String contentEncodingHeader, String clientId, String opId, String xObjectId, String xObjectSite, String xObjectBucket, String xObjectName, long xObjectSize, String xObjectHash, String xObjectMetadata, String xObjectExpires, InputStream inputStream)	Create the Object and returns the associated DTO
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	deleteObject(String bucketName, String objectName, String clientId, String opId)
static AccessorObject	getFromStorageObject(StorageObject storageObject)	Transform StorageObject to AccessorObject without Id
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	getObject(String bucketName, String objectName, String acceptHeader, String acceptEncodingHeader, String clientId, String opId, io.vertx.core.http.HttpServerRequest request, io.quarkus.resteasy.reactive.server.Closer closer)	Returns both the content Object and the associated DTO through Headers
io.smallrye.mutiny.Uni<AccessorObject>	getObjectInfo(String bucketName, String objectName, String clientId, String opId)
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	listObjects(String bucketName, String acceptHeader, String acceptEncodingHeader, String clientId, String opId, String xNamePrefix, String xStatuses, String xCreationBefore, String xCreationAfter, String xExpiresBefore, String xExpiresAfter, long xSizeLt, long xSizeGt, String xMetadataEq, io.vertx.core.http.HttpServerRequest request, io.quarkus.resteasy.reactive.server.Closer closer)
protected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	readObjectList(io.vertx.core.http.HttpServerRequest request, io.quarkus.resteasy.reactive.server.Closer closer, AccessorObject businessIn, boolean alreadyCompressed)	Listing of Objects

Methods inherited from class io.clonecloudstore.common.quarkus.server.service.StreamServiceAbstract

createErrorResponse, createObject, createObject, getNativeStream, readObject

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractPublicObjectHelper

protected AbstractPublicObjectHelper(AccessorObjectServiceInterface service)

Method Details

getFromStorageObject

public static AccessorObject getFromStorageObject(StorageObject storageObject)

Transform StorageObject to AccessorObject without Id

listObjects

public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> listObjects(String bucketName,
 String acceptHeader,
 String acceptEncodingHeader,
 String clientId,
 String opId,
 String xNamePrefix,
 String xStatuses,
 String xCreationBefore,
 String xCreationAfter,
 String xExpiresBefore,
 String xExpiresAfter,
 long xSizeLt,
 long xSizeGt,
 String xMetadataEq,
 io.vertx.core.http.HttpServerRequest request,
 io.quarkus.resteasy.reactive.server.Closer closer)

checkObjectOrDirectory

public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> checkObjectOrDirectory(String bucketName,
 String pathDirectoryOrObject,
 String clientId,
 String opId)

getObjectInfo

public io.smallrye.mutiny.Uni<AccessorObject> getObjectInfo(String bucketName,
 String objectName,
 String clientId,
 String opId)

getObject

public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> getObject(String bucketName,
 String objectName,
 String acceptHeader,
 String acceptEncodingHeader,
 String clientId,
 String opId,
 io.vertx.core.http.HttpServerRequest request,
 io.quarkus.resteasy.reactive.server.Closer closer)

Returns both the content Object and the associated DTO through Headers

createObject

public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> createObject(io.vertx.core.http.HttpServerRequest request,
 io.quarkus.resteasy.reactive.server.Closer closer,
 String bucketName,
 String objectName,
 String contentTypeHeader,
 String contentEncodingHeader,
 String clientId,
 String opId,
 String xObjectId,
 String xObjectSite,
 String xObjectBucket,
 String xObjectName,
 long xObjectSize,
 String xObjectHash,
 String xObjectMetadata,
 String xObjectExpires,
 InputStream inputStream)

Create the Object and returns the associated DTO

deleteObject

public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> deleteObject(String bucketName,
 String objectName,
 String clientId,
 String opId)

readObjectList

protected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> readObjectList(io.vertx.core.http.HttpServerRequest request,
 io.quarkus.resteasy.reactive.server.Closer closer,
 AccessorObject businessIn,
 boolean alreadyCompressed)

Listing of Objects

Parameters:

alreadyCompressed - If True, and if the InputStream is to be compressed, will be kept as is; else will compress the InputStream if it has to be