public class ClusterEvent
extends java.lang.Object
Cluster(system).subscribe(actorRef, classOf[ClusterDomainEvent])
Modifier and Type | Class and Description |
---|---|
static interface |
ClusterEvent.ClusterDomainEvent
Marker interface for cluster domain events.
|
static class |
ClusterEvent.ClusterMetricsChanged
Deprecated.
Superseded by akka.cluster.metrics (in akka-cluster-metrics jar). Since 2.4.
|
static class |
ClusterEvent.ClusterMetricsChanged$
Deprecated.
Superseded by akka.cluster.metrics (in akka-cluster-metrics jar). Since 2.4.
|
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.MemberJoined
Member status changed to Joining.
|
static class |
ClusterEvent.MemberJoined$ |
static class |
ClusterEvent.MemberLeft
Member status changed to Leaving.
|
static class |
ClusterEvent.MemberLeft$ |
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.MemberWeaklyUp
Member status changed to WeaklyUp.
|
static class |
ClusterEvent.MemberWeaklyUp$ |
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 and Description |
---|
ClusterEvent() |
Modifier and Type | Method and Description |
---|---|
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
|
public static ClusterEvent.InitialStateAsSnapshot$ initialStateAsSnapshot()
public static ClusterEvent.InitialStateAsEvents$ initialStateAsEvents()
public static ClusterEvent.ClusterShuttingDown$ getClusterShuttingDownInstance()
ClusterShuttingDown
eventpublic 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)