Search Results for

    Show / Hide Table of Contents

    Class MultiNodeClusterSpec

    Inheritance
    object
    TestKitBase
    MultiNodeSpec
    MultiNodeClusterSpec
    Implements
    IActorRefFactory
    IMultiNodeSpecCallbacks
    IDisposable
    Inherited Members
    MultiNodeSpec.MaxNodes
    MultiNodeSpec.SelfName
    MultiNodeSpec.SelfPort
    MultiNodeSpec.ServerName
    MultiNodeSpec.ServerPort
    MultiNodeSpec.SelfIndex
    MultiNodeSpec.NodeConfig
    MultiNodeSpec.BaseConfig
    MultiNodeSpec.Myself
    MultiNodeSpec.MultiNodeSpecBeforeAll()
    MultiNodeSpec.MultiNodeSpecAfterAll()
    MultiNodeSpec.ShutdownTimeout
    MultiNodeSpec.VerifySystemShutdown
    MultiNodeSpec.Roles
    MultiNodeSpec.InitialParticipants
    MultiNodeSpec.TestConductor
    MultiNodeSpec.RunOn(Action, params RoleName[])
    MultiNodeSpec.RunOnAsync(Func<Task>, params RoleName[])
    MultiNodeSpec.IsNode(params RoleName[])
    MultiNodeSpec.EnterBarrier(params string[])
    MultiNodeSpec.Node(RoleName)
    MultiNodeSpec.MuteDeadLetters(ActorSystem, params Type[])
    MultiNodeSpec.AttachConductor(TestConductor)
    MultiNodeSpec.InjectDeployments(ActorSystem, RoleName)
    MultiNodeSpec.StartNewSystem()
    MultiNodeSpec.Dispose()
    MultiNodeSpec.Dispose(bool)
    TestKitBase.InitializeTest(ActorSystem, ActorSystemSetup, string, string)
    TestKitBase.InitializeTest(ActorSystem, Config, string, string)
    TestKitBase.Sys
    TestKitBase.TestKitSettings
    TestKitBase.LastSender
    TestKitBase.DefaultConfig
    TestKitBase.FullDebugConfig
    TestKitBase.Now
    TestKitBase.Log
    TestKitBase.LastMessage
    TestKitBase.TestActor
    TestKitBase.EventFilter
    TestKitBase.CreateEventFilter(ActorSystem)
    TestKitBase.HasMessages
    TestKitBase.IgnoreMessages(Func<object, bool>)
    TestKitBase.IgnoreMessages<TMsg>(Func<TMsg, bool>)
    TestKitBase.IgnoreMessages<TMsg>()
    TestKitBase.IgnoreNoMessages()
    TestKitBase.Watch(IActorRef)
    TestKitBase.WatchAsync(IActorRef)
    TestKitBase.Unwatch(IActorRef)
    TestKitBase.UnwatchAsync(IActorRef)
    TestKitBase.SetAutoPilot(AutoPilot)
    TestKitBase.RemainingOrDefault
    TestKitBase.Remaining
    TestKitBase.RemainingOr(TimeSpan)
    TestKitBase.RemainingOrDilated(TimeSpan?)
    TestKitBase.Dilated(TimeSpan)
    TestKitBase.GetTimeoutOrDefault(TimeSpan?)
    TestKitBase.Shutdown(TimeSpan?, bool)
    TestKitBase.Shutdown(ActorSystem, TimeSpan?, bool)
    TestKitBase.ChildActorOf(Props, string, SupervisorStrategy, CancellationToken)
    TestKitBase.ChildActorOfAsync(Props, string, SupervisorStrategy, CancellationToken)
    TestKitBase.ChildActorOf(Props, SupervisorStrategy, CancellationToken)
    TestKitBase.ChildActorOfAsync(Props, SupervisorStrategy, CancellationToken)
    TestKitBase.ChildActorOf(Props, string, CancellationToken)
    TestKitBase.ChildActorOfAsync(Props, string, CancellationToken)
    TestKitBase.ChildActorOf(Props, CancellationToken)
    TestKitBase.ChildActorOfAsync(Props, CancellationToken)
    TestKitBase.CreateTestActor(string)
    TestKitBase.CreateTestProbe(string)
    TestKitBase.CreateTestProbe(ActorSystem, string)
    TestKitBase.CreateTestLatch(int)
    TestKitBase.CreateTestBarrier(int)
    TestKitBase.ActorOf(Props)
    TestKitBase.ActorOf(Props, string)
    TestKitBase.ActorOf<TActor>()
    TestKitBase.ActorOf<TActor>(string)
    TestKitBase.ActorOf<TActor>(Expression<Func<TActor>>)
    TestKitBase.ActorOf<TActor>(Expression<Func<TActor>>, string)
    TestKitBase.ActorOf(Action<IActorDsl, IActorContext>, string)
    TestKitBase.ActorOf(Action<IActorDsl>, string)
    TestKitBase.ActorSelection(ActorPath)
    TestKitBase.ActorSelection(string)
    TestKitBase.ActorSelection(IActorRef, string)
    TestKitBase.ActorOfAsTestActorRef<TActor>(Props, IActorRef, string)
    TestKitBase.ActorOfAsTestActorRef<TActor>(Props, string)
    TestKitBase.ActorOfAsTestActorRef<TActor>(Expression<Func<TActor>>, IActorRef, string)
    TestKitBase.ActorOfAsTestActorRef<TActor>(Expression<Func<TActor>>, string)
    TestKitBase.ActorOfAsTestActorRef<TActor>(IActorRef, string)
    TestKitBase.ActorOfAsTestActorRef<TActor>(string)
    TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Props, IActorRef, string, bool)
    TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Props, string, bool)
    TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(IActorRef, string, bool)
    TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(string, bool)
    TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Expression<Func<TFsmActor>>, IActorRef, string, bool)
    TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Expression<Func<TFsmActor>>, string, bool)
    TestKitBase.AwaitAssert(Action, TimeSpan?, TimeSpan?, CancellationToken)
    TestKitBase.AwaitAssertAsync(Action, TimeSpan?, TimeSpan?, CancellationToken)
    TestKitBase.AwaitAssertAsync(Func<Task>, TimeSpan?, TimeSpan?, CancellationToken)
    TestKitBase.AwaitCondition(Func<bool>, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<Task<bool>>, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<bool>, CancellationToken)
    TestKitBase.AwaitCondition(Func<bool>, TimeSpan?, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<Task<bool>>, TimeSpan?, CancellationToken)
    TestKitBase.AwaitCondition(Func<bool>, TimeSpan?, string, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<Task<bool>>, TimeSpan?, string, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<bool>, TimeSpan?, string, CancellationToken)
    TestKitBase.AwaitCondition(Func<bool>, TimeSpan?, TimeSpan?, string, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<Task<bool>>, TimeSpan?, TimeSpan?, string, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<bool>, TimeSpan?, TimeSpan?, string, CancellationToken)
    TestKitBase.AwaitConditionNoThrow(Func<bool>, TimeSpan, TimeSpan?, CancellationToken)
    TestKitBase.AwaitConditionNoThrowAsync(Func<Task<bool>>, TimeSpan, TimeSpan?, CancellationToken)
    TestKitBase.AwaitConditionNoThrowAsync(Func<bool>, TimeSpan, TimeSpan?, CancellationToken)
    TestKitBase.InternalAwaitCondition(Func<bool>, TimeSpan, TimeSpan?, Action<string, object[]>, CancellationToken)
    TestKitBase.InternalAwaitConditionAsync(Func<Task<bool>>, TimeSpan, TimeSpan?, Action<string, object[]>, CancellationToken)
    TestKitBase.InternalAwaitCondition(Func<bool>, TimeSpan, TimeSpan?, Action<string, object[]>, ILoggingAdapter, CancellationToken)
    TestKitBase.InternalAwaitConditionAsync(Func<Task<bool>>, TimeSpan, TimeSpan?, Action<string, object[]>, ILoggingAdapter, CancellationToken)
    TestKitBase.ExpectMsg<T>(TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsg<T>(T, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(T, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsg<T>(Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsg<T>(Action<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(Action<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsg<T>(Func<T, IActorRef, bool>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(Func<T, IActorRef, bool>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsg<T>(Action<T, IActorRef>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(Action<T, IActorRef>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsg<T>(T, Func<T, T, bool>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(T, Func<T, T, bool>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectTerminated(IActorRef, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectTerminatedAsync(IActorRef, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectNoMsg(CancellationToken)
    TestKitBase.ExpectNoMsgAsync(CancellationToken)
    TestKitBase.ExpectNoMsg(TimeSpan, CancellationToken)
    TestKitBase.ExpectNoMsgAsync(TimeSpan, CancellationToken)
    TestKitBase.ExpectNoMsg(int, CancellationToken)
    TestKitBase.ExpectNoMsgAsync(int, CancellationToken)
    TestKitBase.ExpectMsgAnyOf<T>(IEnumerable<T>, CancellationToken)
    TestKitBase.ExpectMsgAnyOfAsync<T>(IEnumerable<T>, CancellationToken)
    TestKitBase.ExpectMsgAllOf<T>(params T[])
    TestKitBase.ExpectMsgAllOf<T>(IReadOnlyCollection<T>, CancellationToken)
    TestKitBase.ExpectMsgAllOfAsync<T>(IReadOnlyCollection<T>, CancellationToken)
    TestKitBase.ExpectMsgAllOf<T>(TimeSpan, params T[])
    TestKitBase.ExpectMsgAllOf<T>(TimeSpan, IReadOnlyCollection<T>, CancellationToken)
    TestKitBase.ExpectMsgAllOfAsync<T>(TimeSpan, IReadOnlyCollection<T>, CancellationToken)
    TestKitBase.ExpectMsgAllOfMatchingPredicates(params PredicateInfo[])
    TestKitBase.ExpectMsgAllOfMatchingPredicates(IReadOnlyCollection<PredicateInfo>, CancellationToken)
    TestKitBase.ExpectMsgAllOfMatchingPredicatesAsync(IReadOnlyCollection<PredicateInfo>, CancellationToken)
    TestKitBase.ExpectMsgAllOfMatchingPredicates(TimeSpan, params PredicateInfo[])
    TestKitBase.ExpectMsgAllOfMatchingPredicates(TimeSpan, IReadOnlyCollection<PredicateInfo>, CancellationToken)
    TestKitBase.ExpectMsgAllOfMatchingPredicatesAsync(TimeSpan, IReadOnlyCollection<PredicateInfo>, CancellationToken)
    TestKitBase.ExpectMsgFrom<T>(IActorRef, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFromAsync<T>(IActorRef, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFrom<T>(IActorRef, T, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFromAsync<T>(IActorRef, T, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFrom<T>(IActorRef, Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFromAsync<T>(IActorRef, Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFrom<T>(Predicate<IActorRef>, Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFromAsync<T>(Predicate<IActorRef>, Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFrom<T>(IActorRef, Action<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFromAsync<T>(IActorRef, Action<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFrom<T>(Action<IActorRef>, Action<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFromAsync<T>(Action<IActorRef>, Action<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.FishForMessage(Predicate<object>, TimeSpan?, string, CancellationToken)
    TestKitBase.FishForMessageAsync(Predicate<object>, TimeSpan?, string, CancellationToken)
    TestKitBase.FishForMessage<T>(Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.FishForMessageAsync<T>(Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.FishForMessage<T>(Predicate<T>, ArrayList, TimeSpan?, string, CancellationToken)
    TestKitBase.FishForMessageAsync<T>(Predicate<T>, ArrayList, TimeSpan?, string, CancellationToken)
    TestKitBase.FishUntilMessageAsync<T>(TimeSpan?, CancellationToken)
    TestKitBase.WaitForRadioSilenceAsync(TimeSpan?, uint?, CancellationToken)
    TestKitBase.ReceiveOne(TimeSpan?, CancellationToken)
    TestKitBase.ReceiveOneAsync(TimeSpan?, CancellationToken)
    TestKitBase.TryReceiveOne(out MessageEnvelope, TimeSpan?, CancellationToken)
    TestKitBase.TryReceiveOneAsync(TimeSpan?, CancellationToken)
    TestKitBase.PeekOne(TimeSpan?, CancellationToken)
    TestKitBase.PeekOneAsync(TimeSpan?, CancellationToken)
    TestKitBase.PeekOne(CancellationToken)
    TestKitBase.PeekOneAsync(CancellationToken)
    TestKitBase.TryPeekOne(out MessageEnvelope, TimeSpan?, CancellationToken)
    TestKitBase.TryPeekOneAsync(TimeSpan?, CancellationToken)
    TestKitBase.ReceiveWhile<T>(TimeSpan?, Func<object, T>, int, CancellationToken)
    TestKitBase.ReceiveWhileAsync<T>(TimeSpan?, Func<object, T>, int, CancellationToken)
    TestKitBase.ReceiveWhile<T>(TimeSpan?, TimeSpan?, Func<object, T>, int, CancellationToken)
    TestKitBase.ReceiveWhileAsync<T>(TimeSpan?, TimeSpan?, Func<object, T>, int, CancellationToken)
    TestKitBase.ReceiveWhile<T>(Func<object, T>, TimeSpan?, TimeSpan?, int, CancellationToken)
    TestKitBase.ReceiveWhileAsync<T>(Func<object, T>, TimeSpan?, TimeSpan?, int, CancellationToken)
    TestKitBase.ReceiveWhile<T>(Predicate<T>, TimeSpan?, TimeSpan?, int, bool, CancellationToken)
    TestKitBase.ReceiveWhileAsync<T>(Predicate<T>, TimeSpan?, TimeSpan?, int, bool, CancellationToken)
    TestKitBase.ReceiveN(int, CancellationToken)
    TestKitBase.ReceiveNAsync(int, CancellationToken)
    TestKitBase.ReceiveN(int, TimeSpan, CancellationToken)
    TestKitBase.ReceiveNAsync(int, TimeSpan, CancellationToken)
    TestKitBase.Within(TimeSpan, Action, TimeSpan?, CancellationToken)
    TestKitBase.WithinAsync(TimeSpan, Func<Task>, TimeSpan?, CancellationToken)
    TestKitBase.Within(TimeSpan, TimeSpan, Action, string, TimeSpan?, CancellationToken)
    TestKitBase.WithinAsync(TimeSpan, TimeSpan, Func<Task>, string, TimeSpan?, CancellationToken)
    TestKitBase.Within<T>(TimeSpan, Func<T>, TimeSpan?, CancellationToken)
    TestKitBase.WithinAsync<T>(TimeSpan, Func<Task<T>>, TimeSpan?, CancellationToken)
    TestKitBase.Within<T>(TimeSpan, TimeSpan, Func<T>, string, TimeSpan?, CancellationToken)
    TestKitBase.WithinAsync<T>(TimeSpan, TimeSpan, Func<Task<T>>, string, TimeSpan?, CancellationToken)
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.MemberwiseClone()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Akka.Cluster.TestKit
    Assembly: Akka.Cluster.TestKit.dll
    Syntax
    public abstract class MultiNodeClusterSpec : MultiNodeSpec, IActorRefFactory, IMultiNodeSpecCallbacks, IDisposable

    Constructors

    | Edit this page View Source

    MultiNodeClusterSpec(MultiNodeConfig, Type)

    Declaration
    protected MultiNodeClusterSpec(MultiNodeConfig config, Type type)
    Parameters
    Type Name Description
    MultiNodeConfig config
    Type type
    | Edit this page 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
    ImmutableList<RoleName> roles
    Func<RoleName, ImmutableList<string>> deployments
    | Edit this page 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
    ImmutableList<RoleName> roles
    Func<RoleName, ImmutableList<string>> deployments

    Properties

    | Edit this page View Source

    Cluster

    Get the cluster node to use.

    Declaration
    public Cluster Cluster { get; }
    Property Value
    Type Description
    Cluster
    | Edit this page View Source

    InitialParticipantsValueFactory

    Must be defined by user. Creates the values used by InitialParticipants

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

    Methods

    | Edit this page View Source

    AfterTermination()

    Override this method to do something when the whole test is terminating.

    Declaration
    protected override void AfterTermination()
    Overrides
    MultiNodeSpec.AfterTermination()
    | Edit this page View Source

    AssertLeader(params 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
    | Edit this page 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
    ImmutableList<RoleName> nodesInCluster
    | Edit this page View Source

    AssertMembers(IEnumerable<Member>, params 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
    | Edit this page View Source

    AtStartup()

    Override this method to do something when the whole test is starting up.

    Declaration
    protected override void AtStartup()
    Overrides
    MultiNodeSpec.AtStartup()
    | Edit this page View Source

    AwaitAllReachable()

    Declaration
    public void AwaitAllReachable()
    | Edit this page View Source

    AwaitClusterUp(params 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
    | Edit this page View Source

    AwaitMembersUp(int, ImmutableHashSet<Address>, TimeSpan?)

    Declaration
    public void AwaitMembersUp(int numbersOfMembers, ImmutableHashSet<Address> canNotBePartOfMemberRing = null, TimeSpan? timeout = null)
    Parameters
    Type Name Description
    int numbersOfMembers
    ImmutableHashSet<Address> canNotBePartOfMemberRing
    TimeSpan? timeout
    | Edit this page View Source

    AwaitSeenSameState(params Address[])

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

    ClusterConfig()

    Declaration
    public static Config ClusterConfig()
    Returns
    Type Description
    Config
    | Edit this page View Source

    ClusterConfig(bool)

    Declaration
    public static Config ClusterConfig(bool failureDetectorPuppet)
    Parameters
    Type Name Description
    bool failureDetectorPuppet
    Returns
    Type Description
    Config
    | Edit this page View Source

    ClusterConfigWithFailureDetectorPuppet()

    Declaration
    public static Config ClusterConfigWithFailureDetectorPuppet()
    Returns
    Type Description
    Config
    | Edit this page View Source

    FailureDetectorPuppet(Address)

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

    GetAddress(RoleName)

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

    IsFailureDetectorPuppet()

    Declaration
    public bool IsFailureDetectorPuppet()
    Returns
    Type Description
    bool
    | Edit this page View Source

    JoinWithin(RoleName, TimeSpan?, TimeSpan?)

    Declaration
    public void JoinWithin(RoleName joinNode, TimeSpan? max = null, TimeSpan? interval = null)
    Parameters
    Type Name Description
    RoleName joinNode
    TimeSpan? max
    TimeSpan? interval
    | Edit this page 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
    | Edit this page 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
    | Edit this page View Source

    MuteLog(ActorSystem)

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

    MuteMarkingAsReachable(ActorSystem)

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

    MuteMarkingAsUnreachable(ActorSystem)

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

    RoleName(Address)

    Declaration
    public RoleName RoleName(Address addr)
    Parameters
    Type Name Description
    Address addr
    Returns
    Type Description
    RoleName
    | Edit this page 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
    ImmutableList<RoleName> nodesInCluster
    Returns
    Type Description
    RoleName
    | Edit this page View Source

    StartClusterNode()

    Use this method for the initial startup of the cluster node

    Declaration
    public void StartClusterNode()

    Implements

    IActorRefFactory
    IMultiNodeSpecCallbacks
    IDisposable

    Extension Methods

    ActorRefFactoryExtensions.ActorOf<TActor>(IActorRefFactory, string)
    ActorRefFactoryExtensions.ActorSelection(IActorRefFactory, IActorRef, string)
    ActExtensions.ActorOf(IActorRefFactory, Action<IActorDsl, IActorContext>, string)
    ActExtensions.ActorOf(IActorRefFactory, Action<IActorDsl>, string)
    ActorMaterializerExtensions.Materializer(IActorRefFactory, ActorMaterializerSettings, string)
    ObjectExtensions.IsDefaultForType<T>(T)
    ObjectExtensions.AsOption<T>(T)
    TestPublisher.CreateManualPublisherProbe<T>(TestKitBase, bool)
    TestPublisher.CreatePublisherProbe<T>(TestKitBase, long)
    TestSink.SinkProbe<T>(TestKitBase)
    TestSource.SourceProbe<T>(TestKitBase)
    TestSubscriber.CreateManualSubscriberProbe<T>(TestKitBase)
    TestSubscriber.CreateSubscriberProbe<T>(TestKitBase)
    Utils.AssertAllStagesStopped(TestKitBase, Action, IMaterializer, TimeSpan?, CancellationToken)
    Utils.AssertAllStagesStoppedAsync(TestKitBase, Func<Task>, IMaterializer, TimeSpan?, CancellationToken)
    Utils.AssertAllStagesStoppedAsync<T>(TestKitBase, Func<Task<T>>, IMaterializer, TimeSpan?, CancellationToken)
    Utils.AssertAllStagesStopped<T>(TestKitBase, Func<T>, IMaterializer, TimeSpan?, CancellationToken)
    Extensions.AsInstanceOf<T>(object)
    In this article
    • githubEdit this page
    • View Source
    Back to top
    Contribute
    • Project Chat
    • Discussion Forum
    • Source Code
    Support
    • Akka.NET Support Plans
    • Akka.NET Observability Tools
    • Akka.NET Training & Consulting
    Maintained By
    • Petabridge - The Akka.NET Company
    • Learn Akka.NET