Skip navigation links
A B C D E F G H I L M N O P Q R S T U V W _ 

A

abort(RoleName, RoleName) - Method in interface akka.remote.testconductor.Conductor
Tell the remote support to TCP_RESET the connection to the given remote peer.
abort() - Method in class akka.remote.testconductor.Disconnect
 
abort() - Method in class akka.remote.testconductor.DisconnectMsg
 
Abort_VALUE - Static variable in enum akka.remote.testconductor.TestConductorProtocol.FailType
Abort = 3;
addr() - Method in class akka.remote.testconductor.AddressReply
 
addr() - Method in class akka.remote.testconductor.Controller.NodeInfo
 
addr() - Method in class akka.remote.testconductor.Hello
 
ADDR_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
ADDR_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
address() - Method in class akka.remote.testconductor.TestConductorExt
Transport address of this Netty-like remote transport.
address2proto(Address) - Method in class akka.remote.testconductor.MsgEncoder
 
address2scala(TestConductorProtocol.Address) - Method in class akka.remote.testconductor.MsgDecoder
 
ADDRESS_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Hello
 
ADDRESS_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
AddressReply - Class in akka.remote.testconductor
 
AddressReply(RoleName, Address) - Constructor for class akka.remote.testconductor.AddressReply
 
AddressReply$ - Class in akka.remote.testconductor
 
AddressReply$() - Constructor for class akka.remote.testconductor.AddressReply$
 
addrInterest() - Method in class akka.remote.testconductor.Controller
 
afterTermination() - Method in class akka.remote.testkit.MultiNodeSpec
Override this method to do something when the whole test is terminating.
akka.remote.testconductor - package akka.remote.testconductor
 
akka.remote.testkit - package akka.remote.testkit
 
apply(Role, InetSocketAddress, int, ChannelUpstreamHandler) - Method in class akka.remote.testconductor.RemoteConnection$
 
apply(Role, InetSocketAddress, int, ChannelUpstreamHandler) - Static method in class akka.remote.testconductor.RemoteConnection
 
apply(ActorContext) - Method in class akka.remote.testconductor.TestConductor$
 
apply(ActorContext) - Static method in class akka.remote.testconductor.TestConductor
 
arrived() - Method in class akka.remote.testconductor.BarrierCoordinator.Data
 
atStartup() - Method in class akka.remote.testkit.MultiNodeSpec
Override this method to do something when the whole test is starting up.
attachConductor(TestConductorExt) - Method in class akka.remote.testkit.MultiNodeSpec
 
await() - Method in class akka.remote.testkit.MultiNodeSpec.AwaitHelper
 
AwaitDone$() - Constructor for class akka.remote.testconductor.ClientFSM.AwaitDone$
 
awaitHelper(Awaitable<T>) - Method in class akka.remote.testkit.MultiNodeSpec
Enrich .await() onto all Awaitables, using remaining duration from the innermost enclosing within block or QueryTimeout.
AwaitHelper(Awaitable<T>) - Constructor for class akka.remote.testkit.MultiNodeSpec.AwaitHelper
 

B

barrier() - Method in class akka.remote.testconductor.BarrierCoordinator.Data
 
barrier() - Method in exception akka.remote.testconductor.BarrierCoordinator.WrongBarrier
 
barrier() - Method in class akka.remote.testconductor.Controller
 
BARRIER_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
BarrierCoordinator - Class in akka.remote.testconductor
This barrier coordinator gets informed of players connecting (NodeInfo), players being deliberately removed (RemoveClient) or failing (ClientDisconnected) by the controller.
BarrierCoordinator() - Constructor for class akka.remote.testconductor.BarrierCoordinator
 
BarrierCoordinator$ - Class in akka.remote.testconductor
INTERNAL API.
BarrierCoordinator$() - Constructor for class akka.remote.testconductor.BarrierCoordinator$
 
BarrierCoordinator.BarrierEmpty - Exception in akka.remote.testconductor
 
BarrierCoordinator.BarrierEmpty$ - Class in akka.remote.testconductor
 
BarrierCoordinator.BarrierTimeout - Exception in akka.remote.testconductor
 
BarrierCoordinator.BarrierTimeout$ - Class in akka.remote.testconductor
 
BarrierCoordinator.ClientLost - Exception in akka.remote.testconductor
 
BarrierCoordinator.ClientLost$ - Class in akka.remote.testconductor
 
BarrierCoordinator.Data - Class in akka.remote.testconductor
 
BarrierCoordinator.Data$ - Class in akka.remote.testconductor
 
BarrierCoordinator.DuplicateNode - Exception in akka.remote.testconductor
 
BarrierCoordinator.DuplicateNode$ - Class in akka.remote.testconductor
 
BarrierCoordinator.FailedBarrier - Exception in akka.remote.testconductor
 
BarrierCoordinator.FailedBarrier$ - Class in akka.remote.testconductor
 
BarrierCoordinator.Idle$ - Class in akka.remote.testconductor
 
BarrierCoordinator.Printer - Interface in akka.remote.testconductor
 
BarrierCoordinator.RemoveClient - Class in akka.remote.testconductor
 
BarrierCoordinator.RemoveClient$ - Class in akka.remote.testconductor
 
BarrierCoordinator.State - Interface in akka.remote.testconductor
 
BarrierCoordinator.Waiting$ - Class in akka.remote.testconductor
 
BarrierCoordinator.WrongBarrier - Exception in akka.remote.testconductor
 
BarrierCoordinator.WrongBarrier$ - Class in akka.remote.testconductor
 
BarrierEmpty(BarrierCoordinator.Data, String) - Constructor for exception akka.remote.testconductor.BarrierCoordinator.BarrierEmpty
 
BarrierEmpty$() - Constructor for class akka.remote.testconductor.BarrierCoordinator.BarrierEmpty$
 
BarrierResult - Class in akka.remote.testconductor
 
BarrierResult(String, boolean) - Constructor for class akka.remote.testconductor.BarrierResult
 
BarrierResult$ - Class in akka.remote.testconductor
 
BarrierResult$() - Constructor for class akka.remote.testconductor.BarrierResult$
 
BarrierTimeout(BarrierCoordinator.Data) - Constructor for exception akka.remote.testconductor.BarrierCoordinator.BarrierTimeout
 
BarrierTimeout() - Method in class akka.remote.testconductor.TestConductorExt.Settings
 
BarrierTimeout$() - Constructor for class akka.remote.testconductor.BarrierCoordinator.BarrierTimeout$
 
baseConfig() - Method in class akka.remote.testkit.MultiNodeSpec$
 
baseConfig() - Static method in class akka.remote.testkit.MultiNodeSpec
 
blackhole(RoleName, RoleName, ThrottlerTransportAdapter.Direction) - Method in interface akka.remote.testconductor.Conductor
Switch the Netty pipeline of the remote support into blackhole mode for sending and/or receiving: it will just drop all messages right before submitting them to the Socket or right after receiving them from the Socket.
Both_VALUE - Static variable in enum akka.remote.testconductor.TestConductorProtocol.Direction
Both = 3;
build() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
 
build() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
 
build() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
 
build() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
 
build() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
 
build() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
 
buildPartial() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
 
buildPartial() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
 
buildPartial() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
 
buildPartial() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
 
buildPartial() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
 
buildPartial() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
 

C

channel() - Method in class akka.remote.testconductor.ClientFSM.Connected
 
channel() - Method in class akka.remote.testconductor.ClientFSM.Data
 
channel() - Method in class akka.remote.testconductor.Controller.CreateServerFSM
 
channel() - Method in class akka.remote.testconductor.ServerFSM
 
channelBound(ChannelHandlerContext, ChannelStateEvent) - Method in class akka.remote.testconductor.PlayerHandler
 
channelClosed(ChannelHandlerContext, ChannelStateEvent) - Method in class akka.remote.testconductor.PlayerHandler
 
channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class akka.remote.testconductor.ConductorHandler
 
channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class akka.remote.testconductor.PlayerHandler
 
channelDisconnected(ChannelHandlerContext, ChannelStateEvent) - Method in class akka.remote.testconductor.ConductorHandler
 
channelDisconnected(ChannelHandlerContext, ChannelStateEvent) - Method in class akka.remote.testconductor.PlayerHandler
 
channelOpen(ChannelHandlerContext, ChannelStateEvent) - Method in class akka.remote.testconductor.PlayerHandler
 
channelUnbound(ChannelHandlerContext, ChannelStateEvent) - Method in class akka.remote.testconductor.PlayerHandler
 
clear() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
 
clear() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
 
clear() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
 
clear() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
 
clear() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
 
clear() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
 
clearAddr() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
optional .Address addr = 2;
clearAddr() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .AddressRequest addr = 5;
clearAddress() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required .Address address = 2;
clearAddress() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional .Address address = 3;
clearBarrier() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .EnterBarrier barrier = 2;
clearDirection() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional .Direction direction = 2;
clearDone() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional string done = 4;
clearExitValue() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional int32 exitValue = 7;
clearFailure() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
required .FailType failure = 1;
clearFailure() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .InjectFailure failure = 3;
clearHello() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .Hello hello = 1;
clearHost() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string host = 3;
clearName() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
required string name = 1;
clearName() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required string name = 1;
clearNode() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
required string node = 1;
clearOp() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
required .BarrierOp op = 2;
clearPort() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required int32 port = 4;
clearProtocol() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string protocol = 1;
clearRateMBit() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional float rateMBit = 6;
clearSystem() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string system = 2;
clearTimeout() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
optional int64 timeout = 3;
client() - Method in exception akka.remote.testconductor.BarrierCoordinator.ClientLost
 
client() - Method in exception akka.remote.testconductor.BarrierCoordinator.WrongBarrier
 
Client - Class in akka.remote.testconductor
INTERNAL API.
Client() - Constructor for class akka.remote.testconductor.Client
 
client() - Method in interface akka.remote.testconductor.Player
 
Client$ - Class in akka.remote.testconductor
INTERNAL API.
Client$() - Constructor for class akka.remote.testconductor.Client$
 
ClientDisconnected(RoleName) - Constructor for class akka.remote.testconductor.Controller.ClientDisconnected
 
ClientDisconnected$() - Constructor for class akka.remote.testconductor.Controller.ClientDisconnected$
 
ClientDisconnectedException(String) - Constructor for exception akka.remote.testconductor.Controller.ClientDisconnectedException
 
ClientFSM - Class in akka.remote.testconductor
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(RoleName, InetSocketAddress) - Constructor for class akka.remote.testconductor.ClientFSM
 
ClientFSM$ - Class in akka.remote.testconductor
INTERNAL API.
ClientFSM$() - Constructor for class akka.remote.testconductor.ClientFSM$
 
ClientFSM.AwaitDone$ - Class in akka.remote.testconductor
 
ClientFSM.Connected - Class in akka.remote.testconductor
 
ClientFSM.Connected$ - Class in akka.remote.testconductor
 
ClientFSM.Connecting$ - Class in akka.remote.testconductor
 
ClientFSM.ConnectionFailure - Exception in akka.remote.testconductor
 
ClientFSM.ConnectionFailure$ - Class in akka.remote.testconductor
 
ClientFSM.Data - Class in akka.remote.testconductor
 
ClientFSM.Data$ - Class in akka.remote.testconductor
 
ClientFSM.Disconnected$ - Class in akka.remote.testconductor
 
ClientFSM.Failed$ - Class in akka.remote.testconductor
 
ClientFSM.State - Interface in akka.remote.testconductor
 
ClientLost(BarrierCoordinator.Data, RoleName) - Constructor for exception akka.remote.testconductor.BarrierCoordinator.ClientLost
 
ClientLost$() - Constructor for class akka.remote.testconductor.BarrierCoordinator.ClientLost$
 
ClientOp - Interface in akka.remote.testconductor
 
ClientReconnects() - Method in class akka.remote.testconductor.TestConductorExt.Settings
 
clients() - Method in class akka.remote.testconductor.BarrierCoordinator.Data
 
clients() - Method in class akka.remote.testconductor.ConductorHandler
 
ClientSocketWorkerPoolSize() - Method in class akka.remote.testconductor.TestConductorExt.Settings
 
clone() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
 
clone() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
 
clone() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
 
clone() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
 
clone() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
 
clone() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
 
CommandOp - Interface in akka.remote.testconductor
 
commonConfig(Config) - Method in class akka.remote.testkit.MultiNodeConfig
Register a common base config for all test participants, if so desired.
Conductor - Interface in akka.remote.testconductor
The conductor is the one orchestrating the test: it governs the Controller&rsquo;s port to which all Players connect, it issues commands to their akka.remote.testconductor.NetworkFailureInjector and provides support for barriers using the BarrierCoordinator.
ConductorHandler - Class in akka.remote.testconductor
This handler is installed at the end of the controller&rsquo;s netty pipeline.
ConductorHandler(Timeout, ActorRef, LoggingAdapter) - Constructor for class akka.remote.testconductor.ConductorHandler
 
config() - Method in class akka.remote.testconductor.TestConductorExt.Settings
 
config() - Method in class akka.remote.testkit.MultiNodeConfig
 
ConfirmedClientOp - Interface in akka.remote.testconductor
 
Connected(Channel) - Constructor for class akka.remote.testconductor.ClientFSM.Connected
 
Connected$() - Constructor for class akka.remote.testconductor.ClientFSM.Connected$
 
Connecting$() - Constructor for class akka.remote.testconductor.ClientFSM.Connecting$
 
connection() - Method in class akka.remote.testconductor.Controller
 
ConnectionFailure(String) - Constructor for exception akka.remote.testconductor.ClientFSM.ConnectionFailure
 
ConnectionFailure$() - Constructor for class akka.remote.testconductor.ClientFSM.ConnectionFailure$
 
ConnectTimeout() - Method in class akka.remote.testconductor.TestConductorExt.Settings
 
controller() - Method in interface akka.remote.testconductor.Conductor
 
Controller - Class in akka.remote.testconductor
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(int, InetSocketAddress) - Constructor for class akka.remote.testconductor.Controller
 
controller() - Method in class akka.remote.testconductor.ServerFSM
 
Controller$ - Class in akka.remote.testconductor
INTERNAL API.
Controller$() - Constructor for class akka.remote.testconductor.Controller$
 
Controller.ClientDisconnected - Class in akka.remote.testconductor
 
Controller.ClientDisconnected$ - Class in akka.remote.testconductor
 
Controller.ClientDisconnectedException - Exception in akka.remote.testconductor
 
Controller.CreateServerFSM - Class in akka.remote.testconductor
 
Controller.CreateServerFSM$ - Class in akka.remote.testconductor
 
Controller.GetNodes$ - Class in akka.remote.testconductor
 
Controller.GetSockAddr$ - Class in akka.remote.testconductor
 
Controller.NodeInfo - Class in akka.remote.testconductor
 
Controller.NodeInfo$ - Class in akka.remote.testconductor
 
createExtension(ExtendedActorSystem) - Method in class akka.remote.testconductor.TestConductor$
 
createExtension(ExtendedActorSystem) - Static method in class akka.remote.testconductor.TestConductor
 
CreateServerFSM(Channel) - Constructor for class akka.remote.testconductor.Controller.CreateServerFSM
 
CreateServerFSM$() - Constructor for class akka.remote.testconductor.Controller.CreateServerFSM$
 
createTimeout() - Method in class akka.remote.testconductor.ConductorHandler
 

D

data() - Method in exception akka.remote.testconductor.BarrierCoordinator.BarrierEmpty
 
data() - Method in exception akka.remote.testconductor.BarrierCoordinator.BarrierTimeout
 
data() - Method in exception akka.remote.testconductor.BarrierCoordinator.ClientLost
 
Data(Set<Controller.NodeInfo>, String, List<ActorRef>, Deadline) - Constructor for class akka.remote.testconductor.BarrierCoordinator.Data
 
data() - Method in exception akka.remote.testconductor.BarrierCoordinator.DuplicateNode
 
data() - Method in exception akka.remote.testconductor.BarrierCoordinator.FailedBarrier
 
data() - Method in exception akka.remote.testconductor.BarrierCoordinator.WrongBarrier
 
Data(Option<Channel>, Option<Tuple2<String, ActorRef>>) - Constructor for class akka.remote.testconductor.ClientFSM.Data
 
Data$() - Constructor for class akka.remote.testconductor.BarrierCoordinator.Data$
 
Data$() - Constructor for class akka.remote.testconductor.ClientFSM.Data$
 
deadline() - Method in class akka.remote.testconductor.BarrierCoordinator.Data
 
debugConfig(boolean) - Method in class akka.remote.testkit.MultiNodeConfig
Include for verbose debug logging
decode(ChannelHandlerContext, Channel, Object) - Method in class akka.remote.testconductor.MsgDecoder
 
decode(ChannelHandlerContext, Channel, Object) - Method in class akka.remote.testconductor.ProtobufDecoder
 
deployments(RoleName) - Method in class akka.remote.testkit.MultiNodeConfig
 
deployOn(RoleName, String) - Method in class akka.remote.testkit.MultiNodeConfig
 
deployOnAll(String) - Method in class akka.remote.testkit.MultiNodeConfig
 
direction() - Method in class akka.remote.testconductor.Throttle
 
direction() - Method in class akka.remote.testconductor.ThrottleMsg
 
direction2proto(ThrottlerTransportAdapter.Direction) - Method in class akka.remote.testconductor.MsgEncoder
 
direction2scala(TestConductorProtocol.Direction) - Method in class akka.remote.testconductor.MsgDecoder
 
DIRECTION_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
disconnect(RoleName, RoleName) - Method in interface akka.remote.testconductor.Conductor
Tell the remote support to shutdown the connection to the given remote peer.
Disconnect - Class in akka.remote.testconductor
 
Disconnect(RoleName, RoleName, boolean) - Constructor for class akka.remote.testconductor.Disconnect
 
Disconnect$ - Class in akka.remote.testconductor
 
Disconnect$() - Constructor for class akka.remote.testconductor.Disconnect$
 
Disconnect_VALUE - Static variable in enum akka.remote.testconductor.TestConductorProtocol.FailType
Disconnect = 2;
Disconnected$() - Constructor for class akka.remote.testconductor.ClientFSM.Disconnected$
 
DisconnectMsg - Class in akka.remote.testconductor
 
DisconnectMsg(Address, boolean) - Constructor for class akka.remote.testconductor.DisconnectMsg
 
DisconnectMsg$ - Class in akka.remote.testconductor
 
DisconnectMsg$() - Constructor for class akka.remote.testconductor.DisconnectMsg$
 
Done - Class in akka.remote.testconductor
 
Done() - Constructor for class akka.remote.testconductor.Done
 
Done$ - Class in akka.remote.testconductor
 
Done$() - Constructor for class akka.remote.testconductor.Done$
 
DONE_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
DuplicateNode(BarrierCoordinator.Data, Controller.NodeInfo) - Constructor for exception akka.remote.testconductor.BarrierCoordinator.DuplicateNode
 
DuplicateNode$() - Constructor for class akka.remote.testconductor.BarrierCoordinator.DuplicateNode$
 

E

encode(ChannelHandlerContext, Channel, Object) - Method in class akka.remote.testconductor.MsgEncoder
 
encode(ChannelHandlerContext, Channel, Object) - Method in class akka.remote.testconductor.ProtobufEncoder
 
enter(Seq<String>) - Method in interface akka.remote.testconductor.Player
Enter the named barriers, one after the other, in the order given.
enter(Timeout, Seq<String>) - Method in interface akka.remote.testconductor.Player
Enter the named barriers, one after the other, in the order given.
Enter_VALUE - Static variable in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
Enter = 1;
EnterBarrier - Class in akka.remote.testconductor
 
EnterBarrier(String, Option<FiniteDuration>) - Constructor for class akka.remote.testconductor.EnterBarrier
 
enterBarrier(Seq<String>) - Method in class akka.remote.testkit.MultiNodeSpec
Enter the named barriers in the order given.
EnterBarrier$ - Class in akka.remote.testconductor
 
EnterBarrier$() - Constructor for class akka.remote.testconductor.EnterBarrier$
 
exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class akka.remote.testconductor.PlayerHandler
 
exit(RoleName, int) - Method in interface akka.remote.testconductor.Conductor
Tell the remote node to shut itself down using System.exit with the given exitValue.
Exit_VALUE - Static variable in enum akka.remote.testconductor.TestConductorProtocol.FailType
Exit = 4;
EXITVALUE_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 

F

Fail_VALUE - Static variable in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
Fail = 2;
failBarrier(BarrierCoordinator.Data) - Method in class akka.remote.testconductor.Controller
 
FailBarrier - Class in akka.remote.testconductor
 
FailBarrier(String) - Constructor for class akka.remote.testconductor.FailBarrier
 
FailBarrier$ - Class in akka.remote.testconductor
 
FailBarrier$() - Constructor for class akka.remote.testconductor.FailBarrier$
 
failed() - Method in class akka.remote.testconductor.BarrierCoordinator
 
Failed$() - Constructor for class akka.remote.testconductor.ClientFSM.Failed$
 
Failed_VALUE - Static variable in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
Failed = 4;
FailedBarrier(BarrierCoordinator.Data) - Constructor for exception akka.remote.testconductor.BarrierCoordinator.FailedBarrier
 
FailedBarrier$() - Constructor for class akka.remote.testconductor.BarrierCoordinator.FailedBarrier$
 
FAILURE_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
FAILURE_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
fsm() - Method in class akka.remote.testconductor.Controller.NodeInfo
 

G

generation() - Method in class akka.remote.testconductor.Controller
 
get(ActorSystem) - Method in class akka.remote.testconductor.TestConductor$
Java API: retrieve the TestConductor extension for the given system.
get(ActorSystem) - Static method in class akka.remote.testconductor.TestConductor
Java API: retrieve the TestConductor extension for the given system.
getAddr() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
optional .Address addr = 2;
getAddr() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
optional .Address addr = 2;
getAddr() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressRequestOrBuilder
optional .Address addr = 2;
getAddr() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .AddressRequest addr = 5;
getAddr() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional .AddressRequest addr = 5;
getAddr() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional .AddressRequest addr = 5;
getAddrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
optional .Address addr = 2;
getAddrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .AddressRequest addr = 5;
GetAddress - Class in akka.remote.testconductor
 
GetAddress(RoleName) - Constructor for class akka.remote.testconductor.GetAddress
 
getAddress() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required .Address address = 2;
getAddress() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
required .Address address = 2;
getAddress() - Method in interface akka.remote.testconductor.TestConductorProtocol.HelloOrBuilder
required .Address address = 2;
getAddress() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional .Address address = 3;
getAddress() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
optional .Address address = 3;
getAddress() - Method in interface akka.remote.testconductor.TestConductorProtocol.InjectFailureOrBuilder
optional .Address address = 3;
GetAddress$ - Class in akka.remote.testconductor
 
GetAddress$() - Constructor for class akka.remote.testconductor.GetAddress$
 
getAddressBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required .Address address = 2;
getAddressBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional .Address address = 3;
getAddressFor(RoleName) - Method in interface akka.remote.testconductor.Player
Query remote transport address of named node.
getAddressOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required .Address address = 2;
getAddressOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
required .Address address = 2;
getAddressOrBuilder() - Method in interface akka.remote.testconductor.TestConductorProtocol.HelloOrBuilder
required .Address address = 2;
getAddressOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional .Address address = 3;
getAddressOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
optional .Address address = 3;
getAddressOrBuilder() - Method in interface akka.remote.testconductor.TestConductorProtocol.InjectFailureOrBuilder
optional .Address address = 3;
getAddrOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
optional .Address addr = 2;
getAddrOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
optional .Address addr = 2;
getAddrOrBuilder() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressRequestOrBuilder
optional .Address addr = 2;
getAddrOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .AddressRequest addr = 5;
getAddrOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional .AddressRequest addr = 5;
getAddrOrBuilder() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional .AddressRequest addr = 5;
getAddrString(Channel) - Method in class akka.remote.testconductor.RemoteConnection$
 
getAddrString(Channel) - Static method in class akka.remote.testconductor.RemoteConnection
 
getBarrier() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .EnterBarrier barrier = 2;
getBarrier() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional .EnterBarrier barrier = 2;
getBarrier() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional .EnterBarrier barrier = 2;
getBarrierBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .EnterBarrier barrier = 2;
getBarrierOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .EnterBarrier barrier = 2;
getBarrierOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional .EnterBarrier barrier = 2;
getBarrierOrBuilder() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional .EnterBarrier barrier = 2;
getDeadline(Option<FiniteDuration>) - Method in class akka.remote.testconductor.BarrierCoordinator
 
getDefaultInstance() - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
getDefaultInstance() - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
getDefaultInstance() - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
getDefaultInstance() - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
getDefaultInstance() - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
getDefaultInstance() - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
getDefaultInstanceForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
 
getDefaultInstanceForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
 
getDefaultInstanceForType() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
 
getDefaultInstanceForType() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
getDefaultInstanceForType() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
 
getDefaultInstanceForType() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
getDefaultInstanceForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
 
getDefaultInstanceForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
getDefaultInstanceForType() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
 
getDefaultInstanceForType() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
getDefaultInstanceForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
 
getDefaultInstanceForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
getDescriptor() - Static method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
 
getDescriptor() - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
getDescriptor() - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
 
getDescriptor() - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
getDescriptor() - Static method in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
 
getDescriptor() - Static method in enum akka.remote.testconductor.TestConductorProtocol.Direction
 
getDescriptor() - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
 
getDescriptor() - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
getDescriptor() - Static method in enum akka.remote.testconductor.TestConductorProtocol.FailType
 
getDescriptor() - Static method in class akka.remote.testconductor.TestConductorProtocol
 
getDescriptor() - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
 
getDescriptor() - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
getDescriptor() - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
 
getDescriptor() - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
getDescriptor() - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
 
getDescriptor() - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
getDescriptorForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
 
getDescriptorForType() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
 
getDescriptorForType() - Method in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
 
getDescriptorForType() - Method in enum akka.remote.testconductor.TestConductorProtocol.Direction
 
getDescriptorForType() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
 
getDescriptorForType() - Method in enum akka.remote.testconductor.TestConductorProtocol.FailType
 
getDescriptorForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
 
getDescriptorForType() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
 
getDescriptorForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
 
getDirection() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional .Direction direction = 2;
getDirection() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
optional .Direction direction = 2;
getDirection() - Method in interface akka.remote.testconductor.TestConductorProtocol.InjectFailureOrBuilder
optional .Direction direction = 2;
getDone() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional string done = 4;
getDone() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional string done = 4;
getDone() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional string done = 4;
getDoneBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional string done = 4;
getDoneBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional string done = 4;
getDoneBytes() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional string done = 4;
getExitValue() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional int32 exitValue = 7;
getExitValue() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
optional int32 exitValue = 7;
getExitValue() - Method in interface akka.remote.testconductor.TestConductorProtocol.InjectFailureOrBuilder
optional int32 exitValue = 7;
getFailure() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
required .FailType failure = 1;
getFailure() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
required .FailType failure = 1;
getFailure() - Method in interface akka.remote.testconductor.TestConductorProtocol.InjectFailureOrBuilder
required .FailType failure = 1;
getFailure() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .InjectFailure failure = 3;
getFailure() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional .InjectFailure failure = 3;
getFailure() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional .InjectFailure failure = 3;
getFailureBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .InjectFailure failure = 3;
getFailureOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .InjectFailure failure = 3;
getFailureOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional .InjectFailure failure = 3;
getFailureOrBuilder() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional .InjectFailure failure = 3;
getHello() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .Hello hello = 1;
getHello() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional .Hello hello = 1;
getHello() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional .Hello hello = 1;
getHelloBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .Hello hello = 1;
getHelloOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .Hello hello = 1;
getHelloOrBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional .Hello hello = 1;
getHelloOrBuilder() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional .Hello hello = 1;
getHost() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string host = 3;
getHost() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
required string host = 3;
getHost() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressOrBuilder
required string host = 3;
getHostBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string host = 3;
getHostBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
required string host = 3;
getHostBytes() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressOrBuilder
required string host = 3;
getInstance() - Method in class akka.remote.testconductor.Done$
 
getInstance() - Static method in class akka.remote.testconductor.Done
 
getName() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
required string name = 1;
getName() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
required string name = 1;
getName() - Method in interface akka.remote.testconductor.TestConductorProtocol.EnterBarrierOrBuilder
required string name = 1;
getName() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required string name = 1;
getName() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
required string name = 1;
getName() - Method in interface akka.remote.testconductor.TestConductorProtocol.HelloOrBuilder
required string name = 1;
getNameBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
required string name = 1;
getNameBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
required string name = 1;
getNameBytes() - Method in interface akka.remote.testconductor.TestConductorProtocol.EnterBarrierOrBuilder
required string name = 1;
getNameBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required string name = 1;
getNameBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
required string name = 1;
getNameBytes() - Method in interface akka.remote.testconductor.TestConductorProtocol.HelloOrBuilder
required string name = 1;
getNode() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
required string node = 1;
getNode() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
required string node = 1;
getNode() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressRequestOrBuilder
required string node = 1;
getNodeBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
required string node = 1;
getNodeBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
required string node = 1;
getNodeBytes() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressRequestOrBuilder
required string node = 1;
getNodes() - Method in interface akka.remote.testconductor.Conductor
Obtain the list of remote host names currently registered.
GetNodes$() - Constructor for class akka.remote.testconductor.Controller.GetNodes$
 
getNumber() - Method in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
 
getNumber() - Method in enum akka.remote.testconductor.TestConductorProtocol.Direction
 
getNumber() - Method in enum akka.remote.testconductor.TestConductorProtocol.FailType
 
getOp() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
required .BarrierOp op = 2;
getOp() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
required .BarrierOp op = 2;
getOp() - Method in interface akka.remote.testconductor.TestConductorProtocol.EnterBarrierOrBuilder
required .BarrierOp op = 2;
getParserForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
 
getParserForType() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
getParserForType() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
getParserForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
getParserForType() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
getParserForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
getPipeline() - Method in class akka.remote.testconductor.TestConductorPipelineFactory
 
getPort() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required int32 port = 4;
getPort() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
required int32 port = 4;
getPort() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressOrBuilder
required int32 port = 4;
getProtocol() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string protocol = 1;
getProtocol() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
required string protocol = 1;
getProtocol() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressOrBuilder
required string protocol = 1;
getProtocolBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string protocol = 1;
getProtocolBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
required string protocol = 1;
getProtocolBytes() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressOrBuilder
required string protocol = 1;
getRateMBit() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional float rateMBit = 6;
getRateMBit() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
optional float rateMBit = 6;
getRateMBit() - Method in interface akka.remote.testconductor.TestConductorProtocol.InjectFailureOrBuilder
optional float rateMBit = 6;
getSerializedSize() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
 
getSerializedSize() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
getSerializedSize() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
getSerializedSize() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
getSerializedSize() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
getSerializedSize() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
GetSockAddr$() - Constructor for class akka.remote.testconductor.Controller.GetSockAddr$
 
getSystem() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string system = 2;
getSystem() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
required string system = 2;
getSystem() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressOrBuilder
required string system = 2;
getSystemBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string system = 2;
getSystemBytes() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
required string system = 2;
getSystemBytes() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressOrBuilder
required string system = 2;
getTimeout() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
optional int64 timeout = 3;
getTimeout() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
optional int64 timeout = 3;
getTimeout() - Method in interface akka.remote.testconductor.TestConductorProtocol.EnterBarrierOrBuilder
optional int64 timeout = 3;
getUnknownFields() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
 
getUnknownFields() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
getUnknownFields() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
getUnknownFields() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
getUnknownFields() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
getUnknownFields() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
getValueDescriptor() - Method in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
 
getValueDescriptor() - Method in enum akka.remote.testconductor.TestConductorProtocol.Direction
 
getValueDescriptor() - Method in enum akka.remote.testconductor.TestConductorProtocol.FailType
 

H

handleBarrier(BarrierCoordinator.Data) - Method in class akka.remote.testconductor.BarrierCoordinator
 
handler() - Method in class akka.remote.testconductor.ClientFSM
 
hasAddr() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
optional .Address addr = 2;
hasAddr() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
optional .Address addr = 2;
hasAddr() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressRequestOrBuilder
optional .Address addr = 2;
hasAddr() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .AddressRequest addr = 5;
hasAddr() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional .AddressRequest addr = 5;
hasAddr() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional .AddressRequest addr = 5;
hasAddress() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required .Address address = 2;
hasAddress() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
required .Address address = 2;
hasAddress() - Method in interface akka.remote.testconductor.TestConductorProtocol.HelloOrBuilder
required .Address address = 2;
hasAddress() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional .Address address = 3;
hasAddress() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
optional .Address address = 3;
hasAddress() - Method in interface akka.remote.testconductor.TestConductorProtocol.InjectFailureOrBuilder
optional .Address address = 3;
hasBarrier() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .EnterBarrier barrier = 2;
hasBarrier() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional .EnterBarrier barrier = 2;
hasBarrier() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional .EnterBarrier barrier = 2;
hasDirection() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional .Direction direction = 2;
hasDirection() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
optional .Direction direction = 2;
hasDirection() - Method in interface akka.remote.testconductor.TestConductorProtocol.InjectFailureOrBuilder
optional .Direction direction = 2;
hasDone() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional string done = 4;
hasDone() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional string done = 4;
hasDone() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional string done = 4;
hasExitValue() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional int32 exitValue = 7;
hasExitValue() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
optional int32 exitValue = 7;
hasExitValue() - Method in interface akka.remote.testconductor.TestConductorProtocol.InjectFailureOrBuilder
optional int32 exitValue = 7;
hasFailure() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
required .FailType failure = 1;
hasFailure() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
required .FailType failure = 1;
hasFailure() - Method in interface akka.remote.testconductor.TestConductorProtocol.InjectFailureOrBuilder
required .FailType failure = 1;
hasFailure() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .InjectFailure failure = 3;
hasFailure() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional .InjectFailure failure = 3;
hasFailure() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional .InjectFailure failure = 3;
hasHello() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .Hello hello = 1;
hasHello() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
optional .Hello hello = 1;
hasHello() - Method in interface akka.remote.testconductor.TestConductorProtocol.WrapperOrBuilder
optional .Hello hello = 1;
hasHost() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string host = 3;
hasHost() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
required string host = 3;
hasHost() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressOrBuilder
required string host = 3;
hasName() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
required string name = 1;
hasName() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
required string name = 1;
hasName() - Method in interface akka.remote.testconductor.TestConductorProtocol.EnterBarrierOrBuilder
required string name = 1;
hasName() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required string name = 1;
hasName() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
required string name = 1;
hasName() - Method in interface akka.remote.testconductor.TestConductorProtocol.HelloOrBuilder
required string name = 1;
hasNode() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
required string node = 1;
hasNode() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
required string node = 1;
hasNode() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressRequestOrBuilder
required string node = 1;
hasOp() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
required .BarrierOp op = 2;
hasOp() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
required .BarrierOp op = 2;
hasOp() - Method in interface akka.remote.testconductor.TestConductorProtocol.EnterBarrierOrBuilder
required .BarrierOp op = 2;
hasPort() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required int32 port = 4;
hasPort() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
required int32 port = 4;
hasPort() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressOrBuilder
required int32 port = 4;
hasProtocol() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string protocol = 1;
hasProtocol() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
required string protocol = 1;
hasProtocol() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressOrBuilder
required string protocol = 1;
hasRateMBit() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional float rateMBit = 6;
hasRateMBit() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
optional float rateMBit = 6;
hasRateMBit() - Method in interface akka.remote.testconductor.TestConductorProtocol.InjectFailureOrBuilder
optional float rateMBit = 6;
hasSystem() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string system = 2;
hasSystem() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
required string system = 2;
hasSystem() - Method in interface akka.remote.testconductor.TestConductorProtocol.AddressOrBuilder
required string system = 2;
hasTimeout() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
optional int64 timeout = 3;
hasTimeout() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
optional int64 timeout = 3;
hasTimeout() - Method in interface akka.remote.testconductor.TestConductorProtocol.EnterBarrierOrBuilder
optional int64 timeout = 3;
Hello - Class in akka.remote.testconductor
First message of connection sets names straight.
Hello(String, Address) - Constructor for class akka.remote.testconductor.Hello
 
Hello$ - Class in akka.remote.testconductor
 
Hello$() - Constructor for class akka.remote.testconductor.Hello$
 
HELLO_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
HOST_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Address
 

I

Idle$() - Constructor for class akka.remote.testconductor.BarrierCoordinator.Idle$
 
Initial$() - Constructor for class akka.remote.testconductor.ServerFSM.Initial$
 
initialParticipants() - Method in class akka.remote.testkit.MultiNodeSpec
TO BE DEFINED BY USER: Defines the number of participants required for starting the test.
injectDeployments(ActorSystem, RoleName) - Method in class akka.remote.testkit.MultiNodeSpec
 
internalGetFieldAccessorTable() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
 
internalGetFieldAccessorTable() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
 
internalGetFieldAccessorTable() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
 
internalGetFieldAccessorTable() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
internalGetFieldAccessorTable() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
 
internalGetFieldAccessorTable() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
internalGetFieldAccessorTable() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
 
internalGetFieldAccessorTable() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
internalGetFieldAccessorTable() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
 
internalGetFieldAccessorTable() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
internalGetFieldAccessorTable() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
 
internalGetFieldAccessorTable() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
internalGetValueMap() - Static method in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
 
internalGetValueMap() - Static method in enum akka.remote.testconductor.TestConductorProtocol.Direction
 
internalGetValueMap() - Static method in enum akka.remote.testconductor.TestConductorProtocol.FailType
 
isInitialized() - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
 
isInitialized() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
 
isInitialized() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
 
isInitialized() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
isInitialized() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
 
isInitialized() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
isInitialized() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
 
isInitialized() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
isInitialized() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
 
isInitialized() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
isInitialized() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
 
isInitialized() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
isNode(Seq<RoleName>) - Method in class akka.remote.testkit.MultiNodeSpec
Verify that the running node matches one of the given nodes

L

log() - Method in class akka.remote.testkit.MultiNodeSpec
 
lookup() - Method in class akka.remote.testconductor.TestConductor$
 
lookup() - Static method in class akka.remote.testconductor.TestConductor
 

M

maxNodes() - Method in class akka.remote.testkit.MultiNodeSpec$
Number of nodes node taking part in this test.
maxNodes() - Static method in class akka.remote.testkit.MultiNodeSpec
Number of nodes node taking part in this test.
mergeAddr(TestConductorProtocol.Address) - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
optional .Address addr = 2;
mergeAddr(TestConductorProtocol.AddressRequest) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .AddressRequest addr = 5;
mergeAddress(TestConductorProtocol.Address) - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required .Address address = 2;
mergeAddress(TestConductorProtocol.Address) - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional .Address address = 3;
mergeBarrier(TestConductorProtocol.EnterBarrier) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .EnterBarrier barrier = 2;
mergeFailure(TestConductorProtocol.InjectFailure) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .InjectFailure failure = 3;
mergeFrom(Message) - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
 
mergeFrom(TestConductorProtocol.Address) - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
 
mergeFrom(Message) - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
 
mergeFrom(TestConductorProtocol.AddressRequest) - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
 
mergeFrom(Message) - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
 
mergeFrom(TestConductorProtocol.EnterBarrier) - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
 
mergeFrom(Message) - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
 
mergeFrom(TestConductorProtocol.Hello) - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
 
mergeFrom(Message) - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
 
mergeFrom(TestConductorProtocol.InjectFailure) - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
 
mergeFrom(Message) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
 
mergeFrom(TestConductorProtocol.Wrapper) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
 
mergeHello(TestConductorProtocol.Hello) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .Hello hello = 1;
messageReceived(ChannelHandlerContext, MessageEvent) - Method in class akka.remote.testconductor.ConductorHandler
 
messageReceived(ChannelHandlerContext, MessageEvent) - Method in class akka.remote.testconductor.PlayerHandler
 
MODULE$ - Static variable in class akka.remote.testconductor.AddressReply$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.BarrierCoordinator$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.BarrierCoordinator.BarrierEmpty$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.BarrierCoordinator.BarrierTimeout$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.BarrierCoordinator.ClientLost$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.BarrierCoordinator.Data$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.BarrierCoordinator.DuplicateNode$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.BarrierCoordinator.FailedBarrier$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.BarrierCoordinator.Idle$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.BarrierCoordinator.RemoveClient$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.BarrierCoordinator.Waiting$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.BarrierCoordinator.WrongBarrier$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.BarrierResult$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Client$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ClientFSM$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ClientFSM.AwaitDone$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ClientFSM.Connected$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ClientFSM.Connecting$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ClientFSM.ConnectionFailure$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ClientFSM.Data$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ClientFSM.Disconnected$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ClientFSM.Failed$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Controller$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Controller.ClientDisconnected$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Controller.CreateServerFSM$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Controller.GetNodes$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Controller.GetSockAddr$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Controller.NodeInfo$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Disconnect$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.DisconnectMsg$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Done$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.EnterBarrier$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.FailBarrier$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.GetAddress$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Hello$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.RemoteConnection$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Remove$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.RoleName$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Server$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ServerFSM$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ServerFSM.Initial$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ServerFSM.Ready$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Terminate$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.TerminateMsg$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.TestConductor$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.Throttle$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ThrottleMsg$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ToClient$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testconductor.ToServer$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.remote.testkit.MultiNodeSpec$
Static reference to the singleton instance of this Scala object.
msg() - Method in exception akka.remote.testconductor.BarrierCoordinator.BarrierEmpty
 
msg() - Method in exception akka.remote.testconductor.ClientFSM.ConnectionFailure
 
msg() - Method in class akka.remote.testconductor.ToClient
 
msg() - Method in class akka.remote.testconductor.ToServer
 
MsgDecoder - Class in akka.remote.testconductor
 
MsgDecoder() - Constructor for class akka.remote.testconductor.MsgDecoder
 
MsgEncoder - Class in akka.remote.testconductor
 
MsgEncoder() - Constructor for class akka.remote.testconductor.MsgEncoder
 
MultiNodeConfig - Class in akka.remote.testkit
Configure the role names and participants of the test, including configuration settings.
MultiNodeConfig() - Constructor for class akka.remote.testkit.MultiNodeConfig
 
MultiNodeSpec - Class in akka.remote.testkit
Note: To be able to run tests with everything ignored or excluded by tags you must not use testconductor, or helper methods that use testconductor, from the constructor of your test class.
MultiNodeSpec(RoleName, ActorSystem, Seq<RoleName>, Function1<RoleName, Seq<String>>) - Constructor for class akka.remote.testkit.MultiNodeSpec
 
MultiNodeSpec(MultiNodeConfig) - Constructor for class akka.remote.testkit.MultiNodeSpec
 
MultiNodeSpec$ - Class in akka.remote.testkit
 
MultiNodeSpec$() - Constructor for class akka.remote.testkit.MultiNodeSpec$
 
MultiNodeSpec.AwaitHelper<T> - Class in akka.remote.testkit
 
multiNodeSpecAfterAll() - Method in class akka.remote.testkit.MultiNodeSpec
 
multiNodeSpecAfterAll() - Method in interface akka.remote.testkit.MultiNodeSpecCallbacks
Call this after the all test cases have run.
multiNodeSpecBeforeAll() - Method in class akka.remote.testkit.MultiNodeSpec
 
multiNodeSpecBeforeAll() - Method in interface akka.remote.testkit.MultiNodeSpecCallbacks
Call this before the start of the test run.
MultiNodeSpecCallbacks - Interface in akka.remote.testkit
Use this to hook MultiNodeSpec into your test framework lifecycle, either by having your test extend MultiNodeSpec and call these methods or by creating a trait that calls them and then mixing that trait with your test together with MultiNodeSpec.
muteDeadLetters(Seq<Class<?>>, ActorSystem) - Method in class akka.remote.testkit.MultiNodeSpec
 
myAddress() - Method in class akka.remote.testkit.MultiNodeSpec
 
myself() - Method in class akka.remote.testkit.MultiNodeConfig
 
myself() - Method in class akka.remote.testkit.MultiNodeSpec
 

N

name() - Method in class akka.remote.testconductor.BarrierCoordinator.RemoveClient
 
name() - Method in class akka.remote.testconductor.BarrierResult
 
name() - Method in class akka.remote.testconductor.Controller.ClientDisconnected
 
name() - Method in class akka.remote.testconductor.Controller.NodeInfo
 
name() - Method in class akka.remote.testconductor.EnterBarrier
 
name() - Method in class akka.remote.testconductor.FailBarrier
 
name() - Method in class akka.remote.testconductor.Hello
 
name() - Method in class akka.remote.testconductor.RoleName
 
NAME_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
NAME_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Hello
 
NetworkOp - Interface in akka.remote.testconductor
 
newBuilder() - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
newBuilder(TestConductorProtocol.Address) - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
newBuilder() - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
newBuilder(TestConductorProtocol.AddressRequest) - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
newBuilder() - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
newBuilder(TestConductorProtocol.EnterBarrier) - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
newBuilder() - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
newBuilder(TestConductorProtocol.Hello) - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
newBuilder() - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
newBuilder(TestConductorProtocol.InjectFailure) - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
newBuilder() - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
newBuilder(TestConductorProtocol.Wrapper) - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
newBuilderForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.remote.testconductor.TestConductorProtocol.Address
 
newBuilderForType() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
newBuilderForType() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
newBuilderForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
newBuilderForType() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
newBuilderForType() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
nextAttempt() - Method in class akka.remote.testconductor.PlayerHandler
 
node() - Method in class akka.remote.testconductor.AddressReply
 
node() - Method in exception akka.remote.testconductor.BarrierCoordinator.DuplicateNode
 
node() - Method in class akka.remote.testconductor.Disconnect
 
node() - Method in class akka.remote.testconductor.GetAddress
 
node() - Method in class akka.remote.testconductor.Remove
 
node() - Method in class akka.remote.testconductor.Terminate
 
node() - Method in class akka.remote.testconductor.Throttle
 
node(RoleName) - Method in class akka.remote.testkit.MultiNodeSpec
Query the controller for the transport address of the given node (by role name) and return that as an ActorPath for easy composition:
NODE_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
nodeConfig(Seq<RoleName>, Seq<Config>) - Method in class akka.remote.testkit.MultiNodeConfig
Register a config override for a specific participant.
nodeConfig() - Method in class akka.remote.testkit.MultiNodeSpec$
 
nodeConfig() - Static method in class akka.remote.testkit.MultiNodeSpec
 
NodeInfo(RoleName, Address, ActorRef) - Constructor for class akka.remote.testconductor.Controller.NodeInfo
 
NodeInfo$() - Constructor for class akka.remote.testconductor.Controller.NodeInfo$
 
nodes() - Method in class akka.remote.testconductor.Controller
 

O

OP_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 

P

PacketSplitThreshold() - Method in class akka.remote.testconductor.TestConductorExt.Settings
 
parseDelimitedFrom(InputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
parseDelimitedFrom(InputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
parseDelimitedFrom(InputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
parseDelimitedFrom(InputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
parseDelimitedFrom(InputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
parseDelimitedFrom(InputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
parseFrom(ByteString) - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
parseFrom(byte[]) - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
parseFrom(InputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
parseFrom(CodedInputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Address
 
parseFrom(ByteString) - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
parseFrom(byte[]) - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
parseFrom(InputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
parseFrom(CodedInputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
parseFrom(ByteString) - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
parseFrom(byte[]) - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
parseFrom(InputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
parseFrom(CodedInputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
parseFrom(ByteString) - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
parseFrom(byte[]) - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
parseFrom(InputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
parseFrom(CodedInputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
parseFrom(ByteString) - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
parseFrom(byte[]) - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
parseFrom(InputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
parseFrom(CodedInputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
parseFrom(ByteString) - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
parseFrom(byte[]) - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
parseFrom(InputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
parseFrom(CodedInputStream) - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
PARSER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Address
 
PARSER - Static variable in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
PARSER - Static variable in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
PARSER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Hello
 
PARSER - Static variable in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
PARSER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
passThrough(RoleName, RoleName, ThrottlerTransportAdapter.Direction) - Method in interface akka.remote.testconductor.Conductor
Switch the Netty pipeline of the remote support into pass through mode for sending and/or receiving.
Player - Interface in akka.remote.testconductor
The Player is the client component of the TestConductorExt extension.
PlayerHandler - Class in akka.remote.testconductor
This handler only forwards messages received from the conductor to the ClientFSM.
PlayerHandler(InetSocketAddress, int, FiniteDuration, int, ActorRef, LoggingAdapter, Scheduler, ExecutionContext) - Constructor for class akka.remote.testconductor.PlayerHandler
 
PORT_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Address
 
postRestart(Throwable) - Method in class akka.remote.testconductor.BarrierCoordinator
 
postStop() - Method in class akka.remote.testconductor.Controller
 
preRestart(Throwable, Option<Object>) - Method in class akka.remote.testconductor.BarrierCoordinator
 
ProtobufDecoder - Class in akka.remote.testconductor
INTERNAL API.
ProtobufDecoder(Message) - Constructor for class akka.remote.testconductor.ProtobufDecoder
 
ProtobufEncoder - Class in akka.remote.testconductor
INTERNAL API.
ProtobufEncoder() - Constructor for class akka.remote.testconductor.ProtobufEncoder
 
PROTOCOL_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Address
 

Q

QueryTimeout() - Method in class akka.remote.testconductor.TestConductorExt.Settings
 

R

rateMBit() - Method in class akka.remote.testconductor.Throttle
 
rateMBit() - Method in class akka.remote.testconductor.ThrottleMsg
 
RATEMBIT_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
Ready$() - Constructor for class akka.remote.testconductor.ServerFSM.Ready$
 
receive() - Method in class akka.remote.testconductor.Controller
 
Receive_VALUE - Static variable in enum akka.remote.testconductor.TestConductorProtocol.Direction
Receive = 2;
ReconnectBackoff() - Method in class akka.remote.testconductor.TestConductorExt.Settings
 
registerAllExtensions(ExtensionRegistry) - Static method in class akka.remote.testconductor.TestConductorProtocol
 
RemoteConnection - Class in akka.remote.testconductor
INTERNAL API.
RemoteConnection() - Constructor for class akka.remote.testconductor.RemoteConnection
 
RemoteConnection$ - Class in akka.remote.testconductor
INTERNAL API.
RemoteConnection$() - Constructor for class akka.remote.testconductor.RemoteConnection$
 
Remove - Class in akka.remote.testconductor
 
Remove(RoleName) - Constructor for class akka.remote.testconductor.Remove
 
Remove$ - Class in akka.remote.testconductor
 
Remove$() - Constructor for class akka.remote.testconductor.Remove$
 
RemoveClient(RoleName) - Constructor for class akka.remote.testconductor.BarrierCoordinator.RemoveClient
 
RemoveClient$() - Constructor for class akka.remote.testconductor.BarrierCoordinator.RemoveClient$
 
removeNode(RoleName) - Method in interface akka.remote.testconductor.Conductor
Remove a remote host from the list, so that the remaining nodes may still pass subsequent barriers.
requireTestConductorTranport() - Method in interface akka.remote.testconductor.Conductor
 
Role - Interface in akka.remote.testconductor
INTERNAL API.
role(String) - Method in class akka.remote.testkit.MultiNodeConfig
Construct a RoleName and return it, to be used as an identifier in the test.
RoleName - Class in akka.remote.testconductor
 
RoleName(String) - Constructor for class akka.remote.testconductor.RoleName
 
roleName() - Method in class akka.remote.testconductor.ServerFSM
 
RoleName$ - Class in akka.remote.testconductor
 
RoleName$() - Constructor for class akka.remote.testconductor.RoleName$
 
roles() - Method in class akka.remote.testkit.MultiNodeConfig
 
roles() - Method in class akka.remote.testkit.MultiNodeSpec
All registered roles
runningOp() - Method in class akka.remote.testconductor.ClientFSM.Data
 
runOn(Seq<RoleName>, Function0<BoxedUnit>) - Method in class akka.remote.testkit.MultiNodeSpec
Execute the given block of code only on the given nodes (names according to the roleMap).

S

selfIndex() - Method in class akka.remote.testkit.MultiNodeSpec$
Index of this node in the roles sequence.
selfIndex() - Static method in class akka.remote.testkit.MultiNodeSpec
Index of this node in the roles sequence.
selfName() - Method in class akka.remote.testkit.MultiNodeSpec$
Name (or IP address; must be resolvable using InetAddress.getByName) of the host this node is running on.
selfName() - Static method in class akka.remote.testkit.MultiNodeSpec
Name (or IP address; must be resolvable using InetAddress.getByName) of the host this node is running on.
selfPort() - Method in class akka.remote.testkit.MultiNodeSpec$
Port number of this node.
selfPort() - Static method in class akka.remote.testkit.MultiNodeSpec
Port number of this node.
Send_VALUE - Static variable in enum akka.remote.testconductor.TestConductorProtocol.Direction
Send = 1;
Server - Class in akka.remote.testconductor
INTERNAL API.
Server() - Constructor for class akka.remote.testconductor.Server
 
Server$ - Class in akka.remote.testconductor
INTERNAL API.
Server$() - Constructor for class akka.remote.testconductor.Server$
 
ServerFSM - Class in akka.remote.testconductor
The server part of each client connection is represented by a ServerFSM.
ServerFSM(ActorRef, Channel) - Constructor for class akka.remote.testconductor.ServerFSM
 
ServerFSM$ - Class in akka.remote.testconductor
INTERNAL API.
ServerFSM$() - Constructor for class akka.remote.testconductor.ServerFSM$
 
ServerFSM.Initial$ - Class in akka.remote.testconductor
 
ServerFSM.Ready$ - Class in akka.remote.testconductor
 
ServerFSM.State - Interface in akka.remote.testconductor
 
serverName() - Method in class akka.remote.testkit.MultiNodeSpec$
Name (or IP address; must be resolvable using InetAddress.getByName) of the host that the server node is running on.
serverName() - Static method in class akka.remote.testkit.MultiNodeSpec
Name (or IP address; must be resolvable using InetAddress.getByName) of the host that the server node is running on.
ServerOp - Interface in akka.remote.testconductor
 
serverPort() - Method in class akka.remote.testkit.MultiNodeSpec$
Port number of the node that's running the server system.
serverPort() - Static method in class akka.remote.testkit.MultiNodeSpec
Port number of the node that's running the server system.
ServerSocketWorkerPoolSize() - Method in class akka.remote.testconductor.TestConductorExt.Settings
 
setAddr(TestConductorProtocol.Address) - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
optional .Address addr = 2;
setAddr(TestConductorProtocol.Address.Builder) - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
optional .Address addr = 2;
setAddr(TestConductorProtocol.AddressRequest) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .AddressRequest addr = 5;
setAddr(TestConductorProtocol.AddressRequest.Builder) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .AddressRequest addr = 5;
setAddress(TestConductorProtocol.Address) - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required .Address address = 2;
setAddress(TestConductorProtocol.Address.Builder) - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required .Address address = 2;
setAddress(TestConductorProtocol.Address) - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional .Address address = 3;
setAddress(TestConductorProtocol.Address.Builder) - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional .Address address = 3;
setBarrier(TestConductorProtocol.EnterBarrier) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .EnterBarrier barrier = 2;
setBarrier(TestConductorProtocol.EnterBarrier.Builder) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .EnterBarrier barrier = 2;
setDirection(TestConductorProtocol.Direction) - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional .Direction direction = 2;
setDone(String) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional string done = 4;
setDoneBytes(ByteString) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional string done = 4;
setExitValue(int) - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional int32 exitValue = 7;
setFailure(TestConductorProtocol.FailType) - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
required .FailType failure = 1;
setFailure(TestConductorProtocol.InjectFailure) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .InjectFailure failure = 3;
setFailure(TestConductorProtocol.InjectFailure.Builder) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .InjectFailure failure = 3;
setHello(TestConductorProtocol.Hello) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .Hello hello = 1;
setHello(TestConductorProtocol.Hello.Builder) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper.Builder
optional .Hello hello = 1;
setHost(String) - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string host = 3;
setHostBytes(ByteString) - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string host = 3;
setName(String) - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
required string name = 1;
setName(String) - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required string name = 1;
setNameBytes(ByteString) - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
required string name = 1;
setNameBytes(ByteString) - Method in class akka.remote.testconductor.TestConductorProtocol.Hello.Builder
required string name = 1;
setNode(String) - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
required string node = 1;
setNodeBytes(ByteString) - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest.Builder
required string node = 1;
setOp(TestConductorProtocol.BarrierOp) - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
required .BarrierOp op = 2;
setPort(int) - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required int32 port = 4;
setProtocol(String) - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string protocol = 1;
setProtocolBytes(ByteString) - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string protocol = 1;
setRateMBit(float) - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure.Builder
optional float rateMBit = 6;
setSystem(String) - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string system = 2;
setSystemBytes(ByteString) - Method in class akka.remote.testconductor.TestConductorProtocol.Address.Builder
required string system = 2;
setTimeout(long) - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier.Builder
optional int64 timeout = 3;
settings() - Method in class akka.remote.testconductor.ClientFSM
 
settings() - Method in class akka.remote.testconductor.Controller
 
Settings() - Method in class akka.remote.testconductor.TestConductorExt
 
Settings() - Constructor for class akka.remote.testconductor.TestConductorExt.Settings
 
shutdown(RoleName) - Method in interface akka.remote.testconductor.Conductor
Tell the actor system at the remote node to shut itself down.
shutdown(RoleName, boolean) - Method in interface akka.remote.testconductor.Conductor
Tell the actor system at the remote node to shut itself down without awaiting termination of remote-deployed children.
shutdown(Channel) - Method in class akka.remote.testconductor.RemoteConnection$
 
shutdown(Channel) - Static method in class akka.remote.testconductor.RemoteConnection
 
Shutdown_VALUE - Static variable in enum akka.remote.testconductor.TestConductorProtocol.FailType
Shutdown = 5;
ShutdownAbrupt_VALUE - Static variable in enum akka.remote.testconductor.TestConductorProtocol.FailType
ShutdownAbrupt = 6;
shutdownOrExit() - Method in class akka.remote.testconductor.Terminate
 
shutdownOrExit() - Method in class akka.remote.testconductor.TerminateMsg
 
shutdownTimeout() - Method in class akka.remote.testkit.MultiNodeSpec
 
sockAddr() - Method in interface akka.remote.testconductor.Conductor
Obtain the port to which the controller&rsquo;s socket is actually bound.
startClient(RoleName, InetSocketAddress) - Method in interface akka.remote.testconductor.Player
Connect to the conductor on the given port (the host is taken from setting akka.testconductor.host).
startController(int, RoleName, InetSocketAddress) - Method in interface akka.remote.testconductor.Conductor
Start the Controller, which in turn will bind to a TCP port as specified in the akka.testconductor.port config property, where 0 denotes automatic allocation.
startNewSystem() - Method in class akka.remote.testkit.MultiNodeSpec
This method starts a new ActorSystem with the same configuration as the previous one on the current node, including deployments.
Succeeded_VALUE - Static variable in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
Succeeded = 3;
success() - Method in class akka.remote.testconductor.BarrierResult
 
supervisorStrategy() - Method in class akka.remote.testconductor.Controller
 
system() - Method in class akka.remote.testconductor.TestConductorExt
 
SYSTEM_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.Address
 

T

target() - Method in class akka.remote.testconductor.Disconnect
 
target() - Method in class akka.remote.testconductor.DisconnectMsg
 
target() - Method in class akka.remote.testconductor.Throttle
 
target() - Method in class akka.remote.testconductor.ThrottleMsg
 
Terminate - Class in akka.remote.testconductor
 
Terminate(RoleName, Either<Object, Object>) - Constructor for class akka.remote.testconductor.Terminate
 
Terminate$ - Class in akka.remote.testconductor
 
Terminate$() - Constructor for class akka.remote.testconductor.Terminate$
 
TerminateMsg - Class in akka.remote.testconductor
 
TerminateMsg(Either<Object, Object>) - Constructor for class akka.remote.testconductor.TerminateMsg
 
TerminateMsg$ - Class in akka.remote.testconductor
 
TerminateMsg$() - Constructor for class akka.remote.testconductor.TerminateMsg$
 
TestConductor - Class in akka.remote.testconductor
Access to the TestConductorExt extension:
TestConductor() - Constructor for class akka.remote.testconductor.TestConductor
 
testConductor() - Method in class akka.remote.testkit.MultiNodeSpec
Access to the barriers, failure injection, etc.
TestConductor$ - Class in akka.remote.testconductor
Access to the TestConductorExt extension:
TestConductor$() - Constructor for class akka.remote.testconductor.TestConductor$
 
TestConductorExt - Class in akka.remote.testconductor
This binds together the Conductor and Player roles inside an Akka Extension.
TestConductorExt(ExtendedActorSystem) - Constructor for class akka.remote.testconductor.TestConductorExt
 
TestConductorExt.Settings - Class in akka.remote.testconductor
 
TestConductorPipelineFactory - Class in akka.remote.testconductor
INTERNAL API.
TestConductorPipelineFactory(ChannelUpstreamHandler) - Constructor for class akka.remote.testconductor.TestConductorPipelineFactory
 
TestConductorProtocol - Class in akka.remote.testconductor
 
TestConductorProtocol.Address - Class in akka.remote.testconductor
Protobuf type Address
TestConductorProtocol.Address.Builder - Class in akka.remote.testconductor
Protobuf type Address
TestConductorProtocol.AddressOrBuilder - Interface in akka.remote.testconductor
 
TestConductorProtocol.AddressRequest - Class in akka.remote.testconductor
Protobuf type AddressRequest
TestConductorProtocol.AddressRequest.Builder - Class in akka.remote.testconductor
Protobuf type AddressRequest
TestConductorProtocol.AddressRequestOrBuilder - Interface in akka.remote.testconductor
 
TestConductorProtocol.BarrierOp - Enum in akka.remote.testconductor
Protobuf enum BarrierOp
TestConductorProtocol.Direction - Enum in akka.remote.testconductor
Protobuf enum Direction
TestConductorProtocol.EnterBarrier - Class in akka.remote.testconductor
Protobuf type EnterBarrier
TestConductorProtocol.EnterBarrier.Builder - Class in akka.remote.testconductor
Protobuf type EnterBarrier
TestConductorProtocol.EnterBarrierOrBuilder - Interface in akka.remote.testconductor
 
TestConductorProtocol.FailType - Enum in akka.remote.testconductor
Protobuf enum FailType
TestConductorProtocol.Hello - Class in akka.remote.testconductor
Protobuf type Hello
TestConductorProtocol.Hello.Builder - Class in akka.remote.testconductor
Protobuf type Hello
TestConductorProtocol.HelloOrBuilder - Interface in akka.remote.testconductor
 
TestConductorProtocol.InjectFailure - Class in akka.remote.testconductor
Protobuf type InjectFailure
TestConductorProtocol.InjectFailure.Builder - Class in akka.remote.testconductor
Protobuf type InjectFailure
TestConductorProtocol.InjectFailureOrBuilder - Interface in akka.remote.testconductor
 
TestConductorProtocol.Wrapper - Class in akka.remote.testconductor
Protobuf type Wrapper
TestConductorProtocol.Wrapper.Builder - Class in akka.remote.testconductor
Protobuf type Wrapper
TestConductorProtocol.WrapperOrBuilder - Interface in akka.remote.testconductor
 
testTransport(boolean) - Method in class akka.remote.testkit.MultiNodeConfig
To be able to use blackhole, passThrough, and throttle you must activate the failure injector and throttler transport adapters by specifying testTransport(on = true) in your MultiNodeConfig.
throttle(RoleName, RoleName, ThrottlerTransportAdapter.Direction, double) - Method in interface akka.remote.testconductor.Conductor
Make the remoting pipeline on the node throttle data sent to or received from the given remote peer.
Throttle - Class in akka.remote.testconductor
 
Throttle(RoleName, RoleName, ThrottlerTransportAdapter.Direction, float) - Constructor for class akka.remote.testconductor.Throttle
 
Throttle$ - Class in akka.remote.testconductor
 
Throttle$() - Constructor for class akka.remote.testconductor.Throttle$
 
Throttle_VALUE - Static variable in enum akka.remote.testconductor.TestConductorProtocol.FailType
Throttle = 1;
ThrottleMsg - Class in akka.remote.testconductor
 
ThrottleMsg(Address, ThrottlerTransportAdapter.Direction, float) - Constructor for class akka.remote.testconductor.ThrottleMsg
 
ThrottleMsg$ - Class in akka.remote.testconductor
 
ThrottleMsg$() - Constructor for class akka.remote.testconductor.ThrottleMsg$
 
timeout() - Method in class akka.remote.testconductor.EnterBarrier
 
TIMEOUT_FIELD_NUMBER - Static variable in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
toBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
 
toBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
toBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
toBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
toBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
toBuilder() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
ToClient - Class in akka.remote.testconductor
 
ToClient(ClientOp) - Constructor for class akka.remote.testconductor.ToClient
 
ToClient$ - Class in akka.remote.testconductor
 
ToClient$() - Constructor for class akka.remote.testconductor.ToClient$
 
ToServer - Class in akka.remote.testconductor
 
ToServer(ServerOp) - Constructor for class akka.remote.testconductor.ToServer
 
ToServer$ - Class in akka.remote.testconductor
 
ToServer$() - Constructor for class akka.remote.testconductor.ToServer$
 
toString() - Method in interface akka.remote.testconductor.BarrierCoordinator.Printer
 
transport() - Method in class akka.remote.testconductor.TestConductorExt
Remote transport used by the actor ref provider.

U

UnconfirmedClientOp - Interface in akka.remote.testconductor
 

V

valueOf(String) - Static method in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
Returns the enum constant of this type with the specified name.
valueOf(int) - Static method in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
 
valueOf(Descriptors.EnumValueDescriptor) - Static method in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
 
valueOf(String) - Static method in enum akka.remote.testconductor.TestConductorProtocol.Direction
Returns the enum constant of this type with the specified name.
valueOf(int) - Static method in enum akka.remote.testconductor.TestConductorProtocol.Direction
 
valueOf(Descriptors.EnumValueDescriptor) - Static method in enum akka.remote.testconductor.TestConductorProtocol.Direction
 
valueOf(String) - Static method in enum akka.remote.testconductor.TestConductorProtocol.FailType
Returns the enum constant of this type with the specified name.
valueOf(int) - Static method in enum akka.remote.testconductor.TestConductorProtocol.FailType
 
valueOf(Descriptors.EnumValueDescriptor) - Static method in enum akka.remote.testconductor.TestConductorProtocol.FailType
 
values() - Static method in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum akka.remote.testconductor.TestConductorProtocol.Direction
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum akka.remote.testconductor.TestConductorProtocol.FailType
Returns an array containing the constants of this enum type, in the order they are declared.
verifySystemShutdown() - Method in class akka.remote.testkit.MultiNodeSpec
Override this and return true to assert that the shutdown of the ActorSystem was done properly.

W

Waiting$() - Constructor for class akka.remote.testconductor.BarrierCoordinator.Waiting$
 
writeComplete(ChannelHandlerContext, WriteCompletionEvent) - Method in class akka.remote.testconductor.PlayerHandler
 
writeReplace() - Method in class akka.remote.testconductor.TestConductorProtocol.Address
 
writeReplace() - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
writeReplace() - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
writeReplace() - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
writeReplace() - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
writeReplace() - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
writeTo(CodedOutputStream) - Method in class akka.remote.testconductor.TestConductorProtocol.Address
 
writeTo(CodedOutputStream) - Method in class akka.remote.testconductor.TestConductorProtocol.AddressRequest
 
writeTo(CodedOutputStream) - Method in class akka.remote.testconductor.TestConductorProtocol.EnterBarrier
 
writeTo(CodedOutputStream) - Method in class akka.remote.testconductor.TestConductorProtocol.Hello
 
writeTo(CodedOutputStream) - Method in class akka.remote.testconductor.TestConductorProtocol.InjectFailure
 
writeTo(CodedOutputStream) - Method in class akka.remote.testconductor.TestConductorProtocol.Wrapper
 
WrongBarrier(String, ActorRef, BarrierCoordinator.Data) - Constructor for exception akka.remote.testconductor.BarrierCoordinator.WrongBarrier
 
WrongBarrier$() - Constructor for class akka.remote.testconductor.BarrierCoordinator.WrongBarrier$
 

_

_client() - Method in interface akka.remote.testconductor.Player
 
_controller() - Method in interface akka.remote.testconductor.Conductor
 
A B C D E F G H I L M N O P Q R S T U V W _ 
Skip navigation links