Package org.apache.pekko.cluster
Class ClusterEvent
java.lang.Object
org.apache.pekko.cluster.ClusterEvent
Domain events published to the event bus.
Subscribe with:
Cluster(system).subscribe(actorRef, classOf[ClusterDomainEvent])
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic interfaceMarker interface for cluster domain events.static classThis event is published when the cluster node is shutting down, before the finalClusterEvent.MemberRemovedevents are published.static final classCurrent snapshot state of the cluster.static classstatic classstatic interfaceMarker interface to facilitate subscription of bothClusterEvent.UnreachableDataCenterandClusterEvent.ReachableDataCenter.static classWhen 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 classWhen using this subscription mode a snapshot ofpekko.cluster.ClusterEvent.CurrentClusterStatewill be sent to the subscriber as the first message.static final classLeader of the cluster data center of this node changed.static classstatic final classMember status changed toMemberStatus.Downand will be removed when all members have seen theDownstatus.static classstatic interfaceMarker interface for membership events.static final classMember status changed toMemberStatus.Exitingand will be removed when all members have seen theExitingstatus.static classstatic final classMember status changed to Joining.static classstatic final classMember status changed to Leaving.static classstatic final classstatic classstatic final classstatic classstatic final classMember completely removed from the cluster.static classstatic classstatic final classMember status changed to Up.static classstatic final classMember status changed to WeaklyUp.static classstatic classstatic interfaceMarker interface to facilitate subscription of bothClusterEvent.UnreachableMemberandClusterEvent.ReachableMember.static final classA data center is considered reachable when all members from the data center are reachablestatic classstatic final classA member is considered as reachable by the failure detector after having been unreachable.static classstatic final classFirst member (leader) of the members within a role set (in the same data center as this node, if data centers are used) changed.static classstatic classstatic classstatic final classA data center is considered as unreachable when any members from the data center are unreachablestatic classstatic final classA member is considered as unreachable by the failure detector.static class -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionJava API: get the singleton instance ofClusterShuttingDowneventJava APIJava API
-
Constructor Details
-
ClusterEvent
public ClusterEvent()
-
-
Method Details
-
initialStateAsSnapshot
Java API -
initialStateAsEvents
Java API -
getClusterShuttingDownInstance
Java API: get the singleton instance ofClusterShuttingDownevent
-