Package akka.cluster
Class ClusterEvent
- java.lang.Object
-
- akka.cluster.ClusterEvent
-
public class ClusterEvent extends java.lang.Object
When using this subscription mode a snapshot ofClusterEvent.CurrentClusterState
will be sent to the subscriber as the first message.
-
-
Nested Class Summary
-
Constructor Summary
Constructors Constructor Description ClusterEvent()
-
Method Summary
-
-
-
Method Detail
-
initialStateAsSnapshot
public static ClusterEvent.InitialStateAsSnapshot$ initialStateAsSnapshot()
-
initialStateAsEvents
public static ClusterEvent.InitialStateAsEvents$ initialStateAsEvents()
Java API- Returns:
- (undocumented)
-
getClusterShuttingDownInstance
public static ClusterEvent.ClusterShuttingDown$ getClusterShuttingDownInstance()
-
diffUnreachable
public static scala.collection.immutable.Seq<ClusterEvent.UnreachableMember> diffUnreachable(MembershipState oldState, MembershipState newState)
-
diffReachable
public static scala.collection.immutable.Seq<ClusterEvent.ReachableMember> diffReachable(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
isReachable
public static boolean isReachable(MembershipState state, scala.collection.immutable.Set<UniqueAddress> oldUnreachableNodes, java.lang.String otherDc)
Internal API- Parameters:
state
- (undocumented)oldUnreachableNodes
- (undocumented)otherDc
- (undocumented)- Returns:
- (undocumented)
-
diffUnreachableDataCenter
public static scala.collection.immutable.Seq<ClusterEvent.UnreachableDataCenter> diffUnreachableDataCenter(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
diffReachableDataCenter
public static scala.collection.immutable.Seq<ClusterEvent.ReachableDataCenter> diffReachableDataCenter(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
diffMemberEvents
public static scala.collection.immutable.Seq<ClusterEvent.MemberEvent> diffMemberEvents(MembershipState oldState, MembershipState newState)
INTERNAL API.- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
diffLeader
public static scala.collection.immutable.Seq<ClusterEvent.LeaderChanged> diffLeader(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
diffRolesLeader
public static scala.collection.immutable.Set<ClusterEvent.RoleLeaderChanged> diffRolesLeader(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
diffSeen
public static scala.collection.immutable.Seq<ClusterEvent.SeenChanged> diffSeen(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
diffReachability
public static scala.collection.immutable.Seq<ClusterEvent.ReachabilityChanged> diffReachability(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
-