Class TuningParameters
Inheritance
TuningParameters
Assembly: Akka.Cluster.Sharding.dll
Syntax
[Serializable]
public class TuningParameters
Constructors
|
Improve this Doc
View Source
TuningParameters(TimeSpan, TimeSpan, Int32, TimeSpan, TimeSpan, TimeSpan, TimeSpan, TimeSpan, Int32, Int32, Int32, Int32, TimeSpan, TimeSpan, String, TimeSpan, Int32, Int32, Int32, Int32, Double)
Declaration
public TuningParameters(TimeSpan coordinatorFailureBackoff, TimeSpan retryInterval, int bufferSize, TimeSpan handOffTimeout, TimeSpan shardStartTimeout, TimeSpan shardFailureBackoff, TimeSpan entityRestartBackoff, TimeSpan rebalanceInterval, int snapshotAfter, int keepNrOfBatches, int leastShardAllocationRebalanceThreshold, int leastShardAllocationMaxSimultaneousRebalance, TimeSpan waitingForStateTimeout, TimeSpan updatingStateTimeout, string entityRecoveryStrategy, TimeSpan entityRecoveryConstantRateStrategyFrequency, int entityRecoveryConstantRateStrategyNumberOfEntities, int coordinatorStateWriteMajorityPlus, int coordinatorStateReadMajorityPlus, int leastShardAllocationAbsoluteLimit, double leastShardAllocationRelativeLimit)
Parameters
Type |
Name |
Description |
TimeSpan |
coordinatorFailureBackoff |
TBD
|
TimeSpan |
retryInterval |
TBD
|
Int32 |
bufferSize |
TBD
|
TimeSpan |
handOffTimeout |
TBD
|
TimeSpan |
shardStartTimeout |
TBD
|
TimeSpan |
shardFailureBackoff |
TBD
|
TimeSpan |
entityRestartBackoff |
TBD
|
TimeSpan |
rebalanceInterval |
TBD
|
Int32 |
snapshotAfter |
TBD
|
Int32 |
keepNrOfBatches |
Keep this number of old persistent batches
|
Int32 |
leastShardAllocationRebalanceThreshold |
TBD
|
Int32 |
leastShardAllocationMaxSimultaneousRebalance |
TBD
|
TimeSpan |
waitingForStateTimeout |
TBD
|
TimeSpan |
updatingStateTimeout |
TBD
|
String |
entityRecoveryStrategy |
TBD
|
TimeSpan |
entityRecoveryConstantRateStrategyFrequency |
TBD
|
Int32 |
entityRecoveryConstantRateStrategyNumberOfEntities |
TBD
|
Int32 |
coordinatorStateWriteMajorityPlus |
TBD
|
Int32 |
coordinatorStateReadMajorityPlus |
TBD
|
Int32 |
leastShardAllocationAbsoluteLimit |
TBD
|
Double |
leastShardAllocationRelativeLimit |
TBD
|
Exceptions
Type |
Condition |
ArgumentException |
This exception is thrown when the specified entityRecoveryStrategy is invalid.
Acceptable values include: all | constant
|
Fields
|
Improve this Doc
View Source
BufferSize
Declaration
public readonly int BufferSize
Field Value
|
Improve this Doc
View Source
CoordinatorFailureBackoff
Declaration
public readonly TimeSpan CoordinatorFailureBackoff
Field Value
|
Improve this Doc
View Source
CoordinatorStateReadMajorityPlus
Declaration
public readonly int CoordinatorStateReadMajorityPlus
Field Value
|
Improve this Doc
View Source
CoordinatorStateWriteMajorityPlus
Declaration
public readonly int CoordinatorStateWriteMajorityPlus
Field Value
|
Improve this Doc
View Source
EntityRecoveryConstantRateStrategyFrequency
Declaration
public readonly TimeSpan EntityRecoveryConstantRateStrategyFrequency
Field Value
|
Improve this Doc
View Source
EntityRecoveryConstantRateStrategyNumberOfEntities
Declaration
public readonly int EntityRecoveryConstantRateStrategyNumberOfEntities
Field Value
|
Improve this Doc
View Source
EntityRecoveryStrategy
Declaration
public readonly string EntityRecoveryStrategy
Field Value
|
Improve this Doc
View Source
EntityRestartBackoff
Declaration
public readonly TimeSpan EntityRestartBackoff
Field Value
|
Improve this Doc
View Source
HandOffTimeout
Declaration
public readonly TimeSpan HandOffTimeout
Field Value
|
Improve this Doc
View Source
KeepNrOfBatches
The shard deletes persistent events (messages and snapshots) after doing snapshot
keeping this number of old persistent batches.
Batch is of size SnapshotAfter.
When set to 0 after snapshot is successfully done all messages with equal or lower sequence number will be deleted.
Default value of 2 leaves last maximum 2*SnapshotAfter messages and 3 snapshots (2 old ones + fresh snapshot)
Declaration
public readonly int KeepNrOfBatches
Field Value
|
Improve this Doc
View Source
LeastShardAllocationAbsoluteLimit
Declaration
public readonly int LeastShardAllocationAbsoluteLimit
Field Value
|
Improve this Doc
View Source
LeastShardAllocationMaxSimultaneousRebalance
Declaration
public readonly int LeastShardAllocationMaxSimultaneousRebalance
Field Value
|
Improve this Doc
View Source
LeastShardAllocationRebalanceThreshold
Declaration
public readonly int LeastShardAllocationRebalanceThreshold
Field Value
|
Improve this Doc
View Source
LeastShardAllocationRelativeLimit
Declaration
public readonly double LeastShardAllocationRelativeLimit
Field Value
|
Improve this Doc
View Source
RebalanceInterval
Declaration
public readonly TimeSpan RebalanceInterval
Field Value
|
Improve this Doc
View Source
RetryInterval
Declaration
public readonly TimeSpan RetryInterval
Field Value
|
Improve this Doc
View Source
ShardFailureBackoff
Declaration
public readonly TimeSpan ShardFailureBackoff
Field Value
|
Improve this Doc
View Source
ShardStartTimeout
Declaration
public readonly TimeSpan ShardStartTimeout
Field Value
|
Improve this Doc
View Source
SnapshotAfter
Declaration
public readonly int SnapshotAfter
Field Value
|
Improve this Doc
View Source
UpdatingStateTimeout
Declaration
public readonly TimeSpan UpdatingStateTimeout
Field Value
|
Improve this Doc
View Source
WaitingForStateTimeout
Declaration
public readonly TimeSpan WaitingForStateTimeout
Field Value
Methods
|
Improve this Doc
View Source
WithBufferSize(Int32)
Declaration
public TuningParameters WithBufferSize(int bufferSize)
Parameters
Type |
Name |
Description |
Int32 |
bufferSize |
|
Returns
|
Improve this Doc
View Source
WithCoordinatorFailureBackoff(TimeSpan)
Declaration
public TuningParameters WithCoordinatorFailureBackoff(TimeSpan coordinatorFailureBackoff)
Parameters
Type |
Name |
Description |
TimeSpan |
coordinatorFailureBackoff |
|
Returns
|
Improve this Doc
View Source
WithCoordinatorStateReadMajorityPlus(Int32)
Declaration
public TuningParameters WithCoordinatorStateReadMajorityPlus(int coordinatorStateReadMajorityPlus)
Parameters
Type |
Name |
Description |
Int32 |
coordinatorStateReadMajorityPlus |
|
Returns
|
Improve this Doc
View Source
WithCoordinatorStateWriteMajorityPlus(Int32)
Declaration
public TuningParameters WithCoordinatorStateWriteMajorityPlus(int coordinatorStateWriteMajorityPlus)
Parameters
Type |
Name |
Description |
Int32 |
coordinatorStateWriteMajorityPlus |
|
Returns
|
Improve this Doc
View Source
WithEntityRecoveryConstantRateStrategyFrequency(TimeSpan)
Declaration
public TuningParameters WithEntityRecoveryConstantRateStrategyFrequency(TimeSpan entityRecoveryConstantRateStrategyFrequency)
Parameters
Type |
Name |
Description |
TimeSpan |
entityRecoveryConstantRateStrategyFrequency |
|
Returns
|
Improve this Doc
View Source
WithEntityRecoveryConstantRateStrategyNumberOfEntities(Int32)
Declaration
public TuningParameters WithEntityRecoveryConstantRateStrategyNumberOfEntities(int entityRecoveryConstantRateStrategyNumberOfEntities)
Parameters
Type |
Name |
Description |
Int32 |
entityRecoveryConstantRateStrategyNumberOfEntities |
|
Returns
|
Improve this Doc
View Source
WithEntityRecoveryStrategy(String)
Declaration
public TuningParameters WithEntityRecoveryStrategy(string entityRecoveryStrategy)
Parameters
Type |
Name |
Description |
String |
entityRecoveryStrategy |
|
Returns
|
Improve this Doc
View Source
WithEntityRestartBackoff(TimeSpan)
Declaration
public TuningParameters WithEntityRestartBackoff(TimeSpan entityRestartBackoff)
Parameters
Type |
Name |
Description |
TimeSpan |
entityRestartBackoff |
|
Returns
|
Improve this Doc
View Source
WithHandOffTimeout(TimeSpan)
Declaration
public TuningParameters WithHandOffTimeout(TimeSpan handOffTimeout)
Parameters
Type |
Name |
Description |
TimeSpan |
handOffTimeout |
|
Returns
|
Improve this Doc
View Source
WithKeepNrOfBatches(Int32)
Declaration
public TuningParameters WithKeepNrOfBatches(int keepNrOfBatches)
Parameters
Type |
Name |
Description |
Int32 |
keepNrOfBatches |
|
Returns
|
Improve this Doc
View Source
WithLeastShardAllocationAbsoluteLimit(Int32)
Declaration
public TuningParameters WithLeastShardAllocationAbsoluteLimit(int leastShardAllocationAbsoluteLimit)
Parameters
Type |
Name |
Description |
Int32 |
leastShardAllocationAbsoluteLimit |
|
Returns
|
Improve this Doc
View Source
WithLeastShardAllocationMaxSimultaneousRebalance(Int32)
Declaration
public TuningParameters WithLeastShardAllocationMaxSimultaneousRebalance(int leastShardAllocationMaxSimultaneousRebalance)
Parameters
Type |
Name |
Description |
Int32 |
leastShardAllocationMaxSimultaneousRebalance |
|
Returns
|
Improve this Doc
View Source
WithLeastShardAllocationRebalanceThreshold(Int32)
Declaration
public TuningParameters WithLeastShardAllocationRebalanceThreshold(int leastShardAllocationRebalanceThreshold)
Parameters
Type |
Name |
Description |
Int32 |
leastShardAllocationRebalanceThreshold |
|
Returns
|
Improve this Doc
View Source
WithLeastShardAllocationRelativeLimit(Double)
Declaration
public TuningParameters WithLeastShardAllocationRelativeLimit(double leastShardAllocationRelativeLimit)
Parameters
Type |
Name |
Description |
Double |
leastShardAllocationRelativeLimit |
|
Returns
|
Improve this Doc
View Source
WithRebalanceInterval(TimeSpan)
Declaration
public TuningParameters WithRebalanceInterval(TimeSpan rebalanceInterval)
Parameters
Type |
Name |
Description |
TimeSpan |
rebalanceInterval |
|
Returns
|
Improve this Doc
View Source
WithRetryInterval(TimeSpan)
Declaration
public TuningParameters WithRetryInterval(TimeSpan retryInterval)
Parameters
Type |
Name |
Description |
TimeSpan |
retryInterval |
|
Returns
|
Improve this Doc
View Source
WithShardFailureBackoff(TimeSpan)
Declaration
public TuningParameters WithShardFailureBackoff(TimeSpan shardFailureBackoff)
Parameters
Type |
Name |
Description |
TimeSpan |
shardFailureBackoff |
|
Returns
|
Improve this Doc
View Source
WithShardStartTimeout(TimeSpan)
Declaration
public TuningParameters WithShardStartTimeout(TimeSpan shardStartTimeout)
Parameters
Type |
Name |
Description |
TimeSpan |
shardStartTimeout |
|
Returns
|
Improve this Doc
View Source
WithSnapshotAfter(Int32)
Declaration
public TuningParameters WithSnapshotAfter(int snapshotAfter)
Parameters
Type |
Name |
Description |
Int32 |
snapshotAfter |
|
Returns
|
Improve this Doc
View Source
WithUpdatingStateTimeout(TimeSpan)
Declaration
public TuningParameters WithUpdatingStateTimeout(TimeSpan updatingStateTimeout)
Parameters
Type |
Name |
Description |
TimeSpan |
updatingStateTimeout |
|
Returns
|
Improve this Doc
View Source
WithWaitingForStateTimeout(TimeSpan)
Declaration
public TuningParameters WithWaitingForStateTimeout(TimeSpan waitingForStateTimeout)
Parameters
Type |
Name |
Description |
TimeSpan |
waitingForStateTimeout |
|
Returns
Extension Methods