Interface | Description |
---|---|
AkkaBootstrapTools.ActorSystemExecutorConfiguration |
Configuration interface for
ActorSystem underlying executor. |
Class | Description |
---|---|
AkkaBootstrapTools |
Tools for starting the Actor Systems used to run the JobManager and TaskManager actors.
|
AkkaRpcService |
Akka based
RpcService implementation. |
AkkaRpcServiceConfiguration |
Configuration for the
AkkaRpcService . |
AkkaRpcServiceUtils |
These RPC utilities contain helper methods around RPC use, such as starting an RPC service, or
constructing RPC addresses.
|
AkkaRpcSystem |
RpcSystem implementation based on Akka. |
AkkaRpcSystemLoader |
Loader for the
AkkaRpcSystemLoader . |
CustomSSLEngineProvider |
Extension of the
ConfigSSLEngineProvider to use a FingerprintTrustManagerFactory . |
DeadLettersActor |
Actor which listens to
DeadLetter and responds with a failure if the message
was a RPC. |
EscalatingSupervisorStrategy |
Escalating supervisor strategy.
|
FencedAkkaInvocationHandler<F extends Serializable> |
Fenced extension of the
AkkaInvocationHandler . |
FencedAkkaRpcActor<F extends Serializable,T extends FencedRpcEndpoint<F> & RpcGateway> |
Fenced extension of the
AkkaRpcActor . |
PrioritySettingThreadFactory |
Wrapper around a
ThreadFactory that configures the thread priority. |
PriorityThreadsDispatcher |
Akka dispatcher threads creates threads with configurable priority.
|
RemoteAddressExtension |
ActorSystem Extension used to obtain the Address on which the
given ActorSystem is listening. |
RemoteAddressExtension.RemoteAddressExtensionImpl |
Actual
Extension implementation. |
RobustActorSystem |
ActorSystemImpl } which has a configurable Thread.UncaughtExceptionHandler . |
Enum | Description |
---|---|
AkkaRpcServiceUtils.AkkaProtocol |
Whether to use TCP or encrypted TCP for Akka.
|
ControlMessages |
Control messages for the
AkkaRpcActor . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.