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

Class BlobstoreClientExt

java.lang.Object

com.here.platform.data.client.blobstore.BlobstoreClientExt

All Implemented Interfaces:

org.apache.pekko.actor.Extension

public final class BlobstoreClientExt
extends Object
implements org.apache.pekko.actor.Extension

Constructor Summary

Constructors

Constructor	Description
BlobstoreClientExt(com.typesafe.config.Config dataClientConfiguration, org.apache.pekko.actor.ActorSystem system)

Method Summary

Modifier and Type	Method	Description
RequestResponseHandler	blobstoreRequestResponseHandler()
int	bufferSize()
scala.Option<HereDigest>	calculateDataIntegrityDigest(org.apache.pekko.util.ByteString data)
final ClientExecutionContext	clientExecutionContext()
org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>	compressIfNeeded(boolean useCompression)
CountBytesStage	countBytes()
ByteStringSizingStage	dataChunker()
org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>	decompressIfNeeded(boolean useCompression)
Settings	defaultSettings()
int	multiPartUploadParallelism()
scala.Option<BlobAccessType>	preferredBlobAccessType()
scala.Option<String>	preferredDataIntegrityDigestAlgorithm()
ReadBlobstore	readBlobstore(HRN hrn, Layer layer, Settings settings)
RetryPolicyType	retryPolicyType()
int	useMultiPartUploadFrom()
scala.Option<String>	userAgentSuffix()
WriteBlobstore	writeBlobstore(HRN hrn, Layer layer, Settings settings, scala.Option<CatalogConfiguration> catalogConfig)

Methods inherited from class java.lang.Object

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

Constructor Details

BlobstoreClientExt

public BlobstoreClientExt(com.typesafe.config.Config dataClientConfiguration,
 org.apache.pekko.actor.ActorSystem system)

Method Details

blobstoreRequestResponseHandler

public RequestResponseHandler blobstoreRequestResponseHandler()

bufferSize

public int bufferSize()

calculateDataIntegrityDigest

public scala.Option<HereDigest> calculateDataIntegrityDigest(org.apache.pekko.util.ByteString data)

clientExecutionContext

public final ClientExecutionContext clientExecutionContext()

compressIfNeeded

public org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> compressIfNeeded(boolean useCompression)

countBytes

public CountBytesStage countBytes()

dataChunker

public ByteStringSizingStage dataChunker()

decompressIfNeeded

public org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> decompressIfNeeded(boolean useCompression)

defaultSettings

public Settings defaultSettings()

multiPartUploadParallelism

public int multiPartUploadParallelism()

preferredBlobAccessType

public scala.Option<BlobAccessType> preferredBlobAccessType()

preferredDataIntegrityDigestAlgorithm

public scala.Option<String> preferredDataIntegrityDigestAlgorithm()

readBlobstore

public ReadBlobstore readBlobstore(HRN hrn,
 Layer layer,
 Settings settings)

retryPolicyType

public RetryPolicyType retryPolicyType()

useMultiPartUploadFrom

public int useMultiPartUploadFrom()

userAgentSuffix

public scala.Option<String> userAgentSuffix()

writeBlobstore

public WriteBlobstore writeBlobstore(HRN hrn,
 Layer layer,
 Settings settings,
 scala.Option<CatalogConfiguration> catalogConfig)