Interface WriteObjectStoreSupport
- All Known Implementing Classes:
ObjectStoreWriteVolume
public interface WriteObjectStoreSupport
-
Method Summary
Modifier and TypeMethodDescriptionscala.concurrent.Future<org.apache.pekko.Done>completeObjectStoreUpload(String layerId, String key, String multipartToken, ObjectStoreUploadResult uploadResult) scala.concurrent.Future<org.apache.pekko.Done>copyObjectStoreBlob(String key, String sourceKey) scala.concurrent.Future<org.apache.pekko.Done>scala.concurrent.Future<org.apache.pekko.Done>putObjectStoreBlob(String key, org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString, org.apache.pekko.NotUsed> data, scala.Option<String> contentType, scala.Option<ContentEncoding> contentEncoding) scala.concurrent.Future<org.apache.pekko.Done>simplePutObjectStoreBlob(String layerId, String key, org.apache.pekko.util.ByteString data, scala.Option<String> contentType, scala.Option<ContentEncoding> contentEncoding) scala.concurrent.Future<ObjectMultipartToken>startMultipartUploadObjectStore(String layerId, String key, scala.Option<String> contentType, scala.Option<ContentEncoding> contentEncoding) scala.concurrent.Future<ObjectUploadPart>uploadObjectStorePart(String multipartToken, int partIndex, org.apache.pekko.util.ByteString data)
-
Method Details
-
completeObjectStoreUpload
scala.concurrent.Future<org.apache.pekko.Done> completeObjectStoreUpload(String layerId, String key, String multipartToken, ObjectStoreUploadResult uploadResult) -
copyObjectStoreBlob
-
deleteObjectStoreBlob
-
putObjectStoreBlob
scala.concurrent.Future<org.apache.pekko.Done> putObjectStoreBlob(String key, org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString, org.apache.pekko.NotUsed> data, scala.Option<String> contentType, scala.Option<ContentEncoding> contentEncoding) -
simplePutObjectStoreBlob
scala.concurrent.Future<org.apache.pekko.Done> simplePutObjectStoreBlob(String layerId, String key, org.apache.pekko.util.ByteString data, scala.Option<String> contentType, scala.Option<ContentEncoding> contentEncoding) -
startMultipartUploadObjectStore
scala.concurrent.Future<ObjectMultipartToken> startMultipartUploadObjectStore(String layerId, String key, scala.Option<String> contentType, scala.Option<ContentEncoding> contentEncoding) -
uploadObjectStorePart
scala.concurrent.Future<ObjectUploadPart> uploadObjectStorePart(String multipartToken, int partIndex, org.apache.pekko.util.ByteString data)
-