public class Controller
extends java.lang.Object
implements akka.actor.Actor
BarrierCoordinator
, its child) and allowing
network and other failures to be injected at the test nodes.
INTERNAL API.
Modifier and Type | Class and Description |
---|---|
static class |
Controller.ClientDisconnected |
static class |
Controller.ClientDisconnected$ |
static class |
Controller.ClientDisconnectedException |
static class |
Controller.CreateServerFSM |
static class |
Controller.CreateServerFSM$ |
static class |
Controller.GetNodes$ |
static class |
Controller.GetSockAddr$ |
static class |
Controller.NodeInfo |
static class |
Controller.NodeInfo$ |
Constructor and Description |
---|
Controller(int initialParticipants,
java.net.InetSocketAddress controllerPort) |
Modifier and Type | Method and Description |
---|---|
scala.collection.immutable.Map<RoleName,scala.collection.immutable.Set<akka.actor.ActorRef>> |
addrInterest() |
akka.actor.ActorRef |
barrier() |
org.jboss.netty.channel.Channel |
connection() |
akka.actor.SupervisorStrategy.Directive |
failBarrier(BarrierCoordinator.Data data) |
scala.collection.Iterator<java.lang.Object> |
generation() |
scala.collection.immutable.Map<RoleName,Controller.NodeInfo> |
nodes() |
void |
postStop() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
akka.remote.testconductor.TestConductorExt.Settings$ |
settings() |
akka.actor.OneForOneStrategy |
supervisorStrategy() |
public Controller(int initialParticipants, java.net.InetSocketAddress controllerPort)
public akka.remote.testconductor.TestConductorExt.Settings$ settings()
public org.jboss.netty.channel.Channel connection()
public akka.actor.OneForOneStrategy supervisorStrategy()
supervisorStrategy
in interface akka.actor.Actor
public akka.actor.SupervisorStrategy.Directive failBarrier(BarrierCoordinator.Data data)
public akka.actor.ActorRef barrier()
public scala.collection.immutable.Map<RoleName,Controller.NodeInfo> nodes()
public scala.collection.immutable.Map<RoleName,scala.collection.immutable.Set<akka.actor.ActorRef>> addrInterest()
public scala.collection.Iterator<java.lang.Object> generation()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
public void postStop()
postStop
in interface akka.actor.Actor