Package akka.remote.testconductor

Interface Summary
BarrierCoordinator.Printer  
BarrierCoordinator.State  
ClientFSM.State  
ClientOp  
CommandOp  
Conductor The conductor is the one orchestrating the test: it governs the Controller’s port to which all Players connect, it issues commands to their akka.remote.testconductor.NetworkFailureInjector and provides support for barriers using the BarrierCoordinator.
ConfirmedClientOp  
NetworkOp  
Player The Player is the client component of the TestConductorExt extension.
Role INTERNAL API.
ServerFSM.State  
ServerOp  
TestConductorProtocol.AddressOrBuilder  
TestConductorProtocol.AddressRequestOrBuilder  
TestConductorProtocol.EnterBarrierOrBuilder  
TestConductorProtocol.HelloOrBuilder  
TestConductorProtocol.InjectFailureOrBuilder  
TestConductorProtocol.WrapperOrBuilder  
UnconfirmedClientOp  
 

Class Summary
AddressReply  
AddressReply$  
BarrierCoordinator This barrier coordinator gets informed of players connecting (NodeInfo), players being deliberately removed (RemoveClient) or failing (ClientDisconnected) by the controller.
BarrierCoordinator.BarrierEmpty$  
BarrierCoordinator.BarrierTimeout$  
BarrierCoordinator.ClientLost$  
BarrierCoordinator.Data  
BarrierCoordinator.Data$  
BarrierCoordinator.DuplicateNode$  
BarrierCoordinator.FailedBarrier$  
BarrierCoordinator.Idle$  
BarrierCoordinator.RemoveClient  
BarrierCoordinator.RemoveClient$  
BarrierCoordinator.Waiting$  
BarrierCoordinator.WrongBarrier$  
BarrierCoordinator$ INTERNAL API.
BarrierResult  
BarrierResult$  
Client INTERNAL API.
Client$ INTERNAL API.
ClientFSM This is the controlling entity on the Player side: in a first step it registers itself with a symbolic name and its remote address at the Controller, then waits for the Done message which signals that all other expected test participants have done the same.
ClientFSM.AwaitDone$  
ClientFSM.Connected  
ClientFSM.Connected$  
ClientFSM.Connecting$  
ClientFSM.ConnectionFailure$  
ClientFSM.Data  
ClientFSM.Data$  
ClientFSM.Disconnected$  
ClientFSM.Failed$  
ClientFSM$ INTERNAL API.
ConductorHandler This handler is installed at the end of the controller’s netty pipeline.
Controller This controls test execution by managing barriers (delegated to BarrierCoordinator, its child) and allowing network and other failures to be injected at the test nodes.
Controller.ClientDisconnected  
Controller.ClientDisconnected$  
Controller.CreateServerFSM  
Controller.CreateServerFSM$  
Controller.GetNodes$  
Controller.GetSockAddr$  
Controller.NodeInfo  
Controller.NodeInfo$  
Controller$ INTERNAL API.
Disconnect  
Disconnect$  
DisconnectMsg  
DisconnectMsg$  
Done  
Done$  
EnterBarrier  
EnterBarrier$  
FailBarrier  
FailBarrier$  
GetAddress  
GetAddress$  
Hello First message of connection sets names straight.
Hello$  
MsgDecoder  
MsgEncoder  
PlayerHandler This handler only forwards messages received from the conductor to the ClientFSM.
RemoteConnection INTERNAL API.
RemoteConnection$ INTERNAL API.
Remove  
Remove$  
RoleName  
RoleName$  
Server INTERNAL API.
Server$ INTERNAL API.
ServerFSM The server part of each client connection is represented by a ServerFSM.
ServerFSM.Initial$  
ServerFSM.Ready$  
ServerFSM$ INTERNAL API.
Terminate  
Terminate$  
TerminateMsg  
TerminateMsg$  
TestConductor Access to the TestConductorExt extension:
TestConductor$ Access to the TestConductorExt extension:
TestConductorExt This binds together the Conductor and Player roles inside an Akka Extension.
TestConductorPipelineFactory INTERNAL API.
TestConductorProtocol  
TestConductorProtocol.Address Protobuf type Address
TestConductorProtocol.Address.Builder Protobuf type Address
TestConductorProtocol.AddressRequest Protobuf type AddressRequest
TestConductorProtocol.AddressRequest.Builder Protobuf type AddressRequest
TestConductorProtocol.EnterBarrier Protobuf type EnterBarrier
TestConductorProtocol.EnterBarrier.Builder Protobuf type EnterBarrier
TestConductorProtocol.Hello Protobuf type Hello
TestConductorProtocol.Hello.Builder Protobuf type Hello
TestConductorProtocol.InjectFailure Protobuf type InjectFailure
TestConductorProtocol.InjectFailure.Builder Protobuf type InjectFailure
TestConductorProtocol.Wrapper Protobuf type Wrapper
TestConductorProtocol.Wrapper.Builder Protobuf type Wrapper
Throttle  
Throttle$  
ThrottleMsg  
ThrottleMsg$  
ToClient  
ToClient$  
ToServer  
ToServer$  
 

Enum Summary
TestConductorProtocol.BarrierOp Protobuf enum BarrierOp
TestConductorProtocol.Direction Protobuf enum Direction
TestConductorProtocol.FailType Protobuf enum FailType
 

Exception Summary
BarrierCoordinator.BarrierEmpty  
BarrierCoordinator.BarrierTimeout  
BarrierCoordinator.ClientLost  
BarrierCoordinator.DuplicateNode  
BarrierCoordinator.FailedBarrier  
BarrierCoordinator.WrongBarrier  
ClientFSM.ConnectionFailure  
Controller.ClientDisconnectedException