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

      • bufferSize

        public int bufferSize()
      • coordinatorFailureBackoff

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

        public int leastShardAllocationMaxSimultaneousRebalance()
      • leastShardAllocationRebalanceThreshold

        public int leastShardAllocationRebalanceThreshold()
      • 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()