Package akka.cluster

Class ClusterSettings


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

      • ClusterSettings

        public ClusterSettings​(com.typesafe.config.Config config,
                               java.lang.String systemName)
    • Method Detail

      • DcRolePrefix

        public static java.lang.String DcRolePrefix()
        INTERNAL API.
        Returns:
        (undocumented)
      • DefaultDataCenter

        public static java.lang.String DefaultDataCenter()
        INTERNAL API.
        Returns:
        (undocumented)
      • config

        public com.typesafe.config.Config config()
      • systemName

        public java.lang.String systemName()
      • LogInfoVerbose

        public boolean LogInfoVerbose()
      • LogInfo

        public boolean LogInfo()
      • FailureDetectorConfig

        public com.typesafe.config.Config FailureDetectorConfig()
      • FailureDetectorImplementationClass

        public java.lang.String FailureDetectorImplementationClass()
      • HeartbeatInterval

        public scala.concurrent.duration.FiniteDuration HeartbeatInterval()
      • HeartbeatExpectedResponseAfter

        public scala.concurrent.duration.FiniteDuration HeartbeatExpectedResponseAfter()
      • MonitoredByNrOfMembers

        public int MonitoredByNrOfMembers()
      • SeedNodes

        public scala.collection.immutable.IndexedSeq<Address> SeedNodes()
      • SeedNodeTimeout

        public scala.concurrent.duration.FiniteDuration SeedNodeTimeout()
      • RetryUnsuccessfulJoinAfter

        public scala.concurrent.duration.Duration RetryUnsuccessfulJoinAfter()
      • ShutdownAfterUnsuccessfulJoinSeedNodes

        public scala.concurrent.duration.Duration ShutdownAfterUnsuccessfulJoinSeedNodes()
      • PeriodicTasksInitialDelay

        public scala.concurrent.duration.FiniteDuration PeriodicTasksInitialDelay()
      • GossipInterval

        public scala.concurrent.duration.FiniteDuration GossipInterval()
      • GossipTimeToLive

        public scala.concurrent.duration.FiniteDuration GossipTimeToLive()
      • LeaderActionsInterval

        public scala.concurrent.duration.FiniteDuration LeaderActionsInterval()
      • UnreachableNodesReaperInterval

        public scala.concurrent.duration.FiniteDuration UnreachableNodesReaperInterval()
      • PublishStatsInterval

        public scala.concurrent.duration.Duration PublishStatsInterval()
      • PruneGossipTombstonesAfter

        public scala.concurrent.duration.Duration PruneGossipTombstonesAfter()
        Is in fact always a FiniteDuration but needs to stay Duration for binary compatibility
        Returns:
        (undocumented)
      • AutoDownUnreachableAfter

        public scala.concurrent.duration.Duration AutoDownUnreachableAfter()
      • DownRemovalMargin

        public scala.concurrent.duration.FiniteDuration DownRemovalMargin()
        Deprecated.
        Specific to AutoDown should not be used anywhere else, instead Cluster.downingProvider.downRemovalMargin should be used as it allows the downing provider to decide removal margins
        Returns:
        (undocumented)
      • DowningProviderClassName

        public java.lang.String DowningProviderClassName()
      • QuarantineRemovedNodeAfter

        public scala.concurrent.duration.FiniteDuration QuarantineRemovedNodeAfter()
      • AllowWeaklyUpMembers

        public boolean AllowWeaklyUpMembers()
      • SelfDataCenter

        public java.lang.String SelfDataCenter()
      • Roles

        public scala.collection.immutable.Set<java.lang.String> Roles()
      • MinNrOfMembers

        public int MinNrOfMembers()
      • MinNrOfMembersOfRole

        public scala.collection.immutable.Map<java.lang.String,​java.lang.Object> MinNrOfMembersOfRole()
      • RunCoordinatedShutdownWhenDown

        public boolean RunCoordinatedShutdownWhenDown()
      • JmxEnabled

        public boolean JmxEnabled()
      • JmxMultiMbeansInSameEnabled

        public boolean JmxMultiMbeansInSameEnabled()
      • UseDispatcher

        public java.lang.String UseDispatcher()
      • GossipDifferentViewProbability

        public double GossipDifferentViewProbability()
      • ReduceGossipDifferentViewProbability

        public int ReduceGossipDifferentViewProbability()
      • SchedulerTickDuration

        public scala.concurrent.duration.FiniteDuration SchedulerTickDuration()
      • SchedulerTicksPerWheel

        public int SchedulerTicksPerWheel()
      • ByPassConfigCompatCheck

        public boolean ByPassConfigCompatCheck()
      • ConfigCompatCheckers

        public scala.collection.immutable.Set<java.lang.String> ConfigCompatCheckers()
      • SensitiveConfigPaths

        public scala.collection.immutable.Set<java.lang.String> SensitiveConfigPaths()