Package org.eclipse.ditto.internal.utils.ddata

Interface DistributedDataConfig

All Known Implementing Classes:

DefaultDistributedDataConfig

@Immutable
public interface DistributedDataConfig

Provides configuration settings for DistributedData.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	DistributedDataConfig.DistributedDataConfigValue	An enumeration of the known config path expressions and their associated default values for DistributedDataConfig.

Method Summary

Modifier and Type	Method	Description
int	getNumberOfShards()	The number of shards Ditto's ddata extension applies for Map keys.
PekkoReplicatorConfig	getPekkoReplicatorConfig()	Returns the config to use for creating the Replicator.
Duration	getReadTimeout()	Returns the timeout of GET-messages of the replicator.
int	getSubscriberPoolSize()	The number of subscribers in each subscriber pool.
Duration	getSubscriptionDelay()	Returns the delay for subscriptions.
org.apache.pekko.cluster.ddata.Replicator.WriteConsistency	getSubscriptionWriteConsistency()	Returns the write consistency for topic subscription.
Duration	getWriteTimeout()	Returns the timeout of UPDATE-messages of the replicator.

Method Details

getReadTimeout

Duration getReadTimeout()

Returns the timeout of GET-messages of the replicator.

Returns:

the timeout of reads.

getWriteTimeout

Duration getWriteTimeout()

Returns the timeout of UPDATE-messages of the replicator.

Returns:

the timeout of writes.

getSubscriptionWriteConsistency

org.apache.pekko.cluster.ddata.Replicator.WriteConsistency getSubscriptionWriteConsistency()

Returns the write consistency for topic subscription.

Returns:

the write consistency.

getSubscriptionDelay

Duration getSubscriptionDelay()

Returns the delay for subscriptions.

Returns:

the subscription delay.

getPekkoReplicatorConfig

PekkoReplicatorConfig getPekkoReplicatorConfig()

Returns the config to use for creating the Replicator.

Returns:

the Pekko replicator config to use.

getNumberOfShards

int getNumberOfShards()

The number of shards Ditto's ddata extension applies for Map keys.

Returns:

the number of shards to apply.

getSubscriberPoolSize

int getSubscriberPoolSize()

The number of subscribers in each subscriber pool.

Returns:

the number of subscribers.