Package akka.cluster
Class ClusterSettings
- java.lang.Object
-
- akka.cluster.ClusterSettings
-
public final class ClusterSettings extends java.lang.Object
Is in fact always aFiniteDuration
but needs to stayDuration
for binary compatibility
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
ClusterSettings.CrossDcFailureDetectorSettings
class
ClusterSettings.Debug$
class
ClusterSettings.MultiDataCenter$
-
Constructor Summary
Constructors Constructor Description ClusterSettings(com.typesafe.config.Config config, java.lang.String systemName)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description boolean
AllowWeaklyUpMembers()
scala.concurrent.duration.Duration
AutoDownUnreachableAfter()
boolean
ByPassConfigCompatCheck()
com.typesafe.config.Config
config()
scala.collection.immutable.Set<java.lang.String>
ConfigCompatCheckers()
static java.lang.String
DcRolePrefix()
INTERNAL API.ClusterSettings.Debug$
Debug()
Accessor for nested Scala objectstatic java.lang.String
DefaultDataCenter()
INTERNAL API.java.lang.String
DowningProviderClassName()
scala.concurrent.duration.FiniteDuration
DownRemovalMargin()
Deprecated.Specific toAutoDown
should not be used anywhere else, insteadCluster.downingProvider.downRemovalMargin
should be used as it allows the downing provider to decide removal margins
com.typesafe.config.Config
FailureDetectorConfig()
java.lang.String
FailureDetectorImplementationClass()
double
GossipDifferentViewProbability()
scala.concurrent.duration.FiniteDuration
GossipInterval()
scala.concurrent.duration.FiniteDuration
GossipTimeToLive()
scala.concurrent.duration.FiniteDuration
HeartbeatExpectedResponseAfter()
scala.concurrent.duration.FiniteDuration
HeartbeatInterval()
boolean
JmxEnabled()
boolean
JmxMultiMbeansInSameEnabled()
scala.concurrent.duration.FiniteDuration
LeaderActionsInterval()
boolean
LogInfo()
boolean
LogInfoVerbose()
int
MinNrOfMembers()
scala.collection.immutable.Map<java.lang.String,java.lang.Object>
MinNrOfMembersOfRole()
int
MonitoredByNrOfMembers()
ClusterSettings.MultiDataCenter$
MultiDataCenter()
Accessor for nested Scala objectscala.concurrent.duration.FiniteDuration
PeriodicTasksInitialDelay()
scala.concurrent.duration.Duration
PruneGossipTombstonesAfter()
Is in fact always aFiniteDuration
but needs to stayDuration
for binary compatibilityscala.concurrent.duration.Duration
PublishStatsInterval()
scala.concurrent.duration.FiniteDuration
QuarantineRemovedNodeAfter()
int
ReduceGossipDifferentViewProbability()
scala.concurrent.duration.Duration
RetryUnsuccessfulJoinAfter()
scala.collection.immutable.Set<java.lang.String>
Roles()
boolean
RunCoordinatedShutdownWhenDown()
scala.concurrent.duration.FiniteDuration
SchedulerTickDuration()
int
SchedulerTicksPerWheel()
scala.collection.immutable.IndexedSeq<Address>
SeedNodes()
scala.concurrent.duration.FiniteDuration
SeedNodeTimeout()
java.lang.String
SelfDataCenter()
scala.collection.immutable.Set<java.lang.String>
SensitiveConfigPaths()
scala.concurrent.duration.Duration
ShutdownAfterUnsuccessfulJoinSeedNodes()
java.lang.String
systemName()
scala.concurrent.duration.FiniteDuration
UnreachableNodesReaperInterval()
java.lang.String
UseDispatcher()
-
-
-
Method Detail
-
DcRolePrefix
public static java.lang.String DcRolePrefix()
INTERNAL API.- Returns:
- (undocumented)
-
DefaultDataCenter
public static java.lang.String DefaultDataCenter()
INTERNAL API.- Returns:
- (undocumented)
-
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 aFiniteDuration
but needs to stayDuration
for binary compatibility- Returns:
- (undocumented)
-
AutoDownUnreachableAfter
public scala.concurrent.duration.Duration AutoDownUnreachableAfter()
-
DownRemovalMargin
public scala.concurrent.duration.FiniteDuration DownRemovalMargin()
Deprecated.Specific toAutoDown
should not be used anywhere else, insteadCluster.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()
-
-