Class ClusterSingletonSettings


  • public final class ClusterSingletonSettings
    extends java.lang.Object
    • Constructor Detail

      • ClusterSingletonSettings

        public ClusterSingletonSettings​(scala.Option<java.lang.String> role,
                                        scala.Option<java.lang.String> dataCenter,
                                        scala.concurrent.duration.FiniteDuration singletonIdentificationInterval,
                                        scala.concurrent.duration.FiniteDuration removalMargin,
                                        scala.concurrent.duration.FiniteDuration handOverRetryInterval,
                                        int bufferSize)
    • Method Detail

      • role

        public scala.Option<java.lang.String> role()
      • dataCenter

        public scala.Option<java.lang.String> dataCenter()
      • singletonIdentificationInterval

        public scala.concurrent.duration.FiniteDuration singletonIdentificationInterval()
      • removalMargin

        public scala.concurrent.duration.FiniteDuration removalMargin()
      • handOverRetryInterval

        public scala.concurrent.duration.FiniteDuration handOverRetryInterval()
      • bufferSize

        public int bufferSize()
      • withRemovalMargin

        public ClusterSingletonSettings withRemovalMargin​(scala.concurrent.duration.FiniteDuration removalMargin)
      • withHandoverRetryInterval

        public ClusterSingletonSettings withHandoverRetryInterval​(scala.concurrent.duration.FiniteDuration handOverRetryInterval)
      • withHandoverRetryInterval

        public ClusterSingletonSettings withHandoverRetryInterval​(java.time.Duration handOverRetryInterval)
      • shouldRunManager

        public boolean shouldRunManager​(Cluster cluster)
        INTERNAL API:
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object