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

Class DefaultDistributedDataConfig

java.lang.Object

org.eclipse.ditto.internal.utils.ddata.DefaultDistributedDataConfig

All Implemented Interfaces:

DistributedDataConfig

@Immutable
public final class DefaultDistributedDataConfig
extends Object
implements DistributedDataConfig

This class is the default implementation of the distributed data config.

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig

DistributedDataConfig.DistributedDataConfigValue

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
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.
int	hashCode()
static DefaultDistributedDataConfig	of(com.typesafe.config.Config config)	Returns an instance of DefaultDistributedDataConfig based on the settings of the specified Config.
static DefaultDistributedDataConfig	of(com.typesafe.config.Config config, CharSequence replicatorName, CharSequence replicatorRole)	Returns an instance of DefaultDistributedDataConfig based on the settings of the specified Config.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Details

of

public static DefaultDistributedDataConfig of(com.typesafe.config.Config config)

Returns an instance of DefaultDistributedDataConfig based on the settings of the specified Config.

Parameters:

config - is supposed to provide the settings of the ddata config at "ddata".

Returns:

the instance.

Throws:

DittoConfigError - if config is invalid.

of

public static DefaultDistributedDataConfig of(com.typesafe.config.Config config,
 CharSequence replicatorName,
 CharSequence replicatorRole)

Returns an instance of DefaultDistributedDataConfig based on the settings of the specified Config.

Parameters:

config - is supposed to provide the settings of the ddata config at "ddata".

replicatorName - the name of the replicator.

replicatorRole - the cluster role of members with replicas of the distributed collection.

Returns:

the instance.

Throws:

DittoConfigError - if config is invalid.

getReadTimeout

public Duration getReadTimeout()

Description copied from interface: DistributedDataConfig

Returns the timeout of GET-messages of the replicator.

Specified by:

getReadTimeout in interface DistributedDataConfig

Returns:

the timeout of reads.

getWriteTimeout

public Duration getWriteTimeout()

Description copied from interface: DistributedDataConfig

Returns the timeout of UPDATE-messages of the replicator.

Specified by:

getWriteTimeout in interface DistributedDataConfig

Returns:

the timeout of writes.

getSubscriptionWriteConsistency

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

Description copied from interface: DistributedDataConfig

Returns the write consistency for topic subscription.

Specified by:

getSubscriptionWriteConsistency in interface DistributedDataConfig

Returns:

the write consistency.

getSubscriptionDelay

public Duration getSubscriptionDelay()

Description copied from interface: DistributedDataConfig

Returns the delay for subscriptions.

Specified by:

getSubscriptionDelay in interface DistributedDataConfig

Returns:

the subscription delay.

getPekkoReplicatorConfig

public PekkoReplicatorConfig getPekkoReplicatorConfig()

Description copied from interface: DistributedDataConfig

Returns the config to use for creating the Replicator.

Specified by:

getPekkoReplicatorConfig in interface DistributedDataConfig

Returns:

the Pekko replicator config to use.

getNumberOfShards

public int getNumberOfShards()

Description copied from interface: DistributedDataConfig

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

Specified by:

getNumberOfShards in interface DistributedDataConfig

Returns:

the number of shards to apply.

getSubscriberPoolSize

public int getSubscriberPoolSize()

Description copied from interface: DistributedDataConfig

The number of subscribers in each subscriber pool.

Specified by:

getSubscriberPoolSize in interface DistributedDataConfig

Returns:

the number of subscribers.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object