| 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$ |
|