Package io.clonecloudstore.replicator.server.remote.resource

Class RemoteReplicatorResource

java.lang.Object

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

io.clonecloudstore.replicator.server.remote.resource.RemoteReplicatorResource

@Path("/replicator/remote")
public class RemoteReplicatorResource
extends StreamServiceAbstract<ReplicatorOrder,AccessorObject,RemoteReplicatorStreamHandler>

Constructor Summary

Constructors

Constructor	Description
RemoteReplicatorResource(AccessorBucketInternalApiFactory accessorBucketInternalApiFactory, AccessorObjectInternalApiFactory accessorObjectInternalApiFactory, RemoteReplicatorOrderEmitter replicatorOrderEmitter)

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)
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	checkObjectOrDirectory(String bucketName, String pathDirectoryOrObject, boolean fullCheck, String xClientId, String xOpId)
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	createOrder(ReplicatorOrder replicatorOrder)
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	createOrders(List<ReplicatorOrder> replicatorOrders)
io.smallrye.mutiny.Uni<AccessorBucket>	getBucket(String bucketName, String xClientId, String xOpId)
io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	remoteReadObject(String bucketName, String objectName, String acceptHeader, String acceptEncodingHeader, String xClientId, String xOpId, 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

RemoteReplicatorResource

public RemoteReplicatorResource(AccessorBucketInternalApiFactory accessorBucketInternalApiFactory,
 AccessorObjectInternalApiFactory accessorObjectInternalApiFactory,
 RemoteReplicatorOrderEmitter replicatorOrderEmitter)

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,
 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)

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)

getBucket

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

createOrder

@POST
@Path("/orders")
@Consumes("application/json")
public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> createOrder(ReplicatorOrder replicatorOrder)

createOrders

@POST
@Path("/orders/multiple")
@Consumes("application/json")
public io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> createOrders(List<ReplicatorOrder> replicatorOrders)