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