Package com.here.platform.data.client.service.blobstore

Interface DurableBlobstoreService

All Known Subinterfaces:
IndexBlobstoreService
All Known Implementing Classes:
DefaultDurableBlobstoreService, DefaultIndexBlobstoreService
public interface DurableBlobstoreService

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.concurrent.Future<Object>
    blobExists(String catalogId, String layerId, String dataHandle)
     
    scala.concurrent.Future<org.apache.pekko.Done>
    completeUpload(ActionLink completeLink, UploadParts parts)
     
    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)
     

  • Method Details

    • blobExists

      scala.concurrent.Future<Object> blobExists(String catalogId, String layerId, String dataHandle)

    • completeUpload

      scala.concurrent.Future<org.apache.pekko.Done> completeUpload(ActionLink completeLink, UploadParts parts)

    • getBlob

      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)

    • getUploadStatus

      scala.concurrent.Future<UploadStatus> getUploadStatus(ActionLink statusLink)

    • putBlob

      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)

    • startUpload

      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)

    • uploadPart

      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)