Package io.clonecloudstore.accessor.server.commons

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

java.lang.Object

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

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

Direct Known Subclasses:

AbstractAccessorPrivateObjectResource, FakeObjectPrivateAbstract

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractPrivateObjectHelper(AccessorObjectServiceInterface service)

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	checkObjectOrDirectory(String bucketName, String pathDirectoryOrObject, boolean fullCheck, String clientId, String opId)
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

AbstractPrivateObjectHelper

protected AbstractPrivateObjectHelper(AccessorObjectServiceInterface service)

Method Details

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,
 boolean fullCheck,
 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

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