Class ClusterShardingSettings.TuningParameters
java.lang.Object
org.apache.pekko.cluster.sharding.typed.ClusterShardingSettings.TuningParameters
- Enclosing class:
- ClusterShardingSettings
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionintscala.concurrent.duration.FiniteDurationintintscala.concurrent.duration.FiniteDurationintscala.concurrent.duration.FiniteDurationscala.concurrent.duration.FiniteDurationintintintintdoublescala.concurrent.duration.FiniteDurationscala.concurrent.duration.FiniteDurationscala.concurrent.duration.FiniteDurationscala.concurrent.duration.FiniteDurationinttoString()scala.concurrent.duration.FiniteDurationscala.concurrent.duration.FiniteDurationwithBufferSize(int value) withCoordinatorFailureBackoff(scala.concurrent.duration.FiniteDuration value) withCoordinatorStateReadMajorityPlus(int value) withCoordinatorStateWriteMajorityPlus(int value) withEntityRecoveryConstantRateStrategyFrequency(scala.concurrent.duration.FiniteDuration value) withEntityRecoveryStrategy(String value) withEntityRestartBackoff(Duration value) withEntityRestartBackoff(scala.concurrent.duration.FiniteDuration value) withHandOffTimeout(Duration value) withHandOffTimeout(scala.concurrent.duration.FiniteDuration value) withKeepNrOfBatches(int value) withLeastShardAllocationAbsoluteLimit(int value) withLeastShardAllocationRebalanceThreshold(int value) withLeastShardAllocationRelativeLimit(double value) withRebalanceInterval(Duration value) withRebalanceInterval(scala.concurrent.duration.FiniteDuration value) withRetryInterval(Duration value) withRetryInterval(scala.concurrent.duration.FiniteDuration value) withShardFailureBackoff(Duration value) withShardFailureBackoff(scala.concurrent.duration.FiniteDuration value) withShardStartTimeout(Duration value) withShardStartTimeout(scala.concurrent.duration.FiniteDuration value) withSnapshotAfter(int value) withUpdatingStateTimeout(Duration value) withUpdatingStateTimeout(scala.concurrent.duration.FiniteDuration value) withWaitingForStateTimeout(scala.concurrent.duration.FiniteDuration value)
-
Constructor Details
-
TuningParameters
-
-
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
-
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
-
updatingStateTimeout
public scala.concurrent.duration.FiniteDuration updatingStateTimeout() -
waitingForStateTimeout
public scala.concurrent.duration.FiniteDuration waitingForStateTimeout() -
withBufferSize
-
withCoordinatorFailureBackoff
public ClusterShardingSettings.TuningParameters withCoordinatorFailureBackoff(scala.concurrent.duration.FiniteDuration value) -
withCoordinatorFailureBackoff
-
withCoordinatorStateReadMajorityPlus
-
withCoordinatorStateWriteMajorityPlus
-
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
-
withEntityRestartBackoff
public ClusterShardingSettings.TuningParameters withEntityRestartBackoff(scala.concurrent.duration.FiniteDuration value) -
withEntityRestartBackoff
-
withHandOffTimeout
public ClusterShardingSettings.TuningParameters withHandOffTimeout(scala.concurrent.duration.FiniteDuration value) -
withHandOffTimeout
-
withKeepNrOfBatches
-
withLeastShardAllocationAbsoluteLimit
-
withLeastShardAllocationMaxSimultaneousRebalance
public ClusterShardingSettings.TuningParameters withLeastShardAllocationMaxSimultaneousRebalance(int value) -
withLeastShardAllocationRebalanceThreshold
public ClusterShardingSettings.TuningParameters withLeastShardAllocationRebalanceThreshold(int value) -
withLeastShardAllocationRelativeLimit
-
withRebalanceInterval
public ClusterShardingSettings.TuningParameters withRebalanceInterval(scala.concurrent.duration.FiniteDuration value) -
withRebalanceInterval
-
withRetryInterval
public ClusterShardingSettings.TuningParameters withRetryInterval(scala.concurrent.duration.FiniteDuration value) -
withRetryInterval
-
withShardFailureBackoff
public ClusterShardingSettings.TuningParameters withShardFailureBackoff(scala.concurrent.duration.FiniteDuration value) -
withShardFailureBackoff
-
withShardStartTimeout
public ClusterShardingSettings.TuningParameters withShardStartTimeout(scala.concurrent.duration.FiniteDuration value) -
withShardStartTimeout
-
withSnapshotAfter
-
withUpdatingStateTimeout
public ClusterShardingSettings.TuningParameters withUpdatingStateTimeout(scala.concurrent.duration.FiniteDuration value) -
withUpdatingStateTimeout
-
withWaitingForStateTimeout
public ClusterShardingSettings.TuningParameters withWaitingForStateTimeout(scala.concurrent.duration.FiniteDuration value) -
withWaitingForStateTimeout
-