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

Class DefaultDurableBlobstoreService

java.lang.Object

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

All Implemented Interfaces:

DurableBlobstoreService

Direct Known Subclasses:

DefaultIndexBlobstoreService

public class DefaultDurableBlobstoreService
extends Object
implements DurableBlobstoreService

Constructor Summary

Constructors

Constructor	Description
DefaultDurableBlobstoreService(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>	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)

Methods inherited from class java.lang.Object

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

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:

blobExists in interface DurableBlobstoreService

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:

getBlob in interface DurableBlobstoreService

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:

putBlob in interface DurableBlobstoreService

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:

startUpload in interface DurableBlobstoreService

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:

uploadPart in interface DurableBlobstoreService

completeUpload

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

Specified by:

completeUpload in interface DurableBlobstoreService

getUploadStatus

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

Specified by:

getUploadStatus in interface DurableBlobstoreService