Package org.apache.pekko.cluster.sharding

Class ClusterShardingSettings.TuningParameters

java.lang.Object

org.apache.pekko.cluster.sharding.ClusterShardingSettings.TuningParameters

Enclosing class:

ClusterShardingSettings

public static class ClusterShardingSettings.TuningParameters
extends 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, String entityRecoveryStrategy, scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency, int entityRecoveryConstantRateStrategyNumberOfEntities, int coordinatorStateWriteMajorityPlus, int coordinatorStateReadMajorityPlus, int leastShardAllocationAbsoluteLimit, double leastShardAllocationRelativeLimit)

Method Summary

Modifier and Type	Method	Description
int	bufferSize()
scala.concurrent.duration.FiniteDuration	coordinatorFailureBackoff()
int	coordinatorStateReadMajorityPlus()
int	coordinatorStateWriteMajorityPlus()
scala.concurrent.duration.FiniteDuration	entityRecoveryConstantRateStrategyFrequency()
int	entityRecoveryConstantRateStrategyNumberOfEntities()
String	entityRecoveryStrategy()
scala.concurrent.duration.FiniteDuration	entityRestartBackoff()
scala.concurrent.duration.FiniteDuration	handOffTimeout()
int	keepNrOfBatches()
int	leastShardAllocationAbsoluteLimit()
int	leastShardAllocationMaxSimultaneousRebalance()
int	leastShardAllocationRebalanceThreshold()
double	leastShardAllocationRelativeLimit()
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 Details

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,
 String entityRecoveryStrategy,
 scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency,
 int entityRecoveryConstantRateStrategyNumberOfEntities,
 int coordinatorStateWriteMajorityPlus,
 int coordinatorStateReadMajorityPlus,
 int leastShardAllocationAbsoluteLimit,
 double leastShardAllocationRelativeLimit)

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

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

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