Package io.clonecloudstore.accessor.server.simple.application

Class ObjectStreamHandler

java.lang.Object

io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract<AccessorObject,AccessorObject>

io.clonecloudstore.accessor.server.commons.AbstractObjectStreamHandler

io.clonecloudstore.accessor.server.simple.application.ObjectStreamHandler

@RequestScoped
public class ObjectStreamHandler
extends AbstractObjectStreamHandler

Field Summary

Fields inherited from class io.clonecloudstore.accessor.server.commons.AbstractObjectStreamHandler

checked, clientId, driverApi, external, filesystemHandler, filter, isListing, service

Fields inherited from class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract

countDownLatch, exceptionAtomicReference, resultProxy

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ObjectStreamHandler()
protected	ObjectStreamHandler(AccessorObjectService service)

Method Summary

Modifier and Type	Method	Description
protected boolean	checkPullAble(AccessorObject object, io.vertx.core.MultiMap headers)	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.
protected Map<String,String>	getHeaderError(AccessorObject object, int status)	Return headers for error message.
protected InputStream	getPullInputStream(AccessorObject object)	Returns the InputStream required for GET (server is sending the InputStream back to the client).

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

checkPushAble, getAnswerPushInputStream, getHeaderPullInputStream, getHeaderPushInputStream, postSetup, pullList

Methods inherited from class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract

checkDigestToCompute, checkEndOfPush, clear, doGetInputStream, endPush, getBusinessIn, getCloser, getInputStreamLength, getOpId, getOriginalHash, getRequest, getServerStreamHandlerResponseException, getVertx, isAlreadyCompressed, isExternal, isKeepAlive, isKeepInputStreamCompressed, isResponseCompressed, isUpload, preparePull, pull, sendError, sendError, setKeepInputStreamCompressed, setResponseCompressed, setResultFromRemote, setup, shallCompress, shallDecompress, throwTrappedException, upload

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ObjectStreamHandler

protected ObjectStreamHandler()

ObjectStreamHandler

protected ObjectStreamHandler(AccessorObjectService service)

Method Details

checkPullAble

protected boolean checkPullAble(AccessorObject object,
 io.vertx.core.MultiMap headers)

Description copied from class: 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. (example: ObjectStorage check of existence of object)

Specified by:

checkPullAble in class StreamHandlerAbstract<AccessorObject,AccessorObject>

Returns:

True if the read action is valid for this businessIn object and headers

getPullInputStream

protected InputStream getPullInputStream(AccessorObject object)

Description copied from class: StreamHandlerAbstract

Returns the InputStream required for GET (server is sending the InputStream back to the client). The implementation shall use the business logic and controls to get the InputStream to return. (example: getting the Object Storage object stream)

Specified by:

getPullInputStream in class StreamHandlerAbstract<AccessorObject,AccessorObject>

Parameters:

object - businessIn as passed in constructor

getHeaderError

protected Map<String,String> getHeaderError(AccessorObject object,
 int status)

Description copied from class: StreamHandlerAbstract

Return headers for error message. (example: get headers in case of error as Object name, Bucket name...)

Specified by:

getHeaderError in class StreamHandlerAbstract<AccessorObject,AccessorObject>