Interface Player
-
- All Known Implementing Classes:
TestConductorExt
public interface PlayerThe Player is the client component of thepekko.remote.testconductor.TestConductorExtextension. It registers with thepekko.remote.testconductor.Conductor’spekko.remote.testconductor.Controllerin order to participate in barriers and enable network failure injection.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static classPlayer.Waiter
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void_client_$eq(ActorRef x$1)ActorRefclient()voidenter(Timeout timeout, scala.collection.immutable.Seq<java.lang.String> name)Enter the named barriers, one after the other, in the order given.voidenter(scala.collection.immutable.Seq<java.lang.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, java.net.InetSocketAddress controllerAddr)Connect to the conductor on the given port (the host is taken from settingpekko.testconductor.host).
-
-
-
Method Detail
-
_client_$eq
void _client_$eq(ActorRef x$1)
-
client
ActorRef client()
-
startClient
scala.concurrent.Future<org.apache.pekko.remote.testconductor.Done> startClient(RoleName name, java.net.InetSocketAddress controllerAddr)
Connect to the conductor on the given port (the host is taken from settingpekko.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 inpekko.remote.testconductor.Conductor.startController().
-
enter
void enter(scala.collection.immutable.Seq<java.lang.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<java.lang.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.
-
-