Package io.clonecloudstore.accessor.server.commons

Class AbstractAccessorPublicObjectResource<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>

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

Direct Known Subclasses:

AccessorPublicObjectResource, AccessorPublicObjectResource, FakeAccessorObjectPublicAbstract

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractAccessorPublicObjectResource(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)
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)

Methods inherited from class io.clonecloudstore.accessor.server.commons.AbstractPublicObjectHelper

getFromStorageObject, readObjectList

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

AbstractAccessorPublicObjectResource

protected AbstractAccessorPublicObjectResource(AccessorObjectServiceInterface service)

Method Details

listObjects

@Path("{bucketName}")
@PUT
@Produces("application/octet-stream")
public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> listObjects(@PathParam("bucketName")
 String bucketName,
 @HeaderParam("Accept")
 String acceptHeader,
 @HeaderParam("Accept-Encoding")
 String acceptEncodingHeader,
 @HeaderParam("x-clonecloudstore-client-id")
 String clientId,
 @HeaderParam("x-clonecloudstore-op-id")
 String opId,
 @HeaderParam("x-clonecloudstore-namePrefix")
 String xNamePrefix,
 @HeaderParam("x-clonecloudstore-statuses")
 String xStatuses,
 @HeaderParam("x-clonecloudstore-creationBefore")
 String xCreationBefore,
 @HeaderParam("x-clonecloudstore-creationAfter")
 String xCreationAfter,
 @HeaderParam("x-clonecloudstore-expiresBefore")
 String xExpiresBefore,
 @HeaderParam("x-clonecloudstore-expiresAfter")
 String xExpiresAfter,
 @DefaultValue("0") @HeaderParam("x-clonecloudstore-sizeLT")
 long xSizeLt,
 @DefaultValue("0") @HeaderParam("x-clonecloudstore-sizeGT")
 long xSizeGt,
 @HeaderParam("x-clonecloudstore-metadataEq")
 String xMetadataEq,
 io.vertx.core.http.HttpServerRequest request,
 @Context
 io.quarkus.resteasy.reactive.server.Closer closer)

Overrides:

listObjects in class AbstractPublicObjectHelper<H extends StreamHandlerAbstract<AccessorObject,AccessorObject>>

checkObjectOrDirectory

@Path("{bucketName}/{pathDirectoryOrObject:.+}")
@HEAD
public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> checkObjectOrDirectory(@PathParam("bucketName")
 String bucketName,
 @PathParam("pathDirectoryOrObject")
 String pathDirectoryOrObject,
 @HeaderParam("x-clonecloudstore-client-id")
 String clientId,
 @HeaderParam("x-clonecloudstore-op-id")
 String opId)

Overrides:

checkObjectOrDirectory in class AbstractPublicObjectHelper<H extends StreamHandlerAbstract<AccessorObject,AccessorObject>>

getObjectInfo

@Path("{bucketName}/{objectName:.+}")
@GET
@Produces("application/json")
public io.smallrye.mutiny.Uni<AccessorObject> getObjectInfo(@PathParam("bucketName")
 String bucketName,
 @PathParam("objectName")
 String objectName,
 @HeaderParam("x-clonecloudstore-client-id")
 String clientId,
 @HeaderParam("x-clonecloudstore-op-id")
 String opId)

Overrides:

getObjectInfo in class AbstractPublicObjectHelper<H extends StreamHandlerAbstract<AccessorObject,AccessorObject>>

getObject

@Path("{bucketName}/{objectName:.+}")
@GET
@Produces("application/octet-stream")
public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> getObject(@PathParam("bucketName")
 String bucketName,
 @PathParam("objectName")
 String objectName,
 @HeaderParam("Accept")
 String acceptHeader,
 @HeaderParam("Accept-Encoding")
 String acceptEncodingHeader,
 @HeaderParam("x-clonecloudstore-client-id")
 String clientId,
 @HeaderParam("x-clonecloudstore-op-id")
 String opId,
 io.vertx.core.http.HttpServerRequest request,
 @Context
 io.quarkus.resteasy.reactive.server.Closer closer)

Returns both the content Object and the associated DTO through Headers

Overrides:

getObject in class AbstractPublicObjectHelper<H extends StreamHandlerAbstract<AccessorObject,AccessorObject>>

createObject

@Path("{bucketName}/{objectName:.+}")
@POST
@Consumes("application/octet-stream")
@Produces("application/json")
public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> createObject(io.vertx.core.http.HttpServerRequest request,
 @Context
 io.quarkus.resteasy.reactive.server.Closer closer,
 @PathParam("bucketName")
 String bucketName,
 @PathParam("objectName")
 String objectName,
 @DefaultValue("application/octet-stream") @HeaderParam("Content-Type")
 String contentTypeHeader,
 @HeaderParam("Content-Encoding")
 String contentEncodingHeader,
 @HeaderParam("x-clonecloudstore-client-id")
 String clientId,
 @HeaderParam("x-clonecloudstore-op-id")
 String opId,
 @HeaderParam("x-clonecloudstore-id")
 String xObjectId,
 @HeaderParam("x-clonecloudstore-site")
 String xObjectSite,
 @HeaderParam("x-clonecloudstore-bucket")
 String xObjectBucket,
 @HeaderParam("x-clonecloudstore-name")
 String xObjectName,
 @DefaultValue("0") @HeaderParam("x-clonecloudstore-size")
 long xObjectSize,
 @HeaderParam("x-clonecloudstore-hash")
 String xObjectHash,
 @HeaderParam("x-clonecloudstore-metadata")
 String xObjectMetadata,
 @HeaderParam("x-clonecloudstore-expires")
 String xObjectExpires,
 InputStream inputStream)

Create the Object and returns the associated DTO

Overrides:

createObject in class AbstractPublicObjectHelper<H extends StreamHandlerAbstract<AccessorObject,AccessorObject>>

deleteObject

@Path("{bucketName}/{objectName:.+}")
@DELETE
public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> deleteObject(@PathParam("bucketName")
 String bucketName,
 @PathParam("objectName")
 String objectName,
 @HeaderParam("x-clonecloudstore-client-id")
 String clientId,
 @HeaderParam("x-clonecloudstore-op-id")
 String opId)

Overrides:

deleteObject in class AbstractPublicObjectHelper<H extends StreamHandlerAbstract<AccessorObject,AccessorObject>>