Index (ccs-common-quarkus-server 0.8.0-SNAPSHOT API)

C D E F G H I P R S T U
All Classes and Interfaces|All Packages|Serialized Form

C

checkDigestToCompute(I) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract: Default based on QuarkusProperties.serverComputeSha256
checkEndOfPush(boolean) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
checkPullAble(I, MultiMap) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract: The implementation must check using business object that get inputStream request (server sending InputStream as result) is valid according to the businessIn from te Rest API and the headers.
checkPushAble(I, MultipleActionsInputStream) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract: Check if the request for POST is valid, and if so, adapt the given MultipleActionsInputStream that will be used to consume the original InputStream.
clear() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract: Clear all context
countDownLatch - Variable in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
createErrorResponse(Exception) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamServiceAbstract
createObject(HttpServerRequest, Closer, I, long, String, boolean, InputStream) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamServiceAbstract: Method to use within the POST query definition with a @Blocking annotation.
createObject(HttpServerRequest, Closer, I, long, String, InputStream) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamServiceAbstract: Method to use within the POST query definition with a @Blocking annotation.

D

doGetInputStream() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract

E

endPush() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
exceptionAtomicReference - Variable in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract

F

filter(ContainerRequestContext) - Method in class io.clonecloudstore.common.quarkus.server.service.ServerRequestFilter
filter(ContainerRequestContext, ContainerResponseContext) - Method in class io.clonecloudstore.common.quarkus.server.service.ServerResponseFilter

G

getAnswerPushInputStream(I, String, long) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract: Returns a BusinessOut in case of POST (receiving InputStream on server side).
getBusinessIn() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
getCloser() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
getException() - Method in exception class io.clonecloudstore.common.quarkus.server.service.ServerStreamHandlerResponseException
getHeaderError(I, int) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract: Return headers for error message.
getHeaderPullInputStream(I) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract: Returns a Map for Headers response in case of GET, added to InputStream get above (server is sending the InputStream back to the client) (example: headers for object name, object size...)
getHeaderPushInputStream(I, String, long, O) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract: Returns a Map for Headers response in case of POST (receiving InputStream on server side).
getInputStreamLength() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
getMessage() - Method in exception class io.clonecloudstore.common.quarkus.server.service.ServerStreamHandlerResponseException
getNativeStream() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamServiceAbstract
getOpId() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
getOriginalHash() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
getPullInputStream(I) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract: Returns the InputStream required for GET (server is sending the InputStream back to the client).
getRequest() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
getResponse() - Method in exception class io.clonecloudstore.common.quarkus.server.service.ServerStreamHandlerResponseException
getServerStreamHandlerResponseException(Response.Status) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
getVertx() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract

H

handleException(UniEmitter<? super Response>, Exception) - Static method in class io.clonecloudstore.common.quarkus.server.service.ServerResponseFilter
handleExceptionFail(UniEmitter<?>, Exception) - Static method in class io.clonecloudstore.common.quarkus.server.service.ServerResponseFilter

I

io.clonecloudstore.common.quarkus.server.service - package io.clonecloudstore.common.quarkus.server.service
isAlreadyCompressed() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
isExternal() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
isKeepAlive() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
isKeepInputStreamCompressed() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract: True means the stream will be kept compressed if source (from client) is compressed or do not recompress getInputStream
isResponseCompressed() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract: True means the incoming stream is compressed (ZSTD)
isUpload() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract

P

postSetup() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract: Method to override for post setup
preparePull() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
pull() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
pullList() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract

R

readObject(HttpServerRequest, Closer, I, boolean) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamServiceAbstract: Method to use within the GET query definition with a @Blocking annotation.
resultProxy - Variable in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract

S

sendError(int, Exception) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
sendError(Response.Status, Throwable) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
ServerRequestFilter - Class in io.clonecloudstore.common.quarkus.server.service
ServerRequestFilter() - Constructor for class io.clonecloudstore.common.quarkus.server.service.ServerRequestFilter
ServerResponseFilter - Class in io.clonecloudstore.common.quarkus.server.service
ServerResponseFilter() - Constructor for class io.clonecloudstore.common.quarkus.server.service.ServerResponseFilter
ServerStreamHandlerResponseException - Exception Class in io.clonecloudstore.common.quarkus.server.service
ServerStreamHandlerResponseException(Response, Exception) - Constructor for exception class io.clonecloudstore.common.quarkus.server.service.ServerStreamHandlerResponseException
setKeepInputStreamCompressed(boolean) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
setResponseCompressed(boolean) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
setResultFromRemote(O) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
setup(HttpServerRequest, Closer, boolean, I, long, String, boolean, boolean) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract: Constructor, while inputLength could be 0 (valid for both POST and GET, signifying the posted InputStream length or the supposed returned InputStream length).
shallCompress() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
shallDecompress() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
StreamHandlerAbstract<I,O> - Class in io.clonecloudstore.common.quarkus.server.service
StreamHandlerAbstract() - Constructor for class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract
StreamServiceAbstract<I,O,H> - Class in io.clonecloudstore.common.quarkus.server.service: Abstraction to enable InputStream Get (Pull) and Post (Push) implementations.
StreamServiceAbstract() - Constructor for class io.clonecloudstore.common.quarkus.server.service.StreamServiceAbstract

T

throwTrappedException() - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract

U

upload(InputStream) - Method in class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract

C D E F G H I P R S T U
All Classes and Interfaces|All Packages|Serialized Form