Package io.clonecloudstore.replicator.client.api

Interface LocalReplicatorApi

All Superinterfaces:

AutoCloseable, Closeable

@Path("/replicator/local")
@RegisterRestClient
@RegisterProvider(ClientResponseExceptionMapper.class) @RegisterProvider(ResponseObjectClientFilter.class)
@RegisterClientHeaders(RequestHeaderFactory.class)
public interface LocalReplicatorApi
extends Closeable

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	checkBucket(String bucketName, boolean fullCheck, String clientId, String opId, String targetId)
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	checkObjectOrDirectory(String bucketName, String pathDirectoryOrObject, boolean fullCheck, String clientId, String opId, String targetId)
default String	computeCompressionModel(io.quarkus.rest.client.reactive.ComputedParamContext context)
io.smallrye.mutiny.Uni<ReplicatorResponse<AccessorBucket>>	getBucket(String bucketName, String clientId, String opId, String targetId)
io.smallrye.mutiny.Uni<InputStream>	remoteReadObject(boolean acceptCompression, String bucketName, String objectName, String xClientId, String xOpId, String xTargetId)

Methods inherited from interface java.io.Closeable

close

Method Details

getBucket

@GET
@Path("/buckets/{bucketName}")
@Produces("application/json")
io.smallrye.mutiny.Uni<ReplicatorResponse<AccessorBucket>> getBucket(@PathParam("bucketName")
 String bucketName,
 @HeaderParam("x-clonecloudstore-client-id")
 String clientId,
 @HeaderParam("x-clonecloudstore-op-id")
 String opId,
 @HeaderParam("x-clonecloudstore-target-id")
 String targetId)

checkBucket

@HEAD
@Path("/buckets/{bucketName}")
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> checkBucket(@PathParam("bucketName")
 String bucketName,
 @DefaultValue("false") @QueryParam("fullCheck")
 boolean fullCheck,
 @HeaderParam("x-clonecloudstore-client-id")
 String clientId,
 @HeaderParam("x-clonecloudstore-op-id")
 String opId,
 @HeaderParam("x-clonecloudstore-target-id")
 String targetId)

checkObjectOrDirectory

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

remoteReadObject

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

computeCompressionModel

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