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 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)
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

Modifier and Type	Method and 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	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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 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

coordinatorFailureBackoff

public scala.concurrent.duration.FiniteDuration coordinatorFailureBackoff()

retryInterval

public scala.concurrent.duration.FiniteDuration retryInterval()

bufferSize

public int bufferSize()

handOffTimeout

public scala.concurrent.duration.FiniteDuration handOffTimeout()

shardStartTimeout

public scala.concurrent.duration.FiniteDuration shardStartTimeout()

shardFailureBackoff

public scala.concurrent.duration.FiniteDuration shardFailureBackoff()

entityRestartBackoff

public scala.concurrent.duration.FiniteDuration entityRestartBackoff()

rebalanceInterval

public scala.concurrent.duration.FiniteDuration rebalanceInterval()

snapshotAfter

public int snapshotAfter()

leastShardAllocationRebalanceThreshold

public int leastShardAllocationRebalanceThreshold()

leastShardAllocationMaxSimultaneousRebalance

public int leastShardAllocationMaxSimultaneousRebalance()

waitingForStateTimeout

public scala.concurrent.duration.FiniteDuration waitingForStateTimeout()

updatingStateTimeout

public scala.concurrent.duration.FiniteDuration updatingStateTimeout()

entityRecoveryStrategy

public java.lang.String entityRecoveryStrategy()

entityRecoveryConstantRateStrategyFrequency

public scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency()

entityRecoveryConstantRateStrategyNumberOfEntities

public int entityRecoveryConstantRateStrategyNumberOfEntities()