public static class ClusterShardingSettings.TuningParameters
extends java.lang.Object
Constructor and 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 leastShardAllocationRebalanceThreshold,
int leastShardAllocationMaxSimultaneousRebalance,
scala.concurrent.duration.FiniteDuration waitingForStateTimeout,
scala.concurrent.duration.FiniteDuration updatingStateTimeout) |
Modifier and Type | Method and Description |
---|---|
int |
bufferSize() |
scala.concurrent.duration.FiniteDuration |
coordinatorFailureBackoff() |
scala.concurrent.duration.FiniteDuration |
entityRestartBackoff() |
scala.concurrent.duration.FiniteDuration |
handOffTimeout() |
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() |
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)
public scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff()
public scala.concurrent.duration.FiniteDuration retryInterval()
public int bufferSize()
public scala.concurrent.duration.FiniteDuration handOffTimeout()
public scala.concurrent.duration.FiniteDuration shardStartTimeout()
public scala.concurrent.duration.FiniteDuration shardFailureBackoff()
public scala.concurrent.duration.FiniteDuration entityRestartBackoff()
public scala.concurrent.duration.FiniteDuration rebalanceInterval()
public int snapshotAfter()
public int leastShardAllocationRebalanceThreshold()
public int leastShardAllocationMaxSimultaneousRebalance()
public scala.concurrent.duration.FiniteDuration waitingForStateTimeout()
public scala.concurrent.duration.FiniteDuration updatingStateTimeout()