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

Class DurableWriteVolume

java.lang.Object

com.here.platform.data.client.blobstore.durable.DurableWriteVolume

All Implemented Interfaces:

WriteBlobstore

Direct Known Subclasses:

IndexWriteVolume

public class DurableWriteVolume
extends Object
implements WriteBlobstore

Constructor Summary

Constructors

Constructor	Description
DurableWriteVolume(DurableWriteVolumeConfiguration config, InternalSettings settings, BlobstoreClientExt blobstoreExt, DurableBlobstoreService blobstoreService, RetryPolicyType retryPolicyType)
DurableWriteVolume(DurableWriteVolumeConfiguration config, InternalSettings settings, BlobstoreClientExt blobstoreExt, RetryPolicyType retryPolicyType)

Method Summary

Modifier and Type	Method	Description
scala.Option<CrcAlgorithm>	crc()
static DefaultDurableBlobstoreService	defaultDurableBlobstoreService(DurableWriteVolumeConfiguration config, InternalSettings settings, BlobstoreClientExt blobstoreExt)
scala.Option<DigestAlgorithm>	digest()
scala.concurrent.Future<BlobMetadata>	putBlob(String dataHandle, org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> data, boolean applyCompression)
SingleMultiDataStage	singleMultiData()
scala.concurrent.Future<UploadPart>	uploadPart(ActionLink uploadLink, int partIndex, org.apache.pekko.util.ByteString bytes)
scala.concurrent.Future<org.apache.pekko.Done>	waitUploadToComplete(String dataHandle, ActionLink statusLink)

Methods inherited from class java.lang.Object

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

Constructor Details

DurableWriteVolume

public DurableWriteVolume(DurableWriteVolumeConfiguration config,
 InternalSettings settings,
 BlobstoreClientExt blobstoreExt,
 DurableBlobstoreService blobstoreService,
 RetryPolicyType retryPolicyType)

DurableWriteVolume

public DurableWriteVolume(DurableWriteVolumeConfiguration config,
 InternalSettings settings,
 BlobstoreClientExt blobstoreExt,
 RetryPolicyType retryPolicyType)

Method Details

defaultDurableBlobstoreService

public static DefaultDurableBlobstoreService defaultDurableBlobstoreService(DurableWriteVolumeConfiguration config,
 InternalSettings settings,
 BlobstoreClientExt blobstoreExt)

singleMultiData

public SingleMultiDataStage singleMultiData()

putBlob

public scala.concurrent.Future<BlobMetadata> putBlob(String dataHandle,
 org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> data,
 boolean applyCompression)

Specified by:

putBlob in interface WriteBlobstore

uploadPart

public scala.concurrent.Future<UploadPart> uploadPart(ActionLink uploadLink,
 int partIndex,
 org.apache.pekko.util.ByteString bytes)

waitUploadToComplete

public scala.concurrent.Future<org.apache.pekko.Done> waitUploadToComplete(String dataHandle,
 ActionLink statusLink)

digest

public scala.Option<DigestAlgorithm> digest()

Specified by:

digest in interface WriteBlobstore

crc

public scala.Option<CrcAlgorithm> crc()

Specified by:

crc in interface WriteBlobstore