akka.cluster
Class ClusterEvent

java.lang.Object
  extended by akka.cluster.ClusterEvent

public class ClusterEvent
extends java.lang.Object

Domain events published to the event bus. Subscribe with:


   Cluster(system).subscribe(actorRef, classOf[ClusterDomainEvent])
 


Nested Class Summary
static interface ClusterEvent.ClusterDomainEvent
          Marker interface for cluster domain events.
static class ClusterEvent.ClusterMetricsChanged
          Current snapshot of cluster node metrics.
static class ClusterEvent.ClusterMetricsChanged$
           
static class ClusterEvent.ClusterShuttingDown$
          This event is published when the cluster node is shutting down, before the final ClusterEvent.MemberRemoved events are published.
static class ClusterEvent.CurrentClusterState
          Current snapshot state of the cluster.
static class ClusterEvent.CurrentClusterState$
           
static class ClusterEvent.CurrentInternalStats
          INTERNAL API
static class ClusterEvent.CurrentInternalStats$
           
static class 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.
static class ClusterEvent.InitialStateAsSnapshot$
          When using this subscription mode a snapshot of ClusterEvent.CurrentClusterState will be sent to the subscriber as the first message.
static class ClusterEvent.LeaderChanged
          Leader of the cluster members changed.
static class ClusterEvent.LeaderChanged$
           
static interface ClusterEvent.MemberEvent
          Marker interface for membership events.
static class ClusterEvent.MemberExited
          Member status changed to MemberStatus.Exiting and will be removed when all members have seen the Exiting status.
static class ClusterEvent.MemberExited$
           
static class ClusterEvent.MemberRemoved
          Member completely removed from the cluster.
static class ClusterEvent.MemberRemoved$
           
static class ClusterEvent.MemberUp
          Member status changed to Up.
static class ClusterEvent.MemberUp$
           
static class ClusterEvent.ReachabilityChanged
          INTERNAL API
static class ClusterEvent.ReachabilityChanged$
           
static interface ClusterEvent.ReachabilityEvent
          Marker interface to facilitate subscription of both ClusterEvent.UnreachableMember and ClusterEvent.ReachableMember.
static class ClusterEvent.ReachableMember
          A member is considered as reachable by the failure detector after having been unreachable.
static class ClusterEvent.ReachableMember$
           
static class ClusterEvent.RoleLeaderChanged
          First member (leader) of the members within a role set changed.
static class ClusterEvent.RoleLeaderChanged$
           
static class ClusterEvent.SeenChanged
          INTERNAL API The nodes that have seen current version of the Gossip.
static class ClusterEvent.SeenChanged$
           
static class ClusterEvent.SubscriptionInitialStateMode
           
static class ClusterEvent.UnreachableMember
          A member is considered as unreachable by the failure detector.
static class ClusterEvent.UnreachableMember$
           
 
Constructor Summary
ClusterEvent()
           
 
Method Summary
static scala.collection.immutable.Seq<ClusterEvent.LeaderChanged> diffLeader(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress)
          INTERNAL API
static scala.collection.immutable.Seq<ClusterEvent.MemberEvent> diffMemberEvents(Gossip oldGossip, Gossip newGossip)
          INTERNAL API.
static scala.collection.immutable.Seq<ClusterEvent.ReachabilityChanged> diffReachability(Gossip oldGossip, Gossip newGossip)
          INTERNAL API
static scala.collection.immutable.Seq<ClusterEvent.ReachableMember> diffReachable(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress)
          INTERNAL API
static scala.collection.immutable.Set<ClusterEvent.RoleLeaderChanged> diffRolesLeader(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress)
          INTERNAL API
static scala.collection.immutable.Seq<ClusterEvent.SeenChanged> diffSeen(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress)
          INTERNAL API
static scala.collection.immutable.Seq<ClusterEvent.UnreachableMember> diffUnreachable(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress)
          INTERNAL API
static ClusterEvent.ClusterShuttingDown$ getClusterShuttingDownInstance()
          Java API: get the singleton instance of ClusterShuttingDown event
static ClusterEvent.InitialStateAsEvents$ initialStateAsEvents()
          Java API
static ClusterEvent.InitialStateAsSnapshot$ initialStateAsSnapshot()
          Java API
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ClusterEvent

public ClusterEvent()
Method Detail

initialStateAsSnapshot

public static ClusterEvent.InitialStateAsSnapshot$ initialStateAsSnapshot()
Java API

Returns:
(undocumented)

initialStateAsEvents

public static ClusterEvent.InitialStateAsEvents$ initialStateAsEvents()
Java API

Returns:
(undocumented)

getClusterShuttingDownInstance

public static ClusterEvent.ClusterShuttingDown$ getClusterShuttingDownInstance()
Java API: get the singleton instance of ClusterShuttingDown event

Returns:
(undocumented)

diffUnreachable

public static scala.collection.immutable.Seq<ClusterEvent.UnreachableMember> diffUnreachable(Gossip oldGossip,
                                                                                             Gossip newGossip,
                                                                                             UniqueAddress selfUniqueAddress)
INTERNAL API

Parameters:
oldGossip - (undocumented)
newGossip - (undocumented)
selfUniqueAddress - (undocumented)
Returns:
(undocumented)

diffReachable

public static scala.collection.immutable.Seq<ClusterEvent.ReachableMember> diffReachable(Gossip oldGossip,
                                                                                         Gossip newGossip,
                                                                                         UniqueAddress selfUniqueAddress)
INTERNAL API

Parameters:
oldGossip - (undocumented)
newGossip - (undocumented)
selfUniqueAddress - (undocumented)
Returns:
(undocumented)

diffMemberEvents

public static scala.collection.immutable.Seq<ClusterEvent.MemberEvent> diffMemberEvents(Gossip oldGossip,
                                                                                        Gossip newGossip)
INTERNAL API.

Parameters:
oldGossip - (undocumented)
newGossip - (undocumented)
Returns:
(undocumented)

diffLeader

public static scala.collection.immutable.Seq<ClusterEvent.LeaderChanged> diffLeader(Gossip oldGossip,
                                                                                    Gossip newGossip,
                                                                                    UniqueAddress selfUniqueAddress)
INTERNAL API

Parameters:
oldGossip - (undocumented)
newGossip - (undocumented)
selfUniqueAddress - (undocumented)
Returns:
(undocumented)

diffRolesLeader

public static scala.collection.immutable.Set<ClusterEvent.RoleLeaderChanged> diffRolesLeader(Gossip oldGossip,
                                                                                             Gossip newGossip,
                                                                                             UniqueAddress selfUniqueAddress)
INTERNAL API

Parameters:
oldGossip - (undocumented)
newGossip - (undocumented)
selfUniqueAddress - (undocumented)
Returns:
(undocumented)

diffSeen

public static scala.collection.immutable.Seq<ClusterEvent.SeenChanged> diffSeen(Gossip oldGossip,
                                                                                Gossip newGossip,
                                                                                UniqueAddress selfUniqueAddress)
INTERNAL API

Parameters:
oldGossip - (undocumented)
newGossip - (undocumented)
selfUniqueAddress - (undocumented)
Returns:
(undocumented)

diffReachability

public static scala.collection.immutable.Seq<ClusterEvent.ReachabilityChanged> diffReachability(Gossip oldGossip,
                                                                                                Gossip newGossip)
INTERNAL API

Parameters:
oldGossip - (undocumented)
newGossip - (undocumented)
Returns:
(undocumented)