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

Interface VolatileBlobstoreService

All Known Implementing Classes:
DefaultVolatileBlobstoreService
public interface VolatileBlobstoreService

  • 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>
    deleteBlob(String catalogId, String layerId, String dataHandle)
     
    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.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.concurrent.Future<org.apache.pekko.Done>
    updateBlobTtl(String catalogId, String layerId, String dataHandle, long ttlSeconds)
     

  • Method Details

    • blobExists

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

    • deleteBlob

      scala.concurrent.Future<org.apache.pekko.Done> deleteBlob(String catalogId, String layerId, String dataHandle)

    • 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)

    • 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)

    • updateBlobTtl

      scala.concurrent.Future<org.apache.pekko.Done> updateBlobTtl(String catalogId, String layerId, String dataHandle, long ttlSeconds)