Package akka.cluster
Class ClusterSettings
- java.lang.Object
-
- akka.cluster.ClusterSettings
-
public final class ClusterSettings extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description classClusterSettings.CrossDcFailureDetectorSettingsclassClusterSettings.Debug$classClusterSettings.MultiDataCenter$
-
Constructor Summary
Constructors Constructor Description ClusterSettings(com.typesafe.config.Config config, java.lang.String systemName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanAllowWeaklyUpMembers()VersionAppVersion()booleanByPassConfigCompatCheck()com.typesafe.config.Configconfig()scala.collection.immutable.Set<java.lang.String>ConfigCompatCheckers()ClusterSettings.Debug$Debug()Accessor for nested Scala objectjava.lang.StringDowningProviderClassName()scala.concurrent.duration.FiniteDurationDownRemovalMargin()com.typesafe.config.ConfigFailureDetectorConfig()java.lang.StringFailureDetectorImplementationClass()doubleGossipDifferentViewProbability()scala.concurrent.duration.FiniteDurationGossipInterval()scala.concurrent.duration.FiniteDurationGossipTimeToLive()scala.concurrent.duration.FiniteDurationHeartbeatExpectedResponseAfter()scala.concurrent.duration.FiniteDurationHeartbeatInterval()booleanJmxEnabled()booleanJmxMultiMbeansInSameEnabled()scala.concurrent.duration.FiniteDurationLeaderActionsInterval()booleanLogInfo()booleanLogInfoVerbose()intMinNrOfMembers()scala.collection.immutable.Map<java.lang.String,java.lang.Object>MinNrOfMembersOfRole()intMonitoredByNrOfMembers()ClusterSettings.MultiDataCenter$MultiDataCenter()Accessor for nested Scala objectscala.concurrent.duration.FiniteDurationPeriodicTasksInitialDelay()scala.concurrent.duration.DurationPruneGossipTombstonesAfter()Is in fact always aFiniteDurationbut needs to stayDurationfor binary compatibilityscala.concurrent.duration.DurationPublishStatsInterval()scala.concurrent.duration.FiniteDurationQuarantineRemovedNodeAfter()intReduceGossipDifferentViewProbability()scala.concurrent.duration.DurationRetryUnsuccessfulJoinAfter()scala.collection.immutable.Set<java.lang.String>Roles()booleanRunCoordinatedShutdownWhenDown()scala.concurrent.duration.FiniteDurationSchedulerTickDuration()intSchedulerTicksPerWheel()scala.collection.immutable.IndexedSeq<Address>SeedNodes()scala.concurrent.duration.FiniteDurationSeedNodeTimeout()java.lang.StringSelfDataCenter()scala.collection.immutable.Set<java.lang.String>SensitiveConfigPaths()scala.concurrent.duration.DurationShutdownAfterUnsuccessfulJoinSeedNodes()java.lang.StringsystemName()scala.concurrent.duration.FiniteDurationUnreachableNodesReaperInterval()java.lang.StringUseDispatcher()scala.concurrent.duration.FiniteDurationWeaklyUpAfter()
-
-
-
Method Detail
-
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 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 aFiniteDurationbut needs to stayDurationfor binary compatibility
-
DownRemovalMargin
public scala.concurrent.duration.FiniteDuration DownRemovalMargin()
-
DowningProviderClassName
public java.lang.String DowningProviderClassName()
-
QuarantineRemovedNodeAfter
public scala.concurrent.duration.FiniteDuration QuarantineRemovedNodeAfter()
-
WeaklyUpAfter
public scala.concurrent.duration.FiniteDuration WeaklyUpAfter()
-
AllowWeaklyUpMembers
public boolean AllowWeaklyUpMembers()
-
SelfDataCenter
public java.lang.String SelfDataCenter()
-
Roles
public scala.collection.immutable.Set<java.lang.String> Roles()
-
AppVersion
public Version AppVersion()
-
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()
-
-