Package org.apache.pekko.cluster.sharding.typed

Class ClusterShardingSettings.TuningParameters

java.lang.Object

org.apache.pekko.cluster.sharding.typed.ClusterShardingSettings.TuningParameters

Enclosing class:

ClusterShardingSettings

public static final class ClusterShardingSettings.TuningParameters
extends Object

Constructor Summary

Constructors

Constructor	Description
TuningParameters(ClusterShardingSettings.TuningParameters classic)

Method Summary

Modifier and Type	Method	Description
int	bufferSize()
scala.concurrent.duration.FiniteDuration	coordinatorFailureBackoff()
int	coordinatorStateReadMajorityPlus()
int	coordinatorStateWriteMajorityPlus()
scala.concurrent.duration.FiniteDuration	entityRecoveryConstantRateStrategyFrequency()
int	entityRecoveryConstantRateStrategyNumberOfEntities()
String	entityRecoveryStrategy()
scala.concurrent.duration.FiniteDuration	entityRestartBackoff()
scala.concurrent.duration.FiniteDuration	handOffTimeout()
int	keepNrOfBatches()
int	leastShardAllocationAbsoluteLimit()
int	leastShardAllocationMaxSimultaneousRebalance()
int	leastShardAllocationRebalanceThreshold()
double	leastShardAllocationRelativeLimit()
scala.concurrent.duration.FiniteDuration	rebalanceInterval()
scala.concurrent.duration.FiniteDuration	retryInterval()
scala.concurrent.duration.FiniteDuration	shardFailureBackoff()
scala.concurrent.duration.FiniteDuration	shardStartTimeout()
int	snapshotAfter()
String	toString()
scala.concurrent.duration.FiniteDuration	updatingStateTimeout()
scala.concurrent.duration.FiniteDuration	waitingForStateTimeout()
ClusterShardingSettings.TuningParameters	withBufferSize(int value)
ClusterShardingSettings.TuningParameters	withCoordinatorFailureBackoff(Duration value)
ClusterShardingSettings.TuningParameters	withCoordinatorFailureBackoff(scala.concurrent.duration.FiniteDuration value)
ClusterShardingSettings.TuningParameters	withCoordinatorStateReadMajorityPlus(int value)
ClusterShardingSettings.TuningParameters	withCoordinatorStateWriteMajorityPlus(int value)
ClusterShardingSettings.TuningParameters	withEntityRecoveryConstantRateStrategyFrequency(Duration value)
ClusterShardingSettings.TuningParameters	withEntityRecoveryConstantRateStrategyFrequency(scala.concurrent.duration.FiniteDuration value)
ClusterShardingSettings.TuningParameters	withEntityRecoveryConstantRateStrategyNumberOfEntities(int value)
ClusterShardingSettings.TuningParameters	withEntityRecoveryStrategy(String value)
ClusterShardingSettings.TuningParameters	withEntityRestartBackoff(Duration value)
ClusterShardingSettings.TuningParameters	withEntityRestartBackoff(scala.concurrent.duration.FiniteDuration value)
ClusterShardingSettings.TuningParameters	withHandOffTimeout(Duration value)
ClusterShardingSettings.TuningParameters	withHandOffTimeout(scala.concurrent.duration.FiniteDuration value)
ClusterShardingSettings.TuningParameters	withKeepNrOfBatches(int value)
ClusterShardingSettings.TuningParameters	withLeastShardAllocationAbsoluteLimit(int value)
ClusterShardingSettings.TuningParameters	withLeastShardAllocationMaxSimultaneousRebalance(int value)
ClusterShardingSettings.TuningParameters	withLeastShardAllocationRebalanceThreshold(int value)
ClusterShardingSettings.TuningParameters	withLeastShardAllocationRelativeLimit(double value)
ClusterShardingSettings.TuningParameters	withRebalanceInterval(Duration value)
ClusterShardingSettings.TuningParameters	withRebalanceInterval(scala.concurrent.duration.FiniteDuration value)
ClusterShardingSettings.TuningParameters	withRetryInterval(Duration value)
ClusterShardingSettings.TuningParameters	withRetryInterval(scala.concurrent.duration.FiniteDuration value)
ClusterShardingSettings.TuningParameters	withShardFailureBackoff(Duration value)
ClusterShardingSettings.TuningParameters	withShardFailureBackoff(scala.concurrent.duration.FiniteDuration value)
ClusterShardingSettings.TuningParameters	withShardStartTimeout(Duration value)
ClusterShardingSettings.TuningParameters	withShardStartTimeout(scala.concurrent.duration.FiniteDuration value)
ClusterShardingSettings.TuningParameters	withSnapshotAfter(int value)
ClusterShardingSettings.TuningParameters	withUpdatingStateTimeout(Duration value)
ClusterShardingSettings.TuningParameters	withUpdatingStateTimeout(scala.concurrent.duration.FiniteDuration value)
ClusterShardingSettings.TuningParameters	withWaitingForStateTimeout(Duration value)
ClusterShardingSettings.TuningParameters	withWaitingForStateTimeout(scala.concurrent.duration.FiniteDuration value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

TuningParameters

public TuningParameters(ClusterShardingSettings.TuningParameters classic)

Method Details

bufferSize

public int bufferSize()

coordinatorFailureBackoff

public scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff()

coordinatorStateReadMajorityPlus

public int coordinatorStateReadMajorityPlus()

coordinatorStateWriteMajorityPlus

public int coordinatorStateWriteMajorityPlus()

entityRecoveryConstantRateStrategyFrequency

public scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency()

entityRecoveryConstantRateStrategyNumberOfEntities

public int entityRecoveryConstantRateStrategyNumberOfEntities()

entityRecoveryStrategy

public String entityRecoveryStrategy()

entityRestartBackoff

public scala.concurrent.duration.FiniteDuration entityRestartBackoff()

handOffTimeout

public scala.concurrent.duration.FiniteDuration handOffTimeout()

keepNrOfBatches

public int keepNrOfBatches()

leastShardAllocationAbsoluteLimit

public int leastShardAllocationAbsoluteLimit()

leastShardAllocationMaxSimultaneousRebalance

public int leastShardAllocationMaxSimultaneousRebalance()

leastShardAllocationRebalanceThreshold

public int leastShardAllocationRebalanceThreshold()

leastShardAllocationRelativeLimit

public double leastShardAllocationRelativeLimit()

rebalanceInterval

public scala.concurrent.duration.FiniteDuration rebalanceInterval()

retryInterval

public scala.concurrent.duration.FiniteDuration retryInterval()

shardFailureBackoff

public scala.concurrent.duration.FiniteDuration shardFailureBackoff()

shardStartTimeout

public scala.concurrent.duration.FiniteDuration shardStartTimeout()

snapshotAfter

public int snapshotAfter()

toString

public String toString()

Overrides:

toString in class Object

updatingStateTimeout

public scala.concurrent.duration.FiniteDuration updatingStateTimeout()

waitingForStateTimeout

public scala.concurrent.duration.FiniteDuration waitingForStateTimeout()

withBufferSize

public ClusterShardingSettings.TuningParameters withBufferSize(int value)

withCoordinatorFailureBackoff

public ClusterShardingSettings.TuningParameters withCoordinatorFailureBackoff(scala.concurrent.duration.FiniteDuration value)

withCoordinatorFailureBackoff

public ClusterShardingSettings.TuningParameters withCoordinatorFailureBackoff(Duration value)

withCoordinatorStateReadMajorityPlus

public ClusterShardingSettings.TuningParameters withCoordinatorStateReadMajorityPlus(int value)

withCoordinatorStateWriteMajorityPlus

public ClusterShardingSettings.TuningParameters withCoordinatorStateWriteMajorityPlus(int value)

withEntityRecoveryConstantRateStrategyFrequency

public ClusterShardingSettings.TuningParameters withEntityRecoveryConstantRateStrategyFrequency(scala.concurrent.duration.FiniteDuration value)

withEntityRecoveryConstantRateStrategyFrequency

public ClusterShardingSettings.TuningParameters withEntityRecoveryConstantRateStrategyFrequency(Duration value)

withEntityRecoveryConstantRateStrategyNumberOfEntities

public ClusterShardingSettings.TuningParameters withEntityRecoveryConstantRateStrategyNumberOfEntities(int value)

withEntityRecoveryStrategy

public ClusterShardingSettings.TuningParameters withEntityRecoveryStrategy(String value)

withEntityRestartBackoff

public ClusterShardingSettings.TuningParameters withEntityRestartBackoff(scala.concurrent.duration.FiniteDuration value)

withEntityRestartBackoff

public ClusterShardingSettings.TuningParameters withEntityRestartBackoff(Duration value)

withHandOffTimeout

public ClusterShardingSettings.TuningParameters withHandOffTimeout(scala.concurrent.duration.FiniteDuration value)

withHandOffTimeout

public ClusterShardingSettings.TuningParameters withHandOffTimeout(Duration value)

withKeepNrOfBatches

public ClusterShardingSettings.TuningParameters withKeepNrOfBatches(int value)

withLeastShardAllocationAbsoluteLimit

public ClusterShardingSettings.TuningParameters withLeastShardAllocationAbsoluteLimit(int value)

withLeastShardAllocationMaxSimultaneousRebalance

public ClusterShardingSettings.TuningParameters withLeastShardAllocationMaxSimultaneousRebalance(int value)

withLeastShardAllocationRebalanceThreshold

public ClusterShardingSettings.TuningParameters withLeastShardAllocationRebalanceThreshold(int value)

withLeastShardAllocationRelativeLimit

public ClusterShardingSettings.TuningParameters withLeastShardAllocationRelativeLimit(double value)

withRebalanceInterval

public ClusterShardingSettings.TuningParameters withRebalanceInterval(scala.concurrent.duration.FiniteDuration value)

withRebalanceInterval

public ClusterShardingSettings.TuningParameters withRebalanceInterval(Duration value)

withRetryInterval

public ClusterShardingSettings.TuningParameters withRetryInterval(scala.concurrent.duration.FiniteDuration value)

withRetryInterval

public ClusterShardingSettings.TuningParameters withRetryInterval(Duration value)

withShardFailureBackoff

public ClusterShardingSettings.TuningParameters withShardFailureBackoff(scala.concurrent.duration.FiniteDuration value)

withShardFailureBackoff

public ClusterShardingSettings.TuningParameters withShardFailureBackoff(Duration value)

withShardStartTimeout

public ClusterShardingSettings.TuningParameters withShardStartTimeout(scala.concurrent.duration.FiniteDuration value)

withShardStartTimeout

public ClusterShardingSettings.TuningParameters withShardStartTimeout(Duration value)

withSnapshotAfter

public ClusterShardingSettings.TuningParameters withSnapshotAfter(int value)

withUpdatingStateTimeout

public ClusterShardingSettings.TuningParameters withUpdatingStateTimeout(scala.concurrent.duration.FiniteDuration value)

withUpdatingStateTimeout

public ClusterShardingSettings.TuningParameters withUpdatingStateTimeout(Duration value)

withWaitingForStateTimeout

public ClusterShardingSettings.TuningParameters withWaitingForStateTimeout(scala.concurrent.duration.FiniteDuration value)

withWaitingForStateTimeout

public ClusterShardingSettings.TuningParameters withWaitingForStateTimeout(Duration value)