|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.cluster.ClusterEvent
public class ClusterEvent
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 |
---|
public ClusterEvent()
Method Detail |
---|
public static ClusterEvent.InitialStateAsSnapshot$ initialStateAsSnapshot()
public static ClusterEvent.InitialStateAsEvents$ initialStateAsEvents()
public static ClusterEvent.ClusterShuttingDown$ getClusterShuttingDownInstance()
ClusterShuttingDown
event
public static scala.collection.immutable.Seq<ClusterEvent.UnreachableMember> diffUnreachable(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress)
oldGossip
- (undocumented)newGossip
- (undocumented)selfUniqueAddress
- (undocumented)
public static scala.collection.immutable.Seq<ClusterEvent.ReachableMember> diffReachable(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress)
oldGossip
- (undocumented)newGossip
- (undocumented)selfUniqueAddress
- (undocumented)
public static scala.collection.immutable.Seq<ClusterEvent.MemberEvent> diffMemberEvents(Gossip oldGossip, Gossip newGossip)
oldGossip
- (undocumented)newGossip
- (undocumented)
public static scala.collection.immutable.Seq<ClusterEvent.LeaderChanged> diffLeader(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress)
oldGossip
- (undocumented)newGossip
- (undocumented)selfUniqueAddress
- (undocumented)
public static scala.collection.immutable.Set<ClusterEvent.RoleLeaderChanged> diffRolesLeader(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress)
oldGossip
- (undocumented)newGossip
- (undocumented)selfUniqueAddress
- (undocumented)
public static scala.collection.immutable.Seq<ClusterEvent.SeenChanged> diffSeen(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress)
oldGossip
- (undocumented)newGossip
- (undocumented)selfUniqueAddress
- (undocumented)
public static scala.collection.immutable.Seq<ClusterEvent.ReachabilityChanged> diffReachability(Gossip oldGossip, Gossip newGossip)
oldGossip
- (undocumented)newGossip
- (undocumented)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |