Package org.apache.pekko.remote.testconductor

Interface Player

All Known Implementing Classes:
TestConductorExt
public interface Player
The Player is the client component of the pekko.remote.testconductor.TestConductorExt extension. It registers with the pekko.remote.testconductor.Conductor’s pekko.remote.testconductor.Controller in order to participate in barriers and enable network failure injection.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static final class 
    Player.Waiter
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    _client_$eq(ActorRef x$1)
     
    ActorRef
    client()
     
    void
    enter(Timeout timeout, scala.collection.immutable.Seq<String> name)
    Enter the named barriers, one after the other, in the order given.
    void
    enter(scala.collection.immutable.Seq<String> name)
    Enter the named barriers, one after the other, in the order given.
    scala.concurrent.Future<Address>
    getAddressFor(RoleName name)
    Query remote transport address of named node.
    scala.concurrent.Future<org.apache.pekko.remote.testconductor.Done>
    startClient(RoleName name, InetSocketAddress controllerAddr)
    Connect to the conductor on the given port (the host is taken from setting pekko.testconductor.host).

  • Method Details

    • _client_$eq

      void _client_$eq(ActorRef x$1)

    • client

      ActorRef client()

    • startClient

      scala.concurrent.Future<org.apache.pekko.remote.testconductor.Done> startClient(RoleName name, InetSocketAddress controllerAddr)
      Connect to the conductor on the given port (the host is taken from setting pekko.testconductor.host). The connection is made asynchronously, but you should await completion of the returned Future because that implies that all expected participants of this test have successfully connected (i.e. this is a first barrier in itself). The number of expected participants is set in pekko.remote.testconductor.Conductor.startController().

    • enter

      void enter(scala.collection.immutable.Seq<String> name)
      Enter the named barriers, one after the other, in the order given. Will throw an exception in case of timeouts or other errors.

    • enter

      void enter(Timeout timeout, scala.collection.immutable.Seq<String> name)
      Enter the named barriers, one after the other, in the order given. Will throw an exception in case of timeouts or other errors.

    • getAddressFor

      scala.concurrent.Future<Address> getAddressFor(RoleName name)
      Query remote transport address of named node.