Send command to DOWN the node specified by 'address'.
Send command to DOWN the node specified by 'address'.
When a member is considered by the failure detector to be unreachable the leader is not allowed to perform its duties, such as changing status of new joining members to 'Up'. The status of the unreachable member must be changed to 'Down', which can be done with this method.
Java API: roles that this member has
Returns true if this cluster instance has be shutdown.
Try to join this cluster node with the node specified by 'address'.
Try to join this cluster node with the node specified by 'address'. A 'Join(selfAddress)' command is sent to the node to join.
An actor system can only join a cluster once. Additional attempts will be ignored. When it has successfully joined it must be restarted to be able to join another cluster or to join the same cluster again.
Join the specified seed nodes without defining them in config.
Join the specified seed nodes without defining them in config. Especially useful from tests when Addresses are unknown before startup time.
An actor system can only join a cluster once. Additional attempts will be ignored. When it has successfully joined it must be restarted to be able to join another cluster or to join the same cluster again.
JAVA API: Use akka.japi.Util.immutableSeq to convert a java.lang.Iterable to the type needed for the seedNodes parameter.
Send command to issue state transition to LEAVING for the node specified by 'address'.
Send command to issue state transition to LEAVING for the node specified by 'address'. The member will go through the status changes MemberStatus.Leaving (not published to subscribers) followed by MemberStatus.Exiting and finally MemberStatus.Removed.
Note that this command can be issued to any member in the cluster, not necessarily the one that is leaving. The cluster extension, but not the actor system or JVM, of the leaving member will be shutdown after the leader has changed status of the member to Exiting. Thereafter the member will be removed from the cluster. Normally this is handled automatically, but in case of network failures during this process it might still be necessary to set the node’s status to Down in order to complete the removal.
Publish current (full) state of the cluster to subscribers, that are subscribing to akka.cluster.ClusterEvent.ClusterDomainEvent or akka.cluster.ClusterEvent.CurrentClusterState.
Publish current (full) state of the cluster to subscribers, that are subscribing to akka.cluster.ClusterEvent.ClusterDomainEvent or akka.cluster.ClusterEvent.CurrentClusterState. If you want this to happen periodically you need to schedule a call to this method yourself.
Java API: The supplied callback will be run, once, when current cluster member is Up
.
Java API: The supplied callback will be run, once, when current cluster member is Up
.
Typically used together with configuration option akka.cluster.min-nr-of-members'
to defer some action, such as starting actors, until the cluster has reached
a certain size.
The supplied thunk will be run, once, when current cluster member is Up
.
The supplied thunk will be run, once, when current cluster member is Up
.
Typically used together with configuration option akka.cluster.min-nr-of-members'
to defer some action, such as starting actors, until the cluster has reached
a certain size.
The address of this cluster member.
roles that this member has
Publish current (full) state of the cluster to the specified receiver.
Publish current (full) state of the cluster to the specified receiver. If you want this to happen periodically you need to schedule a call to this method yourself.
Subscribe to cluster domain events.
Subscribe to cluster domain events.
The to
Class can be akka.cluster.ClusterEvent.ClusterDomainEvent
or subclass.
A snapshot of akka.cluster.ClusterEvent.CurrentClusterState will be sent to the subscriber as the first event.
Unsubscribe to a specific type of cluster domain events,
matching previous subscribe
registration.
Unsubscribe to all cluster domain events.
(cluster: StringAdd).self
(cluster: StringFormat).self
(cluster: ArrowAssoc[Cluster]).x
(Since version 2.10.0) Use leftOfArrow
instead
(cluster: Ensuring[Cluster]).x
(Since version 2.10.0) Use resultOfEnsuring
instead
This module is responsible cluster membership information. Changes to the cluster information is retrieved through #subscribe. Commands to operate the cluster is available through methods in this class, such as #join, #down and #leave.
Each cluster Member is identified by its akka.actor.Address, and the cluster address of this actor system is #selfAddress. A member also has a status; initially MemberStatus.Joining followed by MemberStatus.Up.