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

Class DefaultVolatileBlobstoreService

java.lang.Object

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

All Implemented Interfaces:

VolatileBlobstoreService

public class DefaultVolatileBlobstoreService
extends Object
implements VolatileBlobstoreService

Constructor Summary

Constructors

Constructor	Description
DefaultVolatileBlobstoreService(HRN hrn, InternalSettings settings, HttpHandler httpHandler, ClientExecutionContext clientExecutionContext)

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)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultVolatileBlobstoreService

public DefaultVolatileBlobstoreService(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:

blobExists in interface VolatileBlobstoreService

deleteBlob

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

Specified by:

deleteBlob in interface VolatileBlobstoreService

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)

Specified by:

getBlob in interface VolatileBlobstoreService

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)

Specified by:

putBlob in interface VolatileBlobstoreService

updateBlobTtl

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

Specified by:

updateBlobTtl in interface VolatileBlobstoreService