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

Interface ObjectStoreService

All Known Implementing Classes:

DefaultObjectStoreService

public interface ObjectStoreService

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> nextToken, 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)

Method Details

blobExists

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

copyBlob

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

copyPart

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

deleteBlob

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

finalizeUpload

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

getBlob

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)

getBlobMetadata

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

getUploadStatus

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

listBlobs

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

putBlob

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)

startUpload

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)

uploadPart

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)