Package io.clonecloudstore.replicator.server.local.resource

Class LocalReplicatorResource

java.lang.Object

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

io.clonecloudstore.replicator.server.local.resource.LocalReplicatorResource

@Path("/replicator/local")
public class LocalReplicatorResource
extends StreamServiceAbstract<ReplicatorOrder,AccessorObject,LocalReplicatorStreamHandler>

Constructor Summary

Constructors

Constructor	Description
LocalReplicatorResource(LocalReplicatorService localReplicatorService)

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	checkBucket(String bucketName, boolean fullCheck, String xClientId, String xOpId, String xTargetId)
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	checkObjectOrDirectory(String bucketName, String pathDirectoryOrObject, boolean fullCheck, String xClientId, String xOpId, String xTargetId)
io.smallrye.mutiny.Uni<ReplicatorResponse<AccessorBucket>>	getBucket(String bucketName, String xClientId, String xOpId, String xTargetId)
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	remoteReadObject(String bucketName, String objectName, String acceptHeader, String acceptEncodingHeader, String xClientId, String xOpId, String xTargetId, io.vertx.core.http.HttpServerRequest request, io.quarkus.resteasy.reactive.server.Closer closer)

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

LocalReplicatorResource

public LocalReplicatorResource(LocalReplicatorService localReplicatorService)

Method Details

remoteReadObject

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

checkObjectOrDirectory

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

checkBucket

@HEAD
@Path("/buckets/{bucketName}")
public 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 xClientId,
 @HeaderParam("x-clonecloudstore-op-id")
 String xOpId,
 @HeaderParam("x-clonecloudstore-target-id")
 String xTargetId)

getBucket

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