Package akka.cluster

Interface Summary
ClusterCoreDaemon.ReceiveGossipType The types of gossip actions that receive gossip has performed.
ClusterEvent.ClusterDomainEvent Marker interface for cluster domain events.
ClusterEvent.MemberEvent Marker interface for membership events.
ClusterEvent.ReachabilityEvent Marker interface to facilitate subscription of both ClusterEvent.UnreachableMember and ClusterEvent.ReachableMember.
ClusterMessage Base trait for all cluster messages.
ClusterNodeMBean Interface for the cluster JMX MBean.
InternalClusterAction.PublishMessage  
InternalClusterAction.SubscriptionMessage  
InternalClusterAction.Tick Marker interface for periodic tick messages
MetricNumericConverter INTERNAL API
MetricsCollector Implementations of cluster system metrics extends this trait.
Reachability.ReachabilityStatus  
VectorClock.Ordering  
 

Class Summary
AutoDown INTERNAL API
AutoDown.UnreachableTimeout  
AutoDown.UnreachableTimeout$  
AutoDown$ INTERNAL API
AutoDownBase INTERNAL API
Cluster This module is responsible cluster membership information.
Cluster$ Cluster Extension Id and factory for creating Cluster extension.
ClusterActorRefProvider INTERNAL API
ClusterCoreDaemon INTERNAL API.
ClusterCoreSupervisor INTERNAL API.
ClusterDaemon INTERNAL API.
ClusterDeployer INTERNAL API
ClusterDomainEventPublisher INTERNAL API.
ClusterEvent Domain events published to the event bus.
ClusterEvent.ClusterMetricsChanged Current snapshot of cluster node metrics.
ClusterEvent.ClusterMetricsChanged$  
ClusterEvent.ClusterShuttingDown$ This event is published when the cluster node is shutting down, before the final ClusterEvent.MemberRemoved events are published.
ClusterEvent.CurrentClusterState Current snapshot state of the cluster.
ClusterEvent.CurrentClusterState$  
ClusterEvent.CurrentInternalStats INTERNAL API
ClusterEvent.CurrentInternalStats$  
ClusterEvent.InitialStateAsEvents$ When using this subscription mode the events corresponding to the current state will be sent to the subscriber to mimic what you would have seen if you were listening to the events when they occurred in the past.
ClusterEvent.InitialStateAsSnapshot$ When using this subscription mode a snapshot of ClusterEvent.CurrentClusterState will be sent to the subscriber as the first message.
ClusterEvent.LeaderChanged Leader of the cluster members changed.
ClusterEvent.LeaderChanged$  
ClusterEvent.MemberExited Member status changed to MemberStatus.Exiting and will be removed when all members have seen the Exiting status.
ClusterEvent.MemberExited$  
ClusterEvent.MemberRemoved Member completely removed from the cluster.
ClusterEvent.MemberRemoved$  
ClusterEvent.MemberUp Member status changed to Up.
ClusterEvent.MemberUp$  
ClusterEvent.ReachabilityChanged INTERNAL API
ClusterEvent.ReachabilityChanged$  
ClusterEvent.ReachableMember A member is considered as reachable by the failure detector after having been unreachable.
ClusterEvent.ReachableMember$  
ClusterEvent.RoleLeaderChanged First member (leader) of the members within a role set changed.
ClusterEvent.RoleLeaderChanged$  
ClusterEvent.SeenChanged INTERNAL API The nodes that have seen current version of the Gossip.
ClusterEvent.SeenChanged$  
ClusterEvent.SubscriptionInitialStateMode  
ClusterEvent.UnreachableMember A member is considered as unreachable by the failure detector.
ClusterEvent.UnreachableMember$  
ClusterEvent$ Domain events published to the event bus.
ClusterHeartbeatReceiver INTERNAL API.
ClusterHeartbeatSender  
ClusterHeartbeatSender.ExpectedFirstHeartbeat  
ClusterHeartbeatSender.ExpectedFirstHeartbeat$  
ClusterHeartbeatSender.Heartbeat Sent at regular intervals for failure detection.
ClusterHeartbeatSender.Heartbeat$  
ClusterHeartbeatSender.HeartbeatRsp Sent as reply to ClusterHeartbeatSender.Heartbeat messages.
ClusterHeartbeatSender.HeartbeatRsp$  
ClusterHeartbeatSender.HeartbeatTick$  
ClusterHeartbeatSender$ INTERNAL API
ClusterHeartbeatSenderState INTERNAL API State of ClusterHeartbeatSender.
ClusterHeartbeatSenderState$  
ClusterJmx INTERNAL API
ClusterMetricsCollector INTERNAL API.
ClusterReadView INTERNAL API
ClusterRemoteWatcher INTERNAL API
ClusterRemoteWatcher$ INTERNAL API
ClusterScope  
ClusterScope$ Cluster aware scope of a Deploy
ClusterSettings  
ClusterUserAction INTERNAL API Cluster commands sent by the USER via Cluster extension or JMX.
ClusterUserAction.Down Command to mark node as temporary down.
ClusterUserAction.Down$  
ClusterUserAction.JoinTo Command to initiate join another node (represented by address).
ClusterUserAction.JoinTo$  
ClusterUserAction.Leave Command to leave the cluster.
ClusterUserAction.Leave$  
ClusterUserAction$ INTERNAL API Cluster commands sent by the USER via Cluster extension or JMX.
EWMA  
EWMA$  
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$  
HeartbeatNodeRing INTERNAL API
HeartbeatNodeRing$  
InternalClusterAction INTERNAL API
InternalClusterAction.AddOnMemberUpListener Comand to ClusterDaemon to create a OnMemberUpListener.
InternalClusterAction.AddOnMemberUpListener$  
InternalClusterAction.GetClusterCoreRef$  
InternalClusterAction.GossipSpeedupTick$  
InternalClusterAction.GossipTick$  
InternalClusterAction.InitJoin$  
InternalClusterAction.InitJoinAck  
InternalClusterAction.InitJoinAck$  
InternalClusterAction.InitJoinNack  
InternalClusterAction.InitJoinNack$  
InternalClusterAction.Join Command to join the cluster.
InternalClusterAction.Join$  
InternalClusterAction.JoinSeedNode$ Start message of the process to join one of the seed nodes.
InternalClusterAction.JoinSeedNodes Command to initiate the process to join the specified seed nodes.
InternalClusterAction.JoinSeedNodes$  
InternalClusterAction.LeaderActionsTick$  
InternalClusterAction.MetricsTick$  
InternalClusterAction.PublishChanges  
InternalClusterAction.PublishChanges$  
InternalClusterAction.PublishCurrentClusterState param: receiver if receiver is defined the event will only be sent to that actor, otherwise it will be sent to all subscribers via the eventStream.
InternalClusterAction.PublishCurrentClusterState$  
InternalClusterAction.PublisherCreated  
InternalClusterAction.PublisherCreated$  
InternalClusterAction.PublishEvent  
InternalClusterAction.PublishEvent$  
InternalClusterAction.PublishStatsTick$  
InternalClusterAction.ReapUnreachableTick$  
InternalClusterAction.SendGossipTo  
InternalClusterAction.SendGossipTo$  
InternalClusterAction.Subscribe  
InternalClusterAction.Subscribe$  
InternalClusterAction.Unsubscribe  
InternalClusterAction.Unsubscribe$  
InternalClusterAction.Welcome Reply to Join param: from the sender node in the cluster, i.e.
InternalClusterAction.Welcome$  
InternalClusterAction$ INTERNAL API
JmxMetricsCollector Loads JVM and system metrics through JMX monitoring beans.
JoinSeedNodeProcess INTERNAL API.
Member Represents the address, current status, and roles of a cluster member node.
Member$ Module with factory and ordering methods for Member instances.
MemberStatus Defines the current status of a cluster member node
MemberStatus.Down$  
MemberStatus.Exiting$  
MemberStatus.Joining$  
MemberStatus.Leaving$  
MemberStatus.Removed$  
MemberStatus.Up$  
MemberStatus$  
Metric Metrics key/value.
Metric$ Factory for creating valid Metric instances.
MetricsCollector$ INTERNAL API Factory to create configured MetricsCollector.
MetricsGossip  
MetricsGossip$ INTERNAL API
MetricsGossipEnvelope INTERNAL API Envelope adding a sender address to the gossip.
MetricsGossipEnvelope$  
NodeMetrics The snapshot of current sampled health metrics for any monitored process.
NodeMetrics$  
OnMemberUpListener INTERNAL API
Reachability INTERNAL API
Reachability.Reachable$  
Reachability.Record  
Reachability.Record$  
Reachability.Terminated$  
Reachability.Unreachable$  
Reachability$ INTERNAL API
SigarMetricsCollector Loads metrics through Hyperic SIGAR and JMX monitoring beans.
StandardMetrics Definitions of the built-in standard metrics.
StandardMetrics.Cpu  
StandardMetrics.Cpu$  
StandardMetrics.HeapMemory  
StandardMetrics.HeapMemory$  
StandardMetrics$ Definitions of the built-in standard metrics.
UniqueAddress Member identifier consisting of address and random uid.
UniqueAddress$  
VectorClock  
VectorClock.After$  
VectorClock.Before$  
VectorClock.Concurrent$  
VectorClock.Node$  
VectorClock.Same$  
VectorClock.Timestamp$  
VectorClock$ VectorClock module with helper classes and methods.
VectorClockStats INTERNAL API
VectorClockStats$