Package akka.cluster.sharding
Class ClusterShardingSettings.TuningParameters
- java.lang.Object
-
- akka.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)
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)
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)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
bufferSize()
scala.concurrent.duration.FiniteDuration
coordinatorFailureBackoff()
scala.concurrent.duration.FiniteDuration
entityRecoveryConstantRateStrategyFrequency()
int
entityRecoveryConstantRateStrategyNumberOfEntities()
java.lang.String
entityRecoveryStrategy()
scala.concurrent.duration.FiniteDuration
entityRestartBackoff()
scala.concurrent.duration.FiniteDuration
handOffTimeout()
int
keepNrOfBatches()
int
leastShardAllocationMaxSimultaneousRebalance()
int
leastShardAllocationRebalanceThreshold()
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)
-
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)
-
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)
-
-
Method Detail
-
bufferSize
public int bufferSize()
-
coordinatorFailureBackoff
public scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff()
-
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()
-
leastShardAllocationMaxSimultaneousRebalance
public int leastShardAllocationMaxSimultaneousRebalance()
-
leastShardAllocationRebalanceThreshold
public int leastShardAllocationRebalanceThreshold()
-
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()
-
-