Packages

p

akka.remote

testconductor

package testconductor

Content Hierarchy
Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. 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.

  2. 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.

  3. final case class RoleName(name: String) extends Product with Serializable
  4. 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, passThrough, and throttle you must activate the failure injector and throttler transport adapters by specifying testTransport(on = true) in your MultiNodeConfig.

  5. final class TestConductorProtocol extends AnyRef

Value Members

  1. object Player
  2. 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)

Ungrouped