Package akka.cluster.sharding.typed
Class ClusterShardingSettings.TuningParameters
- java.lang.Object
-
- akka.cluster.sharding.typed.ClusterShardingSettings.TuningParameters
-
- Enclosing class:
- ClusterShardingSettings
public static final class ClusterShardingSettings.TuningParameters extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description TuningParameters(ClusterShardingSettings.TuningParameters classic)
-
Method Summary
-
-
-
Constructor Detail
-
TuningParameters
public TuningParameters(ClusterShardingSettings.TuningParameters classic)
-
-
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()
-
passivationStopTimeout
public scala.concurrent.duration.FiniteDuration passivationStopTimeout()
-
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 java.lang.String toString()
- Overrides:
toString
in classjava.lang.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(java.time.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(java.time.Duration value)
-
withEntityRecoveryConstantRateStrategyNumberOfEntities
public ClusterShardingSettings.TuningParameters withEntityRecoveryConstantRateStrategyNumberOfEntities(int value)
-
withEntityRecoveryStrategy
public ClusterShardingSettings.TuningParameters withEntityRecoveryStrategy(java.lang.String value)
-
withEntityRestartBackoff
public ClusterShardingSettings.TuningParameters withEntityRestartBackoff(scala.concurrent.duration.FiniteDuration value)
-
withEntityRestartBackoff
public ClusterShardingSettings.TuningParameters withEntityRestartBackoff(java.time.Duration value)
-
withHandOffTimeout
public ClusterShardingSettings.TuningParameters withHandOffTimeout(scala.concurrent.duration.FiniteDuration value)
-
withHandOffTimeout
public ClusterShardingSettings.TuningParameters withHandOffTimeout(java.time.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)
-
withPassivationStopTimeout
public ClusterShardingSettings.TuningParameters withPassivationStopTimeout(scala.concurrent.duration.FiniteDuration value)
-
withPassivationStopTimeout
public ClusterShardingSettings.TuningParameters withPassivationStopTimeout(java.time.Duration value)
-
withRebalanceInterval
public ClusterShardingSettings.TuningParameters withRebalanceInterval(scala.concurrent.duration.FiniteDuration value)
-
withRebalanceInterval
public ClusterShardingSettings.TuningParameters withRebalanceInterval(java.time.Duration value)
-
withRetryInterval
public ClusterShardingSettings.TuningParameters withRetryInterval(scala.concurrent.duration.FiniteDuration value)
-
withRetryInterval
public ClusterShardingSettings.TuningParameters withRetryInterval(java.time.Duration value)
-
withShardFailureBackoff
public ClusterShardingSettings.TuningParameters withShardFailureBackoff(scala.concurrent.duration.FiniteDuration value)
-
withShardFailureBackoff
public ClusterShardingSettings.TuningParameters withShardFailureBackoff(java.time.Duration value)
-
withShardStartTimeout
public ClusterShardingSettings.TuningParameters withShardStartTimeout(scala.concurrent.duration.FiniteDuration value)
-
withShardStartTimeout
public ClusterShardingSettings.TuningParameters withShardStartTimeout(java.time.Duration value)
-
withSnapshotAfter
public ClusterShardingSettings.TuningParameters withSnapshotAfter(int value)
-
withUpdatingStateTimeout
public ClusterShardingSettings.TuningParameters withUpdatingStateTimeout(scala.concurrent.duration.FiniteDuration value)
-
withUpdatingStateTimeout
public ClusterShardingSettings.TuningParameters withUpdatingStateTimeout(java.time.Duration value)
-
withWaitingForStateTimeout
public ClusterShardingSettings.TuningParameters withWaitingForStateTimeout(scala.concurrent.duration.FiniteDuration value)
-
withWaitingForStateTimeout
public ClusterShardingSettings.TuningParameters withWaitingForStateTimeout(java.time.Duration value)
-
-