AutoDown |
INTERNAL API
|
AutoDown.UnreachableTimeout |
|
AutoDown.UnreachableTimeout$ |
|
AutoDown$ |
INTERNAL API
|
AutoDownBase |
INTERNAL API
|
AutoDowning |
Used when no custom provider is configured and 'auto-down-unreachable-after' is enabled.
|
Cluster |
The address including a uid of this cluster member.
|
Cluster$ |
INTERNAL API
|
ClusterActorRefProvider |
Factory method to make it possible to override deployer in subclass
Creates a new instance every time
|
ClusterCoreDaemon |
Looks up and returns the remote cluster command connection for the specific address.
|
ClusterCoreDaemon$ |
INTERNAL API.
|
ClusterCoreSupervisor |
INTERNAL API.
|
ClusterDaemon |
INTERNAL API.
|
ClusterDeployer |
INTERNAL API
|
ClusterDomainEventPublisher |
The current snapshot state corresponding to latest gossip
to mimic what you would have seen if you were listening to the events.
|
ClusterEvent |
|
ClusterEvent.ClusterShuttingDown$ |
|
ClusterEvent.CurrentClusterState |
|
ClusterEvent.CurrentClusterState$ |
|
ClusterEvent.CurrentInternalStats |
|
ClusterEvent.CurrentInternalStats$ |
|
ClusterEvent.InitialStateAsEvents$ |
|
ClusterEvent.InitialStateAsSnapshot$ |
|
ClusterEvent.LeaderChanged |
|
ClusterEvent.LeaderChanged$ |
|
ClusterEvent.MemberDowned |
|
ClusterEvent.MemberDowned$ |
|
ClusterEvent.MemberExited |
|
ClusterEvent.MemberExited$ |
|
ClusterEvent.MemberJoined |
|
ClusterEvent.MemberJoined$ |
|
ClusterEvent.MemberLeft |
|
ClusterEvent.MemberLeft$ |
|
ClusterEvent.MemberRemoved |
|
ClusterEvent.MemberRemoved$ |
|
ClusterEvent.MemberUp |
|
ClusterEvent.MemberUp$ |
|
ClusterEvent.MemberWeaklyUp |
|
ClusterEvent.MemberWeaklyUp$ |
|
ClusterEvent.ReachabilityChanged |
|
ClusterEvent.ReachabilityChanged$ |
|
ClusterEvent.ReachableDataCenter |
|
ClusterEvent.ReachableDataCenter$ |
|
ClusterEvent.ReachableMember |
|
ClusterEvent.ReachableMember$ |
|
ClusterEvent.RoleLeaderChanged |
|
ClusterEvent.RoleLeaderChanged$ |
|
ClusterEvent.SeenChanged |
|
ClusterEvent.SeenChanged$ |
|
ClusterEvent.SubscriptionInitialStateMode |
|
ClusterEvent.UnreachableDataCenter |
|
ClusterEvent.UnreachableDataCenter$ |
|
ClusterEvent.UnreachableMember |
|
ClusterEvent.UnreachableMember$ |
|
ClusterEvent$ |
|
ClusterHeartbeatReceiver |
INTERNAL API.
|
ClusterHeartbeatReceiver$ |
INTERNAL API: Utilities to obtain ClusterHeartbeatReceiver paths
|
ClusterHeartbeatSender |
Looks up and returns the remote cluster heartbeat connection for the specific address.
|
ClusterHeartbeatSender.ExpectedFirstHeartbeat |
|
ClusterHeartbeatSender.ExpectedFirstHeartbeat$ |
|
ClusterHeartbeatSender.Heartbeat |
|
ClusterHeartbeatSender.Heartbeat$ |
|
ClusterHeartbeatSender.HeartbeatRsp |
|
ClusterHeartbeatSender.HeartbeatRsp$ |
|
ClusterHeartbeatSender.HeartbeatTick$ |
|
ClusterHeartbeatSender$ |
Sent at regular intervals for failure detection.
|
ClusterHeartbeatSenderState |
|
ClusterHeartbeatSenderState$ |
|
ClusterJmx |
Creates the cluster JMX MBean and registers it in the MBean server.
|
ClusterReadView |
Current state
|
ClusterRemoteWatcher |
When a cluster node is added this class takes over the
responsibility for watchees on that node already handled
by super RemoteWatcher.
|
ClusterRemoteWatcher$ |
Factory method for ClusterRemoteWatcher Props .
|
ClusterScope |
|
ClusterScope$ |
Java API: get the singleton instance
|
ClusterSettings |
Is in fact always a FiniteDuration but needs to stay Duration for binary compatibility
|
ClusterSettings$ |
INTERNAL API.
|
ClusterUserAction |
Command to initiate join another node (represented by address ).
|
ClusterUserAction.Down |
|
ClusterUserAction.Down$ |
|
ClusterUserAction.JoinTo |
|
ClusterUserAction.JoinTo$ |
|
ClusterUserAction.Leave |
|
ClusterUserAction.Leave$ |
|
ClusterUserAction$ |
Command to initiate join another node (represented by address ).
|
CoordinatedShutdownLeave |
INTERNAL API
|
CoordinatedShutdownLeave.LeaveReq$ |
|
CoordinatedShutdownLeave$ |
INTERNAL API
|
CrossDcHeartbeatingState |
Decides if self node should become active and monitor other nodes with heartbeats.
|
CrossDcHeartbeatingState$ |
Sorted by age
|
CrossDcHeartbeatSender |
Looks up and returns the remote cluster heartbeat connection for the specific address.
|
CrossDcHeartbeatSender.MonitoringActive |
|
CrossDcHeartbeatSender.MonitoringActive$ |
|
CrossDcHeartbeatSender.MonitoringDormant |
|
CrossDcHeartbeatSender.MonitoringDormant$ |
|
CrossDcHeartbeatSender.ReportStatus |
|
CrossDcHeartbeatSender.ReportStatus$ |
|
CrossDcHeartbeatSender$ |
INTERNAL API
|
DowningProvider |
Time margin after which shards or singletons that belonged to a downed/removed
partition are created in surviving partition.
|
DowningProvider$ |
param: fqcn Fully qualified class name of the implementation to be loaded.
|
FirstSeedNodeProcess |
INTERNAL API.
|
Gossip |
|
Gossip$ |
INTERNAL API
|
GossipEnvelope |
INTERNAL API
Envelope adding a sender and receiver address to the gossip.
|
GossipEnvelope$ |
|
GossipOverview |
INTERNAL API
Represents the overview of the cluster, holds the cluster convergence table and set with unreachable nodes.
|
GossipOverview$ |
|
GossipStats |
INTERNAL API
|
GossipStats$ |
|
GossipStatus |
INTERNAL API
When there are no known changes to the node ring a GossipStatus
initiates a gossip chat between two members.
|
GossipStatus$ |
|
GossipTargetSelector |
Select n random nodes to gossip to (used to quickly inform the rest of the cluster when leaving for example)
|
HeartbeatNodeRing |
Receivers for selfAddress .
|
HeartbeatNodeRing$ |
|
InternalClusterAction |
Command to join the cluster.
|
InternalClusterAction.AddOnMemberRemovedListener |
|
InternalClusterAction.AddOnMemberRemovedListener$ |
|
InternalClusterAction.AddOnMemberUpListener |
|
InternalClusterAction.AddOnMemberUpListener$ |
|
InternalClusterAction.CompatibleConfig |
|
InternalClusterAction.CompatibleConfig$ |
|
InternalClusterAction.ConfigCheckUnsupportedByJoiningNode$ |
|
InternalClusterAction.ExitingCompleted$ |
|
InternalClusterAction.ExitingConfirmed |
|
InternalClusterAction.ExitingConfirmed$ |
|
InternalClusterAction.GetClusterCoreRef$ |
|
InternalClusterAction.GossipSpeedupTick$ |
|
InternalClusterAction.GossipTick$ |
|
InternalClusterAction.IncompatibleConfig$ |
|
InternalClusterAction.InitJoin |
|
InternalClusterAction.InitJoin$ |
|
InternalClusterAction.InitJoinAck |
|
InternalClusterAction.InitJoinAck$ |
|
InternalClusterAction.InitJoinNack |
|
InternalClusterAction.InitJoinNack$ |
|
InternalClusterAction.Join |
|
InternalClusterAction.Join$ |
|
InternalClusterAction.JoinSeedNode$ |
|
InternalClusterAction.JoinSeedNodes |
|
InternalClusterAction.JoinSeedNodes$ |
|
InternalClusterAction.LeaderActionsTick$ |
|
InternalClusterAction.PublishChanges |
|
InternalClusterAction.PublishChanges$ |
|
InternalClusterAction.PublishEvent |
|
InternalClusterAction.PublishEvent$ |
|
InternalClusterAction.PublishStatsTick$ |
|
InternalClusterAction.ReapUnreachableTick$ |
|
InternalClusterAction.SendCurrentClusterState |
|
InternalClusterAction.SendCurrentClusterState$ |
|
InternalClusterAction.SendGossipTo |
|
InternalClusterAction.SendGossipTo$ |
|
InternalClusterAction.Subscribe |
|
InternalClusterAction.Subscribe$ |
|
InternalClusterAction.UncheckedConfig$ |
|
InternalClusterAction.Unsubscribe |
|
InternalClusterAction.Unsubscribe$ |
|
InternalClusterAction.Welcome |
|
InternalClusterAction.Welcome$ |
|
InternalClusterAction$ |
Command to join the cluster.
|
Invalid |
Java API: get the singleton instance
|
Invalid$ |
|
JoinConfigCompatCheckCluster |
INTERNAL API
|
JoinConfigCompatChecker |
The configuration keys that are required for this checker
|
JoinConfigCompatChecker$ |
Checks that all requiredKeys are available in toCheck Config.
|
JoinSeedNodeProcess |
INTERNAL API.
|
Member |
Java API
|
Member$ |
INTERNAL API
Create a new member with status Joining.
|
MembershipState |
|
MembershipState$ |
INTERNAL API
|
MemberStatus |
Defines the current status of a cluster member node
|
MemberStatus.Down$ |
|
MemberStatus.Exiting$ |
|
MemberStatus.Joining$ |
|
MemberStatus.Leaving$ |
|
MemberStatus.Removed$ |
|
MemberStatus.Up$ |
|
MemberStatus.WeaklyUp$ |
|
MemberStatus$ |
Java API: retrieve the “joining” status singleton
|
NoDowning |
Default downing provider used when no provider is configured and 'auto-down-unreachable-after'
is not enabled.
|
OnMemberStatusChangedListener |
INTERNAL API
|
Reachability |
|
Reachability.Reachable$ |
|
Reachability.Record |
|
Reachability.Record$ |
|
Reachability.Terminated$ |
|
Reachability.Unreachable$ |
|
Reachability$ |
INTERNAL API
|
UniqueAddress |
|
UniqueAddress$ |
INTERNAL API
|
Valid |
Java API: get the singleton instance
|
Valid$ |
Java API: get the singleton instance
|
VectorClock |
|
VectorClock.After$ |
|
VectorClock.Before$ |
|
VectorClock.Concurrent$ |
|
VectorClock.Node$ |
|
VectorClock.Same$ |
|
VectorClock.Timestamp$ |
|
VectorClock$ |
Hash representation of a versioned node name.
|
VectorClockStats |
INTERNAL API
|
VectorClockStats$ |
|