Package io.clonecloudstore.accessor.client.api

Interface AccessorObjectApi

All Superinterfaces:

AutoCloseable, Closeable

@Path("/cloudclonestore")
@RegisterRestClient
@RegisterProvider(ClientResponseExceptionMapper.class) @RegisterProvider(ResponseObjectClientFilter.class)
@RegisterClientHeaders(RequestHeaderFactory.class)
public interface AccessorObjectApi
extends Closeable

API REST for Accessor Object

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)
default String	computeCompressionModel(io.quarkus.rest.client.reactive.ComputedParamContext context)
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	createObject(boolean provideCompressed, String bucketName, String objectName, String clientId, String opId, InputStream inputStream)
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	deleteObject(String bucketName, String objectName, String clientId, String opId)
io.smallrye.mutiny.Uni<InputStream>	getObject(boolean acceptCompression, String bucketName, String objectName, String clientId, String opId)
io.smallrye.mutiny.Uni<AccessorObject>	getObjectInfo(String bucketName, String objectName, String clientId, String opId)
io.smallrye.mutiny.Uni<InputStream>	listObjects(boolean acceptCompression, String bucketName, String clientId, String opId)

Methods inherited from interface java.io.Closeable

close

Method Details

checkObjectOrDirectory

@Path("{bucketName}/{pathDirectoryOrObject:.+}")
@HEAD
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,
 @DefaultValue("") @HeaderParam("x-clonecloudstore-op-id")
 String opId)

getObjectInfo

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

deleteObject

@Path("{bucketName}/{objectName:.+}")
@DELETE
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,
 @DefaultValue("") @HeaderParam("x-clonecloudstore-op-id")
 String opId)

computeCompressionModel

default String computeCompressionModel(io.quarkus.rest.client.reactive.ComputedParamContext context)

listObjects

@Path("{bucketName}")
@PUT
@Produces("application/octet-stream")
@ClientHeaderParam(name="Accept",value="application/octet-stream") @ClientHeaderParam(name="Accept-Encoding",value="{computeCompressionModel}",required=false)
io.smallrye.mutiny.Uni<InputStream> listObjects(@NotBody
 boolean acceptCompression,
 @PathParam("bucketName")
 String bucketName,
 @HeaderParam("x-clonecloudstore-client-id")
 String clientId,
 @HeaderParam("x-clonecloudstore-op-id")
 String opId)

getObject

@Path("{bucketName}/{objectName:.+}")
@GET
@Produces("application/octet-stream")
@ClientHeaderParam(name="Accept",value="application/octet-stream") @ClientHeaderParam(name="Accept-Encoding",value="{computeCompressionModel}",required=false)
io.smallrye.mutiny.Uni<InputStream> getObject(@NotBody
 boolean acceptCompression,
 @PathParam("bucketName")
 String bucketName,
 @PathParam("objectName")
 String objectName,
 @HeaderParam("x-clonecloudstore-client-id")
 String clientId,
 @HeaderParam("x-clonecloudstore-op-id")
 String opId)

createObject

@Path("{bucketName}/{objectName:.+}")
@POST
@Consumes("application/octet-stream")
@Produces("application/json")
@ClientHeaderParam(name="Content-Type",value="application/octet-stream") @ClientHeaderParam(name="Transfer-Encoding",value="chunked") @ClientHeaderParam(name="Content-Encoding",value="{computeCompressionModel}",required=false)
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> createObject(@NotBody
 boolean provideCompressed,
 @PathParam("bucketName")
 String bucketName,
 @PathParam("objectName")
 String objectName,
 @HeaderParam("x-clonecloudstore-client-id")
 String clientId,
 @HeaderParam("x-clonecloudstore-op-id")
 String opId,
 InputStream inputStream)