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
All Methods Instance Methods Concrete Methods 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()
-
-
-
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()
-
-