Class MultiNodeClusterSpec

Inheritance
Object
TestKitBase
MultiNodeSpec
MultiNodeClusterSpec
Implements
Inherited Members
Namespace: Akka.Cluster.TestKit
Assembly: Akka.Cluster.TestKit.dll
Syntax
public abstract class MultiNodeClusterSpec : MultiNodeSpec, IActorRefFactory, IMultiNodeSpecCallbacks, IDisposable

Constructors

| Improve this Doc View Source

MultiNodeClusterSpec(MultiNodeConfig, Type)

Declaration
protected MultiNodeClusterSpec(MultiNodeConfig config, Type type)
Parameters
Type Name Description
MultiNodeConfig config
Type type
| Improve this Doc View Source

MultiNodeClusterSpec(RoleName, ActorSystem, ImmutableList<RoleName>, Func<RoleName, ImmutableList<String>>)

Declaration
protected MultiNodeClusterSpec(RoleName myself, ActorSystem system, ImmutableList<RoleName> roles, Func<RoleName, ImmutableList<string>> deployments)
Parameters
Type Name Description
RoleName myself
ActorSystem system
System.Collections.Immutable.ImmutableList<RoleName> roles
Func<RoleName, System.Collections.Immutable.ImmutableList<String>> deployments
| Improve this Doc View Source

MultiNodeClusterSpec(RoleName, ActorSystemSetup, ImmutableList<RoleName>, Func<RoleName, ImmutableList<String>>)

Declaration
protected MultiNodeClusterSpec(RoleName myself, ActorSystemSetup setup, ImmutableList<RoleName> roles, Func<RoleName, ImmutableList<string>> deployments)
Parameters
Type Name Description
RoleName myself
ActorSystemSetup setup
System.Collections.Immutable.ImmutableList<RoleName> roles
Func<RoleName, System.Collections.Immutable.ImmutableList<String>> deployments

Properties

| Improve this Doc View Source

Cluster

Get the cluster node to use.

Declaration
public Cluster Cluster { get; }
Property Value
Type Description
Cluster
| Improve this Doc View Source

InitialParticipantsValueFactory

Declaration
protected override int InitialParticipantsValueFactory { get; }
Property Value
Type Description
Int32
Overrides

Methods

| Improve this Doc View Source

AfterTermination()

Declaration
protected override void AfterTermination()
Overrides
| Improve this Doc View Source

AssertLeader(RoleName[])

Note that this can only be used for a cluster with all members in Up status, i.e. use awaitMembersUp before using this method. The reason for that is that the cluster leader is preferably a member with status Up or Leaving and that information can't be determined from the RoleName.

Declaration
public void AssertLeader(params RoleName[] nodesInCluster)
Parameters
Type Name Description
RoleName[] nodesInCluster
| Improve this Doc View Source

AssertLeaderIn(ImmutableList<RoleName>)

Assert that the cluster has elected the correct leader out of all nodes in the cluster. First member in the cluster ring is expected leader.

Note that this can only be used for a cluster with all members in Up status, i.e. use awaitMembersUp before using this method. The reason for that is that the cluster leader is preferably a member with status Up or Leaving and that information can't be determined from the RoleName.

Declaration
public void AssertLeaderIn(ImmutableList<RoleName> nodesInCluster)
Parameters
Type Name Description
System.Collections.Immutable.ImmutableList<RoleName> nodesInCluster
| Improve this Doc View Source

AssertMembers(IEnumerable<Member>, Address[])

Assert that the member addresses match the expected addresses in the sort order used by the cluster.

Declaration
public void AssertMembers(IEnumerable<Member> gotMembers, params Address[] expectedAddresses)
Parameters
Type Name Description
IEnumerable<Member> gotMembers
Address[] expectedAddresses
| Improve this Doc View Source

AtStartup()

Declaration
protected override void AtStartup()
Overrides
| Improve this Doc View Source

AwaitAllReachable()

Declaration
public void AwaitAllReachable()
| Improve this Doc View Source

AwaitClusterUp(RoleName[])

Initialize the cluster of the specified member nodes (roles) and wait until all joined and Up.

First node will be started first and others will join the first.

Declaration
public void AwaitClusterUp(params RoleName[] roles)
Parameters
Type Name Description
RoleName[] roles
| Improve this Doc View Source

AwaitMembersUp(Int32, ImmutableHashSet<Address>, Nullable<TimeSpan>)

Declaration
public void AwaitMembersUp(int numbersOfMembers, ImmutableHashSet<Address> canNotBePartOfMemberRing = null, TimeSpan? timeout = null)
Parameters
Type Name Description
Int32 numbersOfMembers
System.Collections.Immutable.ImmutableHashSet<Address> canNotBePartOfMemberRing
Nullable<TimeSpan> timeout
| Improve this Doc View Source

AwaitSeenSameState(Address[])

Declaration
public void AwaitSeenSameState(params Address[] addresses)
Parameters
Type Name Description
Address[] addresses
| Improve this Doc View Source

ClusterConfig()

Declaration
public static Config ClusterConfig()
Returns
Type Description
Config
| Improve this Doc View Source

ClusterConfig(Boolean)

Declaration
public static Config ClusterConfig(bool failureDetectorPuppet)
Parameters
Type Name Description
Boolean failureDetectorPuppet
Returns
Type Description
Config
| Improve this Doc View Source

ClusterConfigWithFailureDetectorPuppet()

Declaration
public static Config ClusterConfigWithFailureDetectorPuppet()
Returns
Type Description
Config
| Improve this Doc View Source

FailureDetectorPuppet(Address)

Declaration
public FailureDetectorPuppet FailureDetectorPuppet(Address address)
Parameters
Type Name Description
Address address
Returns
Type Description
FailureDetectorPuppet
| Improve this Doc View Source

GetAddress(RoleName)

Declaration
public Address GetAddress(RoleName role)
Parameters
Type Name Description
RoleName role
Returns
Type Description
Address
| Improve this Doc View Source

IsFailureDetectorPuppet()

Declaration
public bool IsFailureDetectorPuppet()
Returns
Type Description
Boolean
| Improve this Doc View Source

JoinWithin(RoleName, Nullable<TimeSpan>, Nullable<TimeSpan>)

Declaration
public void JoinWithin(RoleName joinNode, TimeSpan? max = null, TimeSpan? interval = null)
Parameters
Type Name Description
RoleName joinNode
Nullable<TimeSpan> max
Nullable<TimeSpan> interval
| Improve this Doc View Source

MarkNodeAsAvailable(Address)

Marks a node as available in the failure detector if FailureDetectorPuppet(Address) is used as failure detector

Declaration
public void MarkNodeAsAvailable(Address address)
Parameters
Type Name Description
Address address
| Improve this Doc View Source

MarkNodeAsUnavailable(Address)

Marks a node as unavailable in the failure detector if FailureDetectorPuppet(Address) is used as failure detector

Declaration
public void MarkNodeAsUnavailable(Address address)
Parameters
Type Name Description
Address address
| Improve this Doc View Source

MuteLog(ActorSystem)

Declaration
public virtual void MuteLog(ActorSystem sys = null)
Parameters
Type Name Description
ActorSystem sys
| Improve this Doc View Source

MuteMarkingAsReachable(ActorSystem)

Declaration
protected void MuteMarkingAsReachable(ActorSystem system = null)
Parameters
Type Name Description
ActorSystem system
| Improve this Doc View Source

MuteMarkingAsUnreachable(ActorSystem)

Declaration
protected void MuteMarkingAsUnreachable(ActorSystem system = null)
Parameters
Type Name Description
ActorSystem system
| Improve this Doc View Source

RoleName(Address)

Declaration
public RoleName RoleName(Address addr)
Parameters
Type Name Description
Address addr
Returns
Type Description
RoleName
| Improve this Doc View Source

RoleOfLeader(ImmutableList<RoleName>)

Leader according to the address ordering of the roles. Note that this can only be used for a cluster with all members in Up status, i.e. use awaitMembersUp before using this method. The reason for that is that the cluster leader is preferably a member with status Up or Leaving and that information can't be determined from the RoleName.

Declaration
public RoleName RoleOfLeader(ImmutableList<RoleName> nodesInCluster)
Parameters
Type Name Description
System.Collections.Immutable.ImmutableList<RoleName> nodesInCluster
Returns
Type Description
RoleName
| Improve this Doc View Source

StartClusterNode()

Use this method for the initial startup of the cluster node

Declaration
public void StartClusterNode()

Implements

Extension Methods