Package org.apache.pekko.cluster.sharding

Class ClusterShardingSettings.TuningParameters

java.lang.Object

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

Enclosing class:

ClusterShardingSettings

public static class ClusterShardingSettings.TuningParameters
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
TuningParameters(scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff, scala.concurrent.duration.FiniteDuration retryInterval, int bufferSize, scala.concurrent.duration.FiniteDuration handOffTimeout, scala.concurrent.duration.FiniteDuration shardStartTimeout, scala.concurrent.duration.FiniteDuration shardFailureBackoff, scala.concurrent.duration.FiniteDuration entityRestartBackoff, scala.concurrent.duration.FiniteDuration rebalanceInterval, int snapshotAfter, int keepNrOfBatches, int leastShardAllocationRebalanceThreshold, int leastShardAllocationMaxSimultaneousRebalance, scala.concurrent.duration.FiniteDuration waitingForStateTimeout, scala.concurrent.duration.FiniteDuration updatingStateTimeout, java.lang.String entityRecoveryStrategy, scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency, int entityRecoveryConstantRateStrategyNumberOfEntities)	Deprecated. Use the ClusterShardingSettings factory methods or the constructor including coordinatorStateWriteMajorityPlus and coordinatorStateReadMajorityPlus instead.
TuningParameters(scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff, scala.concurrent.duration.FiniteDuration retryInterval, int bufferSize, scala.concurrent.duration.FiniteDuration handOffTimeout, scala.concurrent.duration.FiniteDuration shardStartTimeout, scala.concurrent.duration.FiniteDuration shardFailureBackoff, scala.concurrent.duration.FiniteDuration entityRestartBackoff, scala.concurrent.duration.FiniteDuration rebalanceInterval, int snapshotAfter, int keepNrOfBatches, int leastShardAllocationRebalanceThreshold, int leastShardAllocationMaxSimultaneousRebalance, scala.concurrent.duration.FiniteDuration waitingForStateTimeout, scala.concurrent.duration.FiniteDuration updatingStateTimeout, java.lang.String entityRecoveryStrategy, scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency, int entityRecoveryConstantRateStrategyNumberOfEntities, int coordinatorStateWriteMajorityPlus, int coordinatorStateReadMajorityPlus)	Deprecated. Use the ClusterShardingSettings factory methods or the constructor including leastShardAllocationAbsoluteLimit and leastShardAllocationRelativeLimit instead.
TuningParameters(scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff, scala.concurrent.duration.FiniteDuration retryInterval, int bufferSize, scala.concurrent.duration.FiniteDuration handOffTimeout, scala.concurrent.duration.FiniteDuration shardStartTimeout, scala.concurrent.duration.FiniteDuration shardFailureBackoff, scala.concurrent.duration.FiniteDuration entityRestartBackoff, scala.concurrent.duration.FiniteDuration rebalanceInterval, int snapshotAfter, int keepNrOfBatches, int leastShardAllocationRebalanceThreshold, int leastShardAllocationMaxSimultaneousRebalance, scala.concurrent.duration.FiniteDuration waitingForStateTimeout, scala.concurrent.duration.FiniteDuration updatingStateTimeout, java.lang.String entityRecoveryStrategy, scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency, int entityRecoveryConstantRateStrategyNumberOfEntities, int coordinatorStateWriteMajorityPlus, int coordinatorStateReadMajorityPlus, int leastShardAllocationAbsoluteLimit, double leastShardAllocationRelativeLimit)
TuningParameters(scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff, scala.concurrent.duration.FiniteDuration retryInterval, int bufferSize, scala.concurrent.duration.FiniteDuration handOffTimeout, scala.concurrent.duration.FiniteDuration shardStartTimeout, scala.concurrent.duration.FiniteDuration shardFailureBackoff, scala.concurrent.duration.FiniteDuration entityRestartBackoff, scala.concurrent.duration.FiniteDuration rebalanceInterval, int snapshotAfter, int leastShardAllocationRebalanceThreshold, int leastShardAllocationMaxSimultaneousRebalance, scala.concurrent.duration.FiniteDuration waitingForStateTimeout, scala.concurrent.duration.FiniteDuration updatingStateTimeout)	Deprecated. Use the ClusterShardingSettings factory methods or the full constructor instead.
TuningParameters(scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff, scala.concurrent.duration.FiniteDuration retryInterval, int bufferSize, scala.concurrent.duration.FiniteDuration handOffTimeout, scala.concurrent.duration.FiniteDuration shardStartTimeout, scala.concurrent.duration.FiniteDuration shardFailureBackoff, scala.concurrent.duration.FiniteDuration entityRestartBackoff, scala.concurrent.duration.FiniteDuration rebalanceInterval, int snapshotAfter, int leastShardAllocationRebalanceThreshold, int leastShardAllocationMaxSimultaneousRebalance, scala.concurrent.duration.FiniteDuration waitingForStateTimeout, scala.concurrent.duration.FiniteDuration updatingStateTimeout, java.lang.String entityRecoveryStrategy, scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency, int entityRecoveryConstantRateStrategyNumberOfEntities)	Deprecated. Use the ClusterShardingSettings factory methods or the full constructor instead.

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()
java.lang.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()
scala.concurrent.duration.FiniteDuration	updatingStateTimeout()
scala.concurrent.duration.FiniteDuration	waitingForStateTimeout()

Methods inherited from class java.lang.Object

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

Constructor Detail

TuningParameters

public TuningParameters(scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff,
                        scala.concurrent.duration.FiniteDuration retryInterval,
                        int bufferSize,
                        scala.concurrent.duration.FiniteDuration handOffTimeout,
                        scala.concurrent.duration.FiniteDuration shardStartTimeout,
                        scala.concurrent.duration.FiniteDuration shardFailureBackoff,
                        scala.concurrent.duration.FiniteDuration entityRestartBackoff,
                        scala.concurrent.duration.FiniteDuration rebalanceInterval,
                        int snapshotAfter,
                        int keepNrOfBatches,
                        int leastShardAllocationRebalanceThreshold,
                        int leastShardAllocationMaxSimultaneousRebalance,
                        scala.concurrent.duration.FiniteDuration waitingForStateTimeout,
                        scala.concurrent.duration.FiniteDuration updatingStateTimeout,
                        java.lang.String entityRecoveryStrategy,
                        scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency,
                        int entityRecoveryConstantRateStrategyNumberOfEntities,
                        int coordinatorStateWriteMajorityPlus,
                        int coordinatorStateReadMajorityPlus,
                        int leastShardAllocationAbsoluteLimit,
                        double leastShardAllocationRelativeLimit)

TuningParameters

public TuningParameters(scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff,
                        scala.concurrent.duration.FiniteDuration retryInterval,
                        int bufferSize,
                        scala.concurrent.duration.FiniteDuration handOffTimeout,
                        scala.concurrent.duration.FiniteDuration shardStartTimeout,
                        scala.concurrent.duration.FiniteDuration shardFailureBackoff,
                        scala.concurrent.duration.FiniteDuration entityRestartBackoff,
                        scala.concurrent.duration.FiniteDuration rebalanceInterval,
                        int snapshotAfter,
                        int keepNrOfBatches,
                        int leastShardAllocationRebalanceThreshold,
                        int leastShardAllocationMaxSimultaneousRebalance,
                        scala.concurrent.duration.FiniteDuration waitingForStateTimeout,
                        scala.concurrent.duration.FiniteDuration updatingStateTimeout,
                        java.lang.String entityRecoveryStrategy,
                        scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency,
                        int entityRecoveryConstantRateStrategyNumberOfEntities,
                        int coordinatorStateWriteMajorityPlus,
                        int coordinatorStateReadMajorityPlus)

Deprecated.

Use the ClusterShardingSettings factory methods or the constructor including leastShardAllocationAbsoluteLimit and leastShardAllocationRelativeLimit instead. Since Akka 2.6.10.

TuningParameters

public TuningParameters(scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff,
                        scala.concurrent.duration.FiniteDuration retryInterval,
                        int bufferSize,
                        scala.concurrent.duration.FiniteDuration handOffTimeout,
                        scala.concurrent.duration.FiniteDuration shardStartTimeout,
                        scala.concurrent.duration.FiniteDuration shardFailureBackoff,
                        scala.concurrent.duration.FiniteDuration entityRestartBackoff,
                        scala.concurrent.duration.FiniteDuration rebalanceInterval,
                        int snapshotAfter,
                        int keepNrOfBatches,
                        int leastShardAllocationRebalanceThreshold,
                        int leastShardAllocationMaxSimultaneousRebalance,
                        scala.concurrent.duration.FiniteDuration waitingForStateTimeout,
                        scala.concurrent.duration.FiniteDuration updatingStateTimeout,
                        java.lang.String entityRecoveryStrategy,
                        scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency,
                        int entityRecoveryConstantRateStrategyNumberOfEntities)

Deprecated.

Use the ClusterShardingSettings factory methods or the constructor including coordinatorStateWriteMajorityPlus and coordinatorStateReadMajorityPlus instead. Since Akka 2.6.5.

TuningParameters

public TuningParameters(scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff,
                        scala.concurrent.duration.FiniteDuration retryInterval,
                        int bufferSize,
                        scala.concurrent.duration.FiniteDuration handOffTimeout,
                        scala.concurrent.duration.FiniteDuration shardStartTimeout,
                        scala.concurrent.duration.FiniteDuration shardFailureBackoff,
                        scala.concurrent.duration.FiniteDuration entityRestartBackoff,
                        scala.concurrent.duration.FiniteDuration rebalanceInterval,
                        int snapshotAfter,
                        int leastShardAllocationRebalanceThreshold,
                        int leastShardAllocationMaxSimultaneousRebalance,
                        scala.concurrent.duration.FiniteDuration waitingForStateTimeout,
                        scala.concurrent.duration.FiniteDuration updatingStateTimeout,
                        java.lang.String entityRecoveryStrategy,
                        scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency,
                        int entityRecoveryConstantRateStrategyNumberOfEntities)

Deprecated.

Use the ClusterShardingSettings factory methods or the full constructor instead. Since Akka 2.6.5.

TuningParameters

public TuningParameters(scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff,
                        scala.concurrent.duration.FiniteDuration retryInterval,
                        int bufferSize,
                        scala.concurrent.duration.FiniteDuration handOffTimeout,
                        scala.concurrent.duration.FiniteDuration shardStartTimeout,
                        scala.concurrent.duration.FiniteDuration shardFailureBackoff,
                        scala.concurrent.duration.FiniteDuration entityRestartBackoff,
                        scala.concurrent.duration.FiniteDuration rebalanceInterval,
                        int snapshotAfter,
                        int leastShardAllocationRebalanceThreshold,
                        int leastShardAllocationMaxSimultaneousRebalance,
                        scala.concurrent.duration.FiniteDuration waitingForStateTimeout,
                        scala.concurrent.duration.FiniteDuration updatingStateTimeout)

Deprecated.

Use the ClusterShardingSettings factory methods or the full constructor instead. Since Akka 2.6.5.

Method Detail

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 java.lang.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()

updatingStateTimeout

public scala.concurrent.duration.FiniteDuration updatingStateTimeout()

waitingForStateTimeout

public scala.concurrent.duration.FiniteDuration waitingForStateTimeout()