Class DefaultDurableBlobstoreService
java.lang.Object
com.here.platform.data.client.service.blobstore.DefaultDurableBlobstoreService
- All Implemented Interfaces:
DurableBlobstoreService
- Direct Known Subclasses:
DefaultIndexBlobstoreService
-
Constructor Summary
ConstructorsConstructorDescriptionDefaultDurableBlobstoreService(HRN hrn, InternalSettings settings, HttpHandler httpHandler, ClientExecutionContext clientExecutionContext) -
Method Summary
Modifier and TypeMethodDescriptionscala.concurrent.Future<Object>blobExists(String catalogId, String layerId, String dataHandle) scala.concurrent.Future<org.apache.pekko.Done>completeUpload(ActionLink completeLink, UploadParts uploadParts) scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>> getBlob(String catalogId, String layerId, String dataHandle, ByteRange range, scala.Option<BlobAccessType> accessType) scala.concurrent.Future<UploadStatus>getUploadStatus(ActionLink statusLink) scala.concurrent.Future<org.apache.pekko.Done>putBlob(String catalogId, String layerId, String dataHandle, org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString, org.apache.pekko.NotUsed> data, org.apache.pekko.http.scaladsl.model.ContentType contentType, scala.Option<org.apache.pekko.http.scaladsl.model.headers.HttpEncoding> contentEncoding, long contentLength, scala.Option<HereDigest> digest) scala.concurrent.Future<UploadLinks>startUpload(String catalogId, String layerId, String dataHandle, org.apache.pekko.http.scaladsl.model.ContentType contentType, scala.Option<org.apache.pekko.http.scaladsl.model.headers.HttpEncoding> contentEncoding) scala.concurrent.Future<UploadPart>uploadPart(ActionLink uploadLink, int partNumber, org.apache.pekko.http.scaladsl.model.ContentType contentType, scala.Option<HereDigest> digest, org.apache.pekko.util.ByteString part)
-
Constructor Details
-
DefaultDurableBlobstoreService
public DefaultDurableBlobstoreService(HRN hrn, InternalSettings settings, HttpHandler httpHandler, ClientExecutionContext clientExecutionContext)
-
-
Method Details
-
blobExists
public scala.concurrent.Future<Object> blobExists(String catalogId, String layerId, String dataHandle) - Specified by:
blobExistsin interfaceDurableBlobstoreService
-
getBlob
public scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>> getBlob(String catalogId, String layerId, String dataHandle, ByteRange range, scala.Option<BlobAccessType> accessType) - Specified by:
getBlobin interfaceDurableBlobstoreService
-
putBlob
public scala.concurrent.Future<org.apache.pekko.Done> putBlob(String catalogId, String layerId, String dataHandle, org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString, org.apache.pekko.NotUsed> data, org.apache.pekko.http.scaladsl.model.ContentType contentType, scala.Option<org.apache.pekko.http.scaladsl.model.headers.HttpEncoding> contentEncoding, long contentLength, scala.Option<HereDigest> digest) - Specified by:
putBlobin interfaceDurableBlobstoreService
-
startUpload
public scala.concurrent.Future<UploadLinks> startUpload(String catalogId, String layerId, String dataHandle, org.apache.pekko.http.scaladsl.model.ContentType contentType, scala.Option<org.apache.pekko.http.scaladsl.model.headers.HttpEncoding> contentEncoding) - Specified by:
startUploadin interfaceDurableBlobstoreService
-
uploadPart
public scala.concurrent.Future<UploadPart> uploadPart(ActionLink uploadLink, int partNumber, org.apache.pekko.http.scaladsl.model.ContentType contentType, scala.Option<HereDigest> digest, org.apache.pekko.util.ByteString part) - Specified by:
uploadPartin interfaceDurableBlobstoreService
-
completeUpload
public scala.concurrent.Future<org.apache.pekko.Done> completeUpload(ActionLink completeLink, UploadParts uploadParts) - Specified by:
completeUploadin interfaceDurableBlobstoreService
-
getUploadStatus
- Specified by:
getUploadStatusin interfaceDurableBlobstoreService
-