Class ClusterShardingSettings.TuningParameters

  • Enclosing class:
    ClusterShardingSettings

    public static class ClusterShardingSettings.TuningParameters
    extends java.lang.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, java.lang.String entityRecoveryStrategy, scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency, int entityRecoveryConstantRateStrategyNumberOfEntities)
      Deprecated.
      Use the ClusterShardingSettings factory methods or the constructor including coordinatorStateWriteMajorityPlus and coordinatorStateReadMajorityPlus instead.
      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, java.lang.String entityRecoveryStrategy, scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency, int entityRecoveryConstantRateStrategyNumberOfEntities, int coordinatorStateWriteMajorityPlus, int coordinatorStateReadMajorityPlus)
      Deprecated.
      Use the TuningParameters factory methods or the constructor including leastShardAllocationAbsoluteLimit and leastShardAllocationRelativeLimit instead.
      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, java.lang.String entityRecoveryStrategy, scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency, int entityRecoveryConstantRateStrategyNumberOfEntities, int coordinatorStateWriteMajorityPlus, int coordinatorStateReadMajorityPlus, int leastShardAllocationAbsoluteLimit, double leastShardAllocationRelativeLimit)
      Deprecated.
      Use the TuningParameters factory methods or the constructor including passivationStopTimeout instead.
      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, java.lang.String entityRecoveryStrategy, scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency, int entityRecoveryConstantRateStrategyNumberOfEntities, int coordinatorStateWriteMajorityPlus, int coordinatorStateReadMajorityPlus, int leastShardAllocationAbsoluteLimit, double leastShardAllocationRelativeLimit, scala.concurrent.duration.FiniteDuration passivationStopTimeout)  
      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)
      Deprecated.
      Use the ClusterShardingSettings factory methods or the full constructor instead.
      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)
      Deprecated.
      Use the ClusterShardingSettings factory methods or the full constructor instead.
    • 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 keepNrOfBatches,
                                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,
                                int coordinatorStateWriteMajorityPlus,
                                int coordinatorStateReadMajorityPlus,
                                int leastShardAllocationAbsoluteLimit,
                                double leastShardAllocationRelativeLimit,
                                scala.concurrent.duration.FiniteDuration passivationStopTimeout)
      • 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,
                                java.lang.String entityRecoveryStrategy,
                                scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency,
                                int entityRecoveryConstantRateStrategyNumberOfEntities,
                                int coordinatorStateWriteMajorityPlus,
                                int coordinatorStateReadMajorityPlus,
                                int leastShardAllocationAbsoluteLimit,
                                double leastShardAllocationRelativeLimit)
        Deprecated.
        Use the TuningParameters factory methods or the constructor including passivationStopTimeout instead. Since 2.9.4.
      • 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,
                                java.lang.String entityRecoveryStrategy,
                                scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency,
                                int entityRecoveryConstantRateStrategyNumberOfEntities,
                                int coordinatorStateWriteMajorityPlus,
                                int coordinatorStateReadMajorityPlus)
        Deprecated.
        Use the TuningParameters factory methods or the constructor including leastShardAllocationAbsoluteLimit and leastShardAllocationRelativeLimit instead. Since 2.6.10.
      • 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,
                                java.lang.String entityRecoveryStrategy,
                                scala.concurrent.duration.FiniteDuration entityRecoveryConstantRateStrategyFrequency,
                                int entityRecoveryConstantRateStrategyNumberOfEntities)
        Deprecated.
        Use the ClusterShardingSettings factory methods or the constructor including coordinatorStateWriteMajorityPlus and coordinatorStateReadMajorityPlus instead. Since 2.6.5.
      • 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)
        Deprecated.
        Use the ClusterShardingSettings factory methods or the full constructor instead. Since 2.6.5.
      • 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)
        Deprecated.
        Use the ClusterShardingSettings factory methods or the full constructor instead. Since 2.6.5.
    • Method Detail

      • 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 java.lang.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()
      • passivationStopTimeout

        public scala.concurrent.duration.FiniteDuration passivationStopTimeout()
      • 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()