Packages

p

org.apache.pekko.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 pekko.remote.testconductor.Controller’s port to which all pekko.remote.testconductor.Players connect, it issues commands to their org.apache.pekko.remote.testconductor.NetworkFailureInjector and provides support for barriers using the pekko.remote.testconductor.BarrierCoordinator.

    The conductor is the one orchestrating the test: it governs the pekko.remote.testconductor.Controller’s port to which all pekko.remote.testconductor.Players connect, it issues commands to their org.apache.pekko.remote.testconductor.NetworkFailureInjector and provides support for barriers using the pekko.remote.testconductor.BarrierCoordinator. All of this is bundled inside the pekko.remote.testconductor.TestConductorExt extension.

  2. trait Player extends AnyRef

    The Player is the client component of the pekko.remote.testconductor.TestConductorExt extension.

    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.

  3. final case class RoleName(name: String) extends Product with Serializable
  4. class TestConductorExt extends Extension with Conductor with Player

    This binds together the pekko.remote.testconductor.Conductor and pekko.remote.testconductor.Player roles inside an Akka pekko.actor.Extension.

    This binds together the pekko.remote.testconductor.Conductor and pekko.remote.testconductor.Player roles inside an Akka pekko.actor.Extension. Please follow the aforementioned links for more information.

    Note

    This extension requires the pekko.actor.provider to be a pekko.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
    Annotations
    @ccompatUsedUntil213()
  2. object TestConductor extends ExtensionId[TestConductorExt] with ExtensionIdProvider

    Access to the pekko.remote.testconductor.TestConductorExt extension:

    Access to the pekko.remote.testconductor.TestConductorExt extension:

    val tc = TestConductor(system)
tc.startController(numPlayers)
// OR
tc.startClient(conductorPort)

Ungrouped