Class DefaultObjectStoreService
java.lang.Object
com.here.platform.data.client.service.blobstore.DefaultObjectStoreService
- All Implemented Interfaces:
ObjectStoreService
-
Constructor Summary
ConstructorsConstructorDescriptionDefaultObjectStoreService(HRN hrn, InternalSettings settings, HttpHandler httpHandler, ClientExecutionContext clientExecutionContext) -
Method Summary
Modifier and TypeMethodDescriptionscala.concurrent.Future<Object>blobExists(String layerId, String key) scala.concurrent.Future<org.apache.pekko.Done>scala.concurrent.Future<ObjectStoreUploadPartRaw>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)
-
Constructor Details
-
DefaultObjectStoreService
public DefaultObjectStoreService(HRN hrn, InternalSettings settings, HttpHandler httpHandler, ClientExecutionContext clientExecutionContext)
-
-
Method Details
-
blobExists
- Specified by:
blobExistsin interfaceObjectStoreService
-
copyBlob
public scala.concurrent.Future<org.apache.pekko.Done> copyBlob(String layerId, String key, String sourceKey) - Specified by:
copyBlobin interfaceObjectStoreService
-
copyPart
public scala.concurrent.Future<ObjectStoreUploadPartRaw> copyPart(String layerId, String multipartToken, String source, int partNumber, ByteRange range) - Specified by:
copyPartin interfaceObjectStoreService
-
deleteBlob
- Specified by:
deleteBlobin interfaceObjectStoreService
-
finalizeUpload
public scala.concurrent.Future<org.apache.pekko.Done> finalizeUpload(String layerId, String multipartToken, ObjectStoreUploadPartsRaw parts) - Specified by:
finalizeUploadin interfaceObjectStoreService
-
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:
getBlobin interfaceObjectStoreService
-
getBlobMetadata
- Specified by:
getBlobMetadatain interfaceObjectStoreService
-
getUploadStatus
- Specified by:
getUploadStatusin interfaceObjectStoreService
-
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:
listBlobsin interfaceObjectStoreService
-
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:
putBlobin interfaceObjectStoreService
-
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:
startUploadin interfaceObjectStoreService
-
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:
uploadPartin interfaceObjectStoreService
-