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 and Description
class	ClusterSettings.Debug

Constructor Summary

Constructors

Constructor and Description
ClusterSettings(com.typesafe.config.Config config, java.lang.String systemName)

Method Summary

Modifier and Type	Method and Description
boolean	AllowWeaklyUpMembers()
scala.concurrent.duration.Duration	AutoDownUnreachableAfter()
com.typesafe.config.Config	config()
akka.cluster.ClusterSettings.Debug$	Debug()
java.lang.String	DowningProviderClassName()
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
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()
scala.concurrent.duration.FiniteDuration	LeaderActionsInterval()
boolean	LogInfo()
java.lang.String	MetricsCollectorClass()
boolean	MetricsEnabled()
scala.concurrent.duration.FiniteDuration	MetricsGossipInterval()
scala.concurrent.duration.FiniteDuration	MetricsInterval()
scala.concurrent.duration.FiniteDuration	MetricsMovingAverageHalfLife()
int	MinNrOfMembers()
scala.collection.immutable.Map<java.lang.String,java.lang.Object>	MinNrOfMembersOfRole()
int	MonitoredByNrOfMembers()
scala.concurrent.duration.FiniteDuration	PeriodicTasksInitialDelay()
scala.concurrent.duration.Duration	PublishStatsInterval()
scala.concurrent.duration.FiniteDuration	QuarantineRemovedNodeAfter()
int	ReduceGossipDifferentViewProbability()
scala.concurrent.duration.Duration	RetryUnsuccessfulJoinAfter()
scala.collection.immutable.Set<java.lang.String>	Roles()
scala.concurrent.duration.FiniteDuration	SchedulerTickDuration()
int	SchedulerTicksPerWheel()
scala.collection.immutable.IndexedSeq<Address>	SeedNodes()
scala.concurrent.duration.FiniteDuration	SeedNodeTimeout()
java.lang.String	systemName()
scala.concurrent.duration.FiniteDuration	UnreachableNodesReaperInterval()
java.lang.String	UseDispatcher()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterSettings

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

Method Detail

Debug

public akka.cluster.ClusterSettings.Debug$ Debug()

config

public com.typesafe.config.Config config()

systemName

public java.lang.String systemName()

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()

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()

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()

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()

JmxEnabled

public boolean JmxEnabled()

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()

MetricsEnabled

public boolean MetricsEnabled()

MetricsCollectorClass

public java.lang.String MetricsCollectorClass()

MetricsInterval

public scala.concurrent.duration.FiniteDuration MetricsInterval()

MetricsGossipInterval

public scala.concurrent.duration.FiniteDuration MetricsGossipInterval()

MetricsMovingAverageHalfLife

public scala.concurrent.duration.FiniteDuration MetricsMovingAverageHalfLife()