Package io.clonecloudstore.test.accessor.common

Class FakeAccessorObjectPublicAbstract<H extends FakeStreamHandlerAbstract>

java.lang.Object

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

io.clonecloudstore.accessor.server.commons.AbstractPublicObjectHelper<H>

io.clonecloudstore.accessor.server.commons.AbstractAccessorPublicObjectResource<H>

io.clonecloudstore.test.accessor.common.FakeAccessorObjectPublicAbstract<H>

Direct Known Subclasses:

FakeObjectPublicResourceAbstract

@Dependent
public abstract class FakeAccessorObjectPublicAbstract<H extends FakeStreamHandlerAbstract>
extends AbstractAccessorPublicObjectResource<H>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FakeAccessorObjectPublicAbstract()

Method Summary

Modifier and Type	Method	Description
protected void	checkObjectOrDirectory(io.smallrye.mutiny.subscription.UniEmitter<? super jakarta.ws.rs.core.Response> em, String bucketName, String pathDirectoryOrObject, String clientId)
protected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	checkObjectOrDirectory0(String bucketName, String pathDirectoryOrObject, String clientId)
protected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	createObject0(io.vertx.core.http.HttpServerRequest request, io.quarkus.resteasy.reactive.server.Closer closer, String bucketName, String objectName, String contentTypeHeader, String contentEncodingHeader, String clientId, String opId, String xObjectId, String xObjectSite, String xObjectBucket, String xObjectName, long xObjectSize, String xObjectHash, String xObjectMetadata, String xObjectExpires, InputStream inputStream)
protected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	deleteObject0(String bucketName, String objectName, String clientId)
protected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	getObject0(String bucketName, String objectName, String acceptHeader, String acceptEncodingHeader, String clientId, String opId, io.vertx.core.http.HttpServerRequest request, io.quarkus.resteasy.reactive.server.Closer closer)
protected void	getObjectInfo(io.smallrye.mutiny.subscription.UniEmitter<? super AccessorObject> em, String bucketName, String objectName, String clientId)
protected io.smallrye.mutiny.Uni<AccessorObject>	getObjectInfo0(String bucketName, String objectName, String clientId)
protected boolean	isPublic()
protected void	listObjects(io.smallrye.mutiny.subscription.UniEmitter<? super jakarta.ws.rs.core.Response> em, String bucketName, String xNamePrefix, String xCreationAfter, String xCreationBefore, String clientId, io.vertx.core.http.HttpServerRequest request, io.quarkus.resteasy.reactive.server.Closer closer)
protected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response>	listObjects0(String bucketName, String clientId, String xNamePrefix, String xStatuses, String xCreationBefore, String xCreationAfter, String xExpiresBefore, String xExpiresAfter, long xSizeLt, long xSizeGt, String xMetadataEq, io.vertx.core.http.HttpServerRequest request, io.quarkus.resteasy.reactive.server.Closer closer)

Methods inherited from class io.clonecloudstore.accessor.server.commons.AbstractAccessorPublicObjectResource

checkObjectOrDirectory, createObject, deleteObject, getObject, getObjectInfo, listObjects

Methods inherited from class io.clonecloudstore.accessor.server.commons.AbstractPublicObjectHelper

getFromStorageObject, readObjectList

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

FakeAccessorObjectPublicAbstract

protected FakeAccessorObjectPublicAbstract()

Method Details

isPublic

protected boolean isPublic()

listObjects

protected void listObjects(io.smallrye.mutiny.subscription.UniEmitter<? super jakarta.ws.rs.core.Response> em,
 String bucketName,
 String xNamePrefix,
 String xCreationAfter,
 String xCreationBefore,
 String clientId,
 io.vertx.core.http.HttpServerRequest request,
 io.quarkus.resteasy.reactive.server.Closer closer)

listObjects0

protected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> listObjects0(String bucketName,
 String clientId,
 String xNamePrefix,
 String xStatuses,
 String xCreationBefore,
 String xCreationAfter,
 String xExpiresBefore,
 String xExpiresAfter,
 long xSizeLt,
 long xSizeGt,
 String xMetadataEq,
 io.vertx.core.http.HttpServerRequest request,
 io.quarkus.resteasy.reactive.server.Closer closer)

checkObjectOrDirectory

protected void checkObjectOrDirectory(io.smallrye.mutiny.subscription.UniEmitter<? super jakarta.ws.rs.core.Response> em,
 String bucketName,
 String pathDirectoryOrObject,
 String clientId)

checkObjectOrDirectory0

protected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> checkObjectOrDirectory0(String bucketName,
 String pathDirectoryOrObject,
 String clientId)

getObjectInfo

protected void getObjectInfo(io.smallrye.mutiny.subscription.UniEmitter<? super AccessorObject> em,
 String bucketName,
 String objectName,
 String clientId)

getObjectInfo0

protected io.smallrye.mutiny.Uni<AccessorObject> getObjectInfo0(String bucketName,
 String objectName,
 String clientId)

deleteObject0

protected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> deleteObject0(String bucketName,
 String objectName,
 String clientId)

createObject0

protected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> createObject0(io.vertx.core.http.HttpServerRequest request,
 io.quarkus.resteasy.reactive.server.Closer closer,
 String bucketName,
 String objectName,
 String contentTypeHeader,
 String contentEncodingHeader,
 String clientId,
 String opId,
 String xObjectId,
 String xObjectSite,
 String xObjectBucket,
 String xObjectName,
 long xObjectSize,
 String xObjectHash,
 String xObjectMetadata,
 String xObjectExpires,
 InputStream inputStream)

getObject0

protected io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> getObject0(String bucketName,
 String objectName,
 String acceptHeader,
 String acceptEncodingHeader,
 String clientId,
 String opId,
 io.vertx.core.http.HttpServerRequest request,
 io.quarkus.resteasy.reactive.server.Closer closer)