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.
-
-
Field Summary
Fields Modifier and Type Field Description static ClusterEvent$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description ClusterEvent$()
-
Method Summary
-
-
-
Field Detail
-
MODULE$
public static final ClusterEvent$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
initialStateAsSnapshot
public ClusterEvent.InitialStateAsSnapshot$ initialStateAsSnapshot()
-
initialStateAsEvents
public ClusterEvent.InitialStateAsEvents$ initialStateAsEvents()
Java API- Returns:
- (undocumented)
-
getClusterShuttingDownInstance
public ClusterEvent.ClusterShuttingDown$ getClusterShuttingDownInstance()
-
diffUnreachable
public scala.collection.immutable.Seq<ClusterEvent.UnreachableMember> diffUnreachable(MembershipState oldState, MembershipState newState)
-
diffReachable
public scala.collection.immutable.Seq<ClusterEvent.ReachableMember> diffReachable(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
isReachable
public 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 scala.collection.immutable.Seq<ClusterEvent.UnreachableDataCenter> diffUnreachableDataCenter(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
diffReachableDataCenter
public scala.collection.immutable.Seq<ClusterEvent.ReachableDataCenter> diffReachableDataCenter(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
diffMemberEvents
public scala.collection.immutable.Seq<ClusterEvent.MemberEvent> diffMemberEvents(MembershipState oldState, MembershipState newState)
INTERNAL API.- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
diffLeader
public scala.collection.immutable.Seq<ClusterEvent.LeaderChanged> diffLeader(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
diffRolesLeader
public scala.collection.immutable.Set<ClusterEvent.RoleLeaderChanged> diffRolesLeader(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
diffSeen
public scala.collection.immutable.Seq<ClusterEvent.SeenChanged> diffSeen(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
diffReachability
public scala.collection.immutable.Seq<ClusterEvent.ReachabilityChanged> diffReachability(MembershipState oldState, MembershipState newState)
INTERNAL API- Parameters:
oldState
- (undocumented)newState
- (undocumented)- Returns:
- (undocumented)
-
-