Package io.clonecloudstore.accessor.client.internal.api

Interface AccessorObjectInternalApi

All Superinterfaces:

AutoCloseable, Closeable

@Path("/ccs/internal")
@RegisterRestClient
@RegisterProvider(ClientResponseExceptionMapper.class) @RegisterProvider(ResponseObjectClientFilter.class)
@RegisterClientHeaders(RequestHeaderFactory.class)
public interface AccessorObjectInternalApi
extends Closeable

API REST for Accessor Object for Internals between Clone Cloud Store services

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)
default String	computeCompressionModel(io.quarkus.rest.client.reactive.ComputedParamContext context)
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,
 @DefaultValue("false") @QueryParam("fullCheck")
 boolean fullCheck,
 @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)

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)