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

Class DefaultObjectStoreService

java.lang.Object

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

All Implemented Interfaces:

ObjectStoreService

public class DefaultObjectStoreService
extends Object
implements ObjectStoreService

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
scala.concurrent.Future<Object>	blobExists(String layerId, String key)
scala.concurrent.Future<org.apache.pekko.Done>	copyBlob(String layerId, String key, String sourceKey)
scala.concurrent.Future<ObjectStoreUploadPartRaw>	copyPart(String layerId, String multipartToken, String source, int partNumber, ByteRange range)
scala.concurrent.Future<org.apache.pekko.Done>	deleteBlob(String layerId, String key)
scala.concurrent.Future<org.apache.pekko.Done>	finalizeUpload(String layerId, String multipartToken, ObjectStoreUploadPartsRaw parts)
scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>>	getBlob(String layerId, String key, ByteRange range, scala.Option<BlobAccessType> accessType)
scala.concurrent.Future<ObjectStoreMetadataRaw>	getBlobMetadata(String layerId, String key)
scala.concurrent.Future<UploadStatus>	getUploadStatus(String layerId, String multipartToken)
scala.concurrent.Future<ObjectStoreListingRaw>	listBlobs(String layerId, scala.Option<String> parent, scala.Option<Object> limit, scala.Option<String> pageToken, boolean deepListEnabled)
scala.concurrent.Future<org.apache.pekko.Done>	putBlob(String layerId, String key, org.apache.pekko.util.ByteString data, org.apache.pekko.http.scaladsl.model.ContentType contentType, scala.Option<org.apache.pekko.http.scaladsl.model.headers.HttpEncoding> contentEncoding, scala.Option<HereDigest> digest)
scala.concurrent.Future<ObjectStoreMultipartTokenRaw>	startUpload(String layerId, String key, org.apache.pekko.http.scaladsl.model.ContentType contentType, scala.Option<org.apache.pekko.http.scaladsl.model.headers.HttpEncoding> contentEncoding)
scala.concurrent.Future<ObjectStoreUploadPartRaw>	uploadPart(String layerId, String multipartToken, int partNumber, org.apache.pekko.http.scaladsl.model.ContentType contentType, scala.Option<HereDigest> digest, org.apache.pekko.util.ByteString data)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultObjectStoreService

public DefaultObjectStoreService(HRN hrn,
 InternalSettings settings,
 HttpHandler httpHandler,
 ClientExecutionContext clientExecutionContext)

Method Details

blobExists

public scala.concurrent.Future<Object> blobExists(String layerId,
 String key)

Specified by:

blobExists in interface ObjectStoreService

copyBlob

public scala.concurrent.Future<org.apache.pekko.Done> copyBlob(String layerId,
 String key,
 String sourceKey)

Specified by:

copyBlob in interface ObjectStoreService

copyPart

public scala.concurrent.Future<ObjectStoreUploadPartRaw> copyPart(String layerId,
 String multipartToken,
 String source,
 int partNumber,
 ByteRange range)

Specified by:

copyPart in interface ObjectStoreService

deleteBlob

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

Specified by:

deleteBlob in interface ObjectStoreService

finalizeUpload

public scala.concurrent.Future<org.apache.pekko.Done> finalizeUpload(String layerId,
 String multipartToken,
 ObjectStoreUploadPartsRaw parts)

Specified by:

finalizeUpload in interface ObjectStoreService

getBlob

public scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>> getBlob(String layerId,
 String key,
 ByteRange range,
 scala.Option<BlobAccessType> accessType)

Specified by:

getBlob in interface ObjectStoreService

getBlobMetadata

public scala.concurrent.Future<ObjectStoreMetadataRaw> getBlobMetadata(String layerId,
 String key)

Specified by:

getBlobMetadata in interface ObjectStoreService

getUploadStatus

public scala.concurrent.Future<UploadStatus> getUploadStatus(String layerId,
 String multipartToken)

Specified by:

getUploadStatus in interface ObjectStoreService

listBlobs

public scala.concurrent.Future<ObjectStoreListingRaw> listBlobs(String layerId,
 scala.Option<String> parent,
 scala.Option<Object> limit,
 scala.Option<String> pageToken,
 boolean deepListEnabled)

Specified by:

listBlobs in interface ObjectStoreService

putBlob

public scala.concurrent.Future<org.apache.pekko.Done> putBlob(String layerId,
 String key,
 org.apache.pekko.util.ByteString data,
 org.apache.pekko.http.scaladsl.model.ContentType contentType,
 scala.Option<org.apache.pekko.http.scaladsl.model.headers.HttpEncoding> contentEncoding,
 scala.Option<HereDigest> digest)

Specified by:

putBlob in interface ObjectStoreService

startUpload

public scala.concurrent.Future<ObjectStoreMultipartTokenRaw> startUpload(String layerId,
 String key,
 org.apache.pekko.http.scaladsl.model.ContentType contentType,
 scala.Option<org.apache.pekko.http.scaladsl.model.headers.HttpEncoding> contentEncoding)

Specified by:

startUpload in interface ObjectStoreService

uploadPart

public scala.concurrent.Future<ObjectStoreUploadPartRaw> uploadPart(String layerId,
 String multipartToken,
 int partNumber,
 org.apache.pekko.http.scaladsl.model.ContentType contentType,
 scala.Option<HereDigest> digest,
 org.apache.pekko.util.ByteString data)

Specified by:

uploadPart in interface ObjectStoreService