Package org.apache.pekko.cluster

Class ClusterEvent

java.lang.Object

org.apache.pekko.cluster.ClusterEvent

public class ClusterEvent
extends Object

Domain events published to the event bus. Subscribe with:

   Cluster(system).subscribe(actorRef, classOf[ClusterDomainEvent])
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ClusterEvent.ClusterDomainEvent	Marker interface for cluster domain events.
static class	ClusterEvent.ClusterShuttingDown$	This event is published when the cluster node is shutting down, before the final ClusterEvent.MemberRemoved events are published.
static final class	ClusterEvent.CurrentClusterState	Current snapshot state of the cluster.
static class	ClusterEvent.CurrentClusterState$
static class	ClusterEvent.CurrentInternalStats$
static interface	ClusterEvent.DataCenterReachabilityEvent	Marker interface to facilitate subscription of both ClusterEvent.UnreachableDataCenter and ClusterEvent.ReachableDataCenter.
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 pekko.cluster.ClusterEvent.CurrentClusterState will be sent to the subscriber as the first message.
static final class	ClusterEvent.LeaderChanged	Leader of the cluster data center of this node changed.
static class	ClusterEvent.LeaderChanged$
static final class	ClusterEvent.MemberDowned	Member status changed to MemberStatus.Down and will be removed when all members have seen the Down status.
static class	ClusterEvent.MemberDowned$
static interface	ClusterEvent.MemberEvent	Marker interface for membership events.
static final 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 final class	ClusterEvent.MemberJoined	Member status changed to Joining.
static class	ClusterEvent.MemberJoined$
static final class	ClusterEvent.MemberLeft	Member status changed to Leaving.
static class	ClusterEvent.MemberLeft$
static final class	ClusterEvent.MemberPreparingForShutdown
static class	ClusterEvent.MemberPreparingForShutdown$
static final class	ClusterEvent.MemberReadyForShutdown
static class	ClusterEvent.MemberReadyForShutdown$
static final class	ClusterEvent.MemberRemoved	Member completely removed from the cluster.
static class	ClusterEvent.MemberRemoved$
static class	ClusterEvent.MemberTombstonesChanged$
static final class	ClusterEvent.MemberUp	Member status changed to Up.
static class	ClusterEvent.MemberUp$
static final class	ClusterEvent.MemberWeaklyUp	Member status changed to WeaklyUp.
static class	ClusterEvent.MemberWeaklyUp$
static class	ClusterEvent.ReachabilityChanged$
static interface	ClusterEvent.ReachabilityEvent	Marker interface to facilitate subscription of both ClusterEvent.UnreachableMember and ClusterEvent.ReachableMember.
static final class	ClusterEvent.ReachableDataCenter	A data center is considered reachable when all members from the data center are reachable
static class	ClusterEvent.ReachableDataCenter$
static final class	ClusterEvent.ReachableMember	A member is considered as reachable by the failure detector after having been unreachable.
static class	ClusterEvent.ReachableMember$
static final class	ClusterEvent.RoleLeaderChanged	First member (leader) of the members within a role set (in the same data center as this node, if data centers are used) changed.
static class	ClusterEvent.RoleLeaderChanged$
static class	ClusterEvent.SeenChanged$
static class	ClusterEvent.SubscriptionInitialStateMode
static final class	ClusterEvent.UnreachableDataCenter	A data center is considered as unreachable when any members from the data center are unreachable
static class	ClusterEvent.UnreachableDataCenter$
static final class	ClusterEvent.UnreachableMember	A member is considered as unreachable by the failure detector.
static class	ClusterEvent.UnreachableMember$

Constructor Summary

Constructors

Constructor	Description
ClusterEvent()

Method Summary

Modifier and Type	Method	Description
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 Details

ClusterEvent

public ClusterEvent()

Method Details

initialStateAsSnapshot

public static ClusterEvent.InitialStateAsSnapshot$ initialStateAsSnapshot()

Java API

initialStateAsEvents

public static ClusterEvent.InitialStateAsEvents$ initialStateAsEvents()

Java API

getClusterShuttingDownInstance

public static ClusterEvent.ClusterShuttingDown$ getClusterShuttingDownInstance()

Java API: get the singleton instance of ClusterShuttingDown event