package testconductor
- Alphabetic
- Public
- All
Type Members
-
trait
Conductor
extends AnyRef
The conductor is the one orchestrating the test: it governs the akka.remote.testconductor.Controller’s port to which all akka.remote.testconductor.Players connect, it issues commands to their
akka.remote.testconductor.NetworkFailureInjector
and provides support for barriers using the akka.remote.testconductor.BarrierCoordinator.The conductor is the one orchestrating the test: it governs the akka.remote.testconductor.Controller’s port to which all akka.remote.testconductor.Players connect, it issues commands to their
akka.remote.testconductor.NetworkFailureInjector
and provides support for barriers using the akka.remote.testconductor.BarrierCoordinator. All of this is bundled inside the akka.remote.testconductor.TestConductorExt extension. -
trait
Player
extends AnyRef
The Player is the client component of the akka.remote.testconductor.TestConductorExt extension.
The Player is the client component of the akka.remote.testconductor.TestConductorExt extension. It registers with the akka.remote.testconductor.Conductor’s akka.remote.testconductor.Controller in order to participate in barriers and enable network failure injection.
- final case class RoleName (name: String) extends Product with Serializable
-
class
TestConductorExt
extends Extension with Conductor with Player
This binds together the akka.remote.testconductor.Conductor and akka.remote.testconductor.Player roles inside an Akka akka.actor.Extension.
This binds together the akka.remote.testconductor.Conductor and akka.remote.testconductor.Player roles inside an Akka akka.actor.Extension. Please follow the aforementioned links for more information.
Note
This extension requires the
akka.actor.provider
to be a akka.remote.RemoteActorRefProvider.To use
,blackhole
, andpassThrough
you must activate the failure injector and throttler transport adapters by specifyingthrottle
testTransport(on = true)
in your MultiNodeConfig. - final class TestConductorProtocol extends AnyRef
Value Members
-
object
TestConductor
extends ExtensionId[TestConductorExt] with ExtensionIdProvider
Access to the akka.remote.testconductor.TestConductorExt extension:
Access to the akka.remote.testconductor.TestConductorExt extension:
val tc = TestConductor(system) tc.startController(numPlayers) // OR tc.startClient(conductorPort)