Cluster |
This module is responsible cluster membership information.
|
Cluster$ |
Cluster Extension Id and factory for creating Cluster extension.
|
ClusterCoreDaemon$ |
INTERNAL API.
|
ClusterEvent |
Domain events published to the event bus.
|
ClusterEvent.ClusterShuttingDown$ |
|
ClusterEvent.CurrentClusterState |
|
ClusterEvent.CurrentClusterState$ |
|
ClusterEvent.CurrentInternalStats$ |
|
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.
|
ClusterEvent.InitialStateAsSnapshot$ |
When using this subscription mode a snapshot of
pekko.cluster.ClusterEvent.CurrentClusterState will be sent to the
subscriber as the first message.
|
ClusterEvent.LeaderChanged |
Leader of the cluster data center of this node changed.
|
ClusterEvent.LeaderChanged$ |
|
ClusterEvent.MemberDowned |
Member status changed to MemberStatus.Down and will be removed
when all members have seen the Down status.
|
ClusterEvent.MemberDowned$ |
|
ClusterEvent.MemberExited |
Member status changed to MemberStatus.Exiting and will be removed
when all members have seen the Exiting status.
|
ClusterEvent.MemberExited$ |
|
ClusterEvent.MemberJoined |
Member status changed to Joining.
|
ClusterEvent.MemberJoined$ |
|
ClusterEvent.MemberLeft |
Member status changed to Leaving.
|
ClusterEvent.MemberLeft$ |
|
ClusterEvent.MemberPreparingForShutdown |
|
ClusterEvent.MemberPreparingForShutdown$ |
|
ClusterEvent.MemberReadyForShutdown |
|
ClusterEvent.MemberReadyForShutdown$ |
|
ClusterEvent.MemberRemoved |
Member completely removed from the cluster.
|
ClusterEvent.MemberRemoved$ |
|
ClusterEvent.MemberTombstonesChanged$ |
|
ClusterEvent.MemberUp |
Member status changed to Up.
|
ClusterEvent.MemberUp$ |
|
ClusterEvent.MemberWeaklyUp |
Member status changed to WeaklyUp.
|
ClusterEvent.MemberWeaklyUp$ |
|
ClusterEvent.ReachabilityChanged$ |
|
ClusterEvent.ReachableDataCenter |
A data center is considered reachable when all members from the data center are reachable
|
ClusterEvent.ReachableDataCenter$ |
|
ClusterEvent.ReachableMember |
A member is considered as reachable by the failure detector
after having been unreachable.
|
ClusterEvent.ReachableMember$ |
|
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.
|
ClusterEvent.RoleLeaderChanged$ |
|
ClusterEvent.SeenChanged$ |
|
ClusterEvent.SubscriptionInitialStateMode |
|
ClusterEvent.UnreachableDataCenter |
A data center is considered as unreachable when any members from the data center are unreachable
|
ClusterEvent.UnreachableDataCenter$ |
|
ClusterEvent.UnreachableMember |
A member is considered as unreachable by the failure detector.
|
ClusterEvent.UnreachableMember$ |
|
ClusterEvent$ |
Domain events published to the event bus.
|
ClusterHeartbeatReceiver$ |
INTERNAL API: Utilities to obtain ClusterHeartbeatReceiver paths
|
ClusterHeartbeatSender$ |
INTERNAL API
|
ClusterHeartbeatSenderState$ |
|
ClusterLogClass |
INTERNAL API
|
ClusterLogClass$ |
INTERNAL API
|
ClusterLogMarker |
This is public with the purpose to document the used markers and properties of log events.
|
ClusterLogMarker.Properties$ |
INTERNAL API
|
ClusterLogMarker$ |
This is public with the purpose to document the used markers and properties of log events.
|
ClusterReadView$ |
INTERNAL API
|
ClusterRemoteWatcher$ |
INTERNAL API
|
ClusterScope |
|
ClusterScope$ |
Cluster aware scope of a pekko.actor.Deploy
|
ClusterSettings |
|
ClusterSettings$ |
|
ClusterUserAction |
INTERNAL API
Cluster commands sent by the USER via
pekko.cluster.Cluster extension
or JMX.
|
ClusterUserAction.Down |
Command to mark node as temporary down.
|
ClusterUserAction.Down$ |
|
ClusterUserAction.JoinTo |
Command to initiate join another node (represented by address ).
|
ClusterUserAction.JoinTo$ |
|
ClusterUserAction.Leave |
Command to leave the cluster.
|
ClusterUserAction.Leave$ |
|
ClusterUserAction.PrepareForShutdown$ |
Command to mark all nodes as shutting down
|
ClusterUserAction$ |
INTERNAL API
Cluster commands sent by the USER via
pekko.cluster.Cluster extension
or JMX.
|
ConfigUtil |
|
ConfigUtil$ |
|
CoordinatedShutdownLeave$ |
INTERNAL API
|
CrossDcHeartbeatingState$ |
INTERNAL API
|
CrossDcHeartbeatSender$ |
INTERNAL API
|
DowningProvider |
API for plugins that will handle downing of cluster nodes.
|
DowningProvider$ |
INTERNAL API
|
Gossip$ |
INTERNAL API
|
GossipEnvelope$ |
|
GossipOverview$ |
|
GossipStats$ |
|
GossipStatus$ |
|
HeartbeatNodeRing$ |
|
InternalClusterAction |
INTERNAL API
|
InternalClusterAction.AddOnMemberRemovedListener |
|
InternalClusterAction.AddOnMemberRemovedListener$ |
|
InternalClusterAction.AddOnMemberUpListener |
Command to pekko.cluster.ClusterDaemon to create a
pekko.cluster.OnMemberStatusChangedListener .
|
InternalClusterAction.AddOnMemberUpListener$ |
|
InternalClusterAction.CompatibleConfig |
|
InternalClusterAction.CompatibleConfig$ |
|
InternalClusterAction.ConfigCheckUnsupportedByJoiningNode$ |
Node with version 2.5.9 or earlier is joining.
|
InternalClusterAction.ExitingCompleted$ |
|
InternalClusterAction.ExitingConfirmed |
|
InternalClusterAction.ExitingConfirmed$ |
|
InternalClusterAction.GetClusterCoreRef$ |
|
InternalClusterAction.GossipSpeedupTick$ |
|
InternalClusterAction.GossipTick$ |
|
InternalClusterAction.IncompatibleConfig$ |
|
InternalClusterAction.InitJoin |
see JoinSeedNode
|
InternalClusterAction.InitJoin$ |
|
InternalClusterAction.InitJoinAck |
see JoinSeedNode
|
InternalClusterAction.InitJoinAck$ |
|
InternalClusterAction.InitJoinNack |
see JoinSeedNode
|
InternalClusterAction.InitJoinNack$ |
|
InternalClusterAction.Join |
Command to join the cluster.
|
InternalClusterAction.Join$ |
|
InternalClusterAction.JoinSeedNode$ |
Start message of the process to join one of the seed nodes.
|
InternalClusterAction.JoinSeedNodes |
Command to initiate the process to join the specified
seed nodes.
|
InternalClusterAction.JoinSeedNodes$ |
|
InternalClusterAction.LeaderActionsTick$ |
|
InternalClusterAction.PublishChanges |
|
InternalClusterAction.PublishChanges$ |
|
InternalClusterAction.PublishEvent |
|
InternalClusterAction.PublishEvent$ |
|
InternalClusterAction.PublishStatsTick$ |
|
InternalClusterAction.ReapUnreachableTick$ |
|
InternalClusterAction.SendCurrentClusterState |
param: receiver pekko.cluster.ClusterEvent.CurrentClusterState will be sent to the receiver
|
InternalClusterAction.SendCurrentClusterState$ |
|
InternalClusterAction.SendGossipTo |
|
InternalClusterAction.SendGossipTo$ |
|
InternalClusterAction.Subscribe |
|
InternalClusterAction.Subscribe$ |
|
InternalClusterAction.UncheckedConfig$ |
|
InternalClusterAction.Unsubscribe |
|
InternalClusterAction.Unsubscribe$ |
|
InternalClusterAction.Welcome |
Reply to Join
|
InternalClusterAction.Welcome$ |
|
InternalClusterAction$ |
INTERNAL API
|
Invalid |
|
Invalid$ |
|
JoinConfigCompatCheckCluster |
INTERNAL API
|
JoinConfigCompatCheckCluster$ |
INTERNAL API
|
JoinConfigCompatChecker |
|
JoinConfigCompatChecker$ |
|
Member |
Represents the address, current status, and roles of a cluster member node.
|
Member$ |
Module with factory and ordering methods for Member instances.
|
MembershipState$ |
INTERNAL API
|
MemberStatus |
Defines the current status of a cluster member node
|
MemberStatus.Down$ |
|
MemberStatus.Exiting$ |
|
MemberStatus.Joining$ |
|
MemberStatus.Leaving$ |
|
MemberStatus.PreparingForShutdown$ |
|
MemberStatus.ReadyForShutdown$ |
|
MemberStatus.Removed$ |
|
MemberStatus.Up$ |
|
MemberStatus.WeaklyUp$ |
|
MemberStatus$ |
|
NoDowning |
Default downing provider used when no provider is configured.
|
Reachability$ |
INTERNAL API
|
UniqueAddress |
Member identifier consisting of address and random uid .
|
UniqueAddress$ |
|
Valid |
|
Valid$ |
|
VectorClock |
|
VectorClock.After$ |
|
VectorClock.Before$ |
|
VectorClock.Concurrent$ |
|
VectorClock.Node$ |
|
VectorClock.Same$ |
|
VectorClock.Timestamp$ |
|
VectorClock$ |
VectorClock module with helper classes and methods.
|
VectorClockStats$ |
|