Package org.apache.pekko.cluster

Class ClusterSettings

java.lang.Object
org.apache.pekko.cluster.ClusterSettings
public final class ClusterSettings extends Object

  • Constructor Details

    • ClusterSettings

      public ClusterSettings(com.typesafe.config.Config config, String systemName)

  • Method Details

    • MultiDataCenter

      public ClusterSettings.MultiDataCenter$ MultiDataCenter()
      Accessor for nested Scala object
      Returns:
      (undocumented)

    • Debug

      public ClusterSettings.Debug$ Debug()
      Accessor for nested Scala object
      Returns:
      (undocumented)

    • config

      public com.typesafe.config.Config config()

    • systemName

      public String systemName()

    • LogInfoVerbose

      public boolean LogInfoVerbose()

    • LogInfo

      public boolean LogInfo()

    • FailureDetectorConfig

      public com.typesafe.config.Config FailureDetectorConfig()

    • FailureDetectorImplementationClass

      public 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

    • DownRemovalMargin

      public scala.concurrent.duration.FiniteDuration DownRemovalMargin()

    • DowningProviderClassName

      public String DowningProviderClassName()

    • QuarantineRemovedNodeAfter

      public scala.concurrent.duration.FiniteDuration QuarantineRemovedNodeAfter()

    • WeaklyUpAfter

      public scala.concurrent.duration.FiniteDuration WeaklyUpAfter()

    • AllowWeaklyUpMembers

      public boolean AllowWeaklyUpMembers()

    • SelfDataCenter

      public String SelfDataCenter()

    • Roles

      public scala.collection.immutable.Set<String> Roles()

    • AppVersion

      public Version AppVersion()

    • MinNrOfMembers

      public int MinNrOfMembers()

    • MinNrOfMembersOfRole

      public scala.collection.immutable.Map<String,Object> MinNrOfMembersOfRole()

    • RunCoordinatedShutdownWhenDown

      public boolean RunCoordinatedShutdownWhenDown()

    • JmxEnabled

      public boolean JmxEnabled()

    • JmxMultiMbeansInSameEnabled

      public boolean JmxMultiMbeansInSameEnabled()

    • UseDispatcher

      public 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<String> ConfigCompatCheckers()

    • SensitiveConfigPaths

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