Package org.apache.pekko.cluster
package org.apache.pekko.cluster
-
ClassDescriptionThis module is responsible cluster membership information.Cluster Extension Id and factory for creating Cluster extension.INTERNAL API.Domain events published to the event bus.Marker interface for cluster domain events.This event is published when the cluster node is shutting down, before the final
ClusterEvent.MemberRemovedevents are published.Current snapshot state of the cluster.Marker interface to facilitate subscription of bothClusterEvent.UnreachableDataCenterandClusterEvent.ReachableDataCenter.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.When using this subscription mode a snapshot ofpekko.cluster.ClusterEvent.CurrentClusterStatewill be sent to the subscriber as the first message.Leader of the cluster data center of this node changed.Member status changed toMemberStatus.Downand will be removed when all members have seen theDownstatus.Marker interface for membership events.Member status changed toMemberStatus.Exitingand will be removed when all members have seen theExitingstatus.Member status changed to Joining.Member status changed to Leaving.Member completely removed from the cluster.Member status changed to Up.Member status changed to WeaklyUp.Marker interface to facilitate subscription of bothClusterEvent.UnreachableMemberandClusterEvent.ReachableMember.A data center is considered reachable when all members from the data center are reachableA member is considered as reachable by the failure detector after having been unreachable.First member (leader) of the members within a role set (in the same data center as this node, if data centers are used) changed.A data center is considered as unreachable when any members from the data center are unreachableA member is considered as unreachable by the failure detector.Domain events published to the event bus.INTERNAL API: Utilities to obtain ClusterHeartbeatReceiver pathsINTERNAL APIINTERNAL APIINTERNAL APIThis is public with the purpose to document the used markers and properties of log events.INTERNAL APIThis is public with the purpose to document the used markers and properties of log events.Base trait for all cluster messages.Interface for the cluster JMX MBean.INTERNAL APIINTERNAL APICluster aware scope of apekko.actor.DeployINTERNAL API Cluster commands sent by the USER viapekko.cluster.Clusterextension or JMX.Command to mark node as temporary down.Command to initiate join another node (represented byaddress).Command to leave the cluster.Command to mark all nodes as shutting downINTERNAL API Cluster commands sent by the USER viapekko.cluster.Clusterextension or JMX.INTERNAL APIINTERNAL APIINTERNAL APIAPI for plugins that will handle downing of cluster nodes.INTERNAL APIINTERNAL APIINTERNAL APICommand topekko.cluster.ClusterDaemonto create apekko.cluster.OnMemberStatusChangedListener.Node with version 2.5.9 or earlier is joining.see JoinSeedNodesee JoinSeedNodesee JoinSeedNodeCommand to join the cluster.Start message of the process to join one of the seed nodes.Command to initiate the process to join the specified seed nodes.param: receiverpekko.cluster.ClusterEvent.CurrentClusterStatewill be sent to thereceiverMarker interface for periodic tick messagesReply to JoinINTERNAL APIINTERNAL APIINTERNAL APIRepresents the address, current status, and roles of a cluster member node.Module with factory and ordering methods for Member instances.INTERNAL APIDefines the current status of a cluster member nodeDefault downing provider used when no provider is configured.INTERNAL APIMember identifier consisting of address and randomuid.VectorClock module with helper classes and methods.