Click or drag to resize
Akka.NETCluster Class
This module is responsible for 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(Address), Down(Address) and Leave(Address). Each cluster Member is identified by its Address, and the cluster address of this actor system is [[#selfAddress]]. A member also has a status; initially Joining followed by Up.
Inheritance Hierarchy
SystemObject
  Akka.ClusterCluster

Namespace:  Akka.Cluster
Assembly:  Akka.Cluster (in Akka.Cluster.dll) Version: 1.1.3.30 (1.1.3.30)
Syntax
public class Cluster : IExtension

The Cluster type exposes the following members.

Constructors
  NameDescription
Public methodCluster
TBD
Top
Properties
  NameDescription
Public propertyDowningProvider
TBD
Public propertyFailureDetector
TBD
Public propertyIsTerminated
Returns true if this cluster instance has be shutdown.
Public propertySelfAddress
The address of this cluster member.
Public propertySelfRoles
roles that this member has
Public propertySelfUniqueAddress
TBD
Public propertySettings
TBD
Public propertyState
Current snapshot state of the cluster.
Public propertySystem
TBD
Top
Methods
  NameDescription
Public methodDown
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.
Public methodEquals
Determines whether the specified object is equal to the current object.
(Inherited from Object.)
Protected methodFinalize
Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.
(Inherited from Object.)
Public methodStatic memberGet
TBD
Public methodGetHashCode
Serves as the default hash function.
(Inherited from Object.)
Public methodGetType
Gets the Type of the current instance.
(Inherited from Object.)
Public methodJoin
Try to join this cluster node specified by address. A Join(Address) 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.
Public methodJoinSeedNodes
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.
Public methodLeave
Send command to issue state transition to LEAVING for the node specified by address. The member will go through the status changes Leaving (not published to subscribers) followed by Exiting and finally 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, 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.
Public methodLeaveAsync
Causes the CURRENT node, i.e. the one calling this function, to leave the cluster. Once the returned Task completes, it means that the member has successfully been removed from the cluster.
Protected methodMemberwiseClone
Creates a shallow copy of the current Object.
(Inherited from Object.)
Public methodRegisterOnMemberRemoved
The supplied callback will be run once when the current cluster member is Removed. Typically used in combination with Leave(Address) and Terminate.
Public methodRegisterOnMemberUp
The supplied callback will be run once when the 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.
Public methodRemotePathOf
Generate the remote actor path by replacing the Address in the RootActor Path for the given ActorRef with the cluster's `SelfAddress`, unless address' host is already defined
Public methodSendCurrentClusterState
Send the current (full) state of the cluster to the specified receiver. If you want this to happen periodically, you can use the Scheduler to schedule a call to this method. You can also call State directly for this information.
Public methodSubscribe(IActorRef, Type)
Subscribe to one or more cluster domain events.
Public methodSubscribe(IActorRef, ClusterEventSubscriptionInitialStateMode, Type)
Subscribe to one or more cluster domain events.
Public methodToString
Returns a string that represents the current object.
(Inherited from Object.)
Public methodUnsubscribe(IActorRef)
Unsubscribe to all cluster domain events.
Public methodUnsubscribe(IActorRef, Type)
Unsubscribe to a specific type of cluster domain event
Top
Extension Methods
  NameDescription
Public Extension MethodAsInstanceOfT
TBD
(Defined by Extensions.)
Public Extension MethodGCounterOverloaded.
Creates a new instance of GCounter, that works within the scope of the current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodGCounter(GCounter)Overloaded.
Creates an instance of GCounter scoped to a current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodLWWDictionaryTKey, TValOverloaded.
Creates a new instance of an LWWDictionary scoped to a current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodLWWDictionaryTKey, TVal(LWWDictionaryTKey, TVal)Overloaded.
Creates an instance of an LWWDictionary scoped to a current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodLWWRegisterTVal
Creates an instance of an LWWRegister scoped to a current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodMatchOverloaded.
Matches the specified target.
(Defined by PatternMatch.)
Public Extension MethodMatchTOverloaded.
Matches the specified target and return a result of target processing.
(Defined by PatternMatch.)
Public Extension MethodORDictionaryTKey, TValOverloaded.
Creates a new instance of an ORDictionary scoped to a current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodORDictionaryTKey, TVal(ORDictionaryTKey, TVal)Overloaded.
Creates an instance of an ORDictionary scoped to a current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodORMultiDictionaryTKey, TValOverloaded.
Creates a new instance of an ORMultiDictionary scoped to a current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodORMultiDictionaryTKey, TVal(ORMultiDictionaryTKey, TVal)Overloaded.
Creates an instance of an ORMultiDictionary scoped to a current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodORSetTOverloaded. (Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodORSetT(ORSetT)Overloaded.
Creates an instance of an ORSet scoped to a current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodPNCounterOverloaded.
Creates a new instance of PNCounter, that works within the scope of the current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodPNCounter(PNCounter)Overloaded.
Creates an instance of PNCounter scoped to a current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodPNCounterDictionaryTKeyOverloaded.
Creates a new instance of an PNCounterDictionary scoped to a current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Public Extension MethodPNCounterDictionaryTKey(PNCounterDictionaryTKey)Overloaded.
Creates an instance of an PNCounterDictionary scoped to a current cluster.
(Defined by ClusterReplicatedDataExtensions.)
Top
See Also