Ack |
Class representing an acknowledgement with selective negative acknowledgements.
|
Ack$ |
|
AckedReceiveBuffer<T extends HasSequenceNumber> |
Implements an immutable receive buffer that buffers incoming messages until they can be safely delivered.
|
AckedReceiveBuffer$ |
|
AckedSendBuffer<T extends HasSequenceNumber> |
Implements an immutable resend buffer that buffers messages until they have been acknowledged.
|
AckedSendBuffer$ |
|
AddressUidExtension |
|
AddressUidExtension$ |
Extension that holds a uid that is assigned as a random Int .
|
AddressUrlEncoder |
INTERNAL API
|
AddressUrlEncoder$ |
INTERNAL API
|
AssociatedEvent |
|
AssociatedEvent$ |
|
AssociationErrorEvent |
|
AssociationErrorEvent$ |
|
BoundAddressesExtension |
|
BoundAddressesExtension$ |
Extension provides access to bound addresses.
|
ContainerFormats |
|
ContainerFormats.Selection |
Protobuf type Selection
|
ContainerFormats.Selection.Builder |
Protobuf type Selection
|
ContainerFormats.SelectionEnvelope |
Protobuf type SelectionEnvelope
|
ContainerFormats.SelectionEnvelope.Builder |
Protobuf type SelectionEnvelope
|
DaemonMsgCreate |
INTERNAL API
|
DaemonMsgCreate$ |
|
DeadlineFailureDetector |
Implementation of failure detector using an absolute timeout of missing heartbeats
to trigger unavailability.
|
DefaultFailureDetectorRegistry<A> |
|
DefaultMessageDispatcher |
INTERNAL API
|
DisassociatedEvent |
|
DisassociatedEvent$ |
|
EndpointActor |
INTERNAL API
|
EndpointManager |
INTERNAL API
|
EndpointManager.EndpointRegistry |
|
EndpointManager.Gated |
|
EndpointManager.Gated$ |
|
EndpointManager.Link |
|
EndpointManager.Link$ |
|
EndpointManager.Listen |
|
EndpointManager.Listen$ |
|
EndpointManager.ListensFailure |
|
EndpointManager.ListensFailure$ |
|
EndpointManager.ListensResult |
|
EndpointManager.ListensResult$ |
|
EndpointManager.ManagementCommand |
|
EndpointManager.ManagementCommand$ |
|
EndpointManager.ManagementCommandAck |
|
EndpointManager.ManagementCommandAck$ |
|
EndpointManager.Pass |
|
EndpointManager.Pass$ |
|
EndpointManager.Prune$ |
|
EndpointManager.Quarantine |
|
EndpointManager.Quarantine$ |
|
EndpointManager.Quarantined |
|
EndpointManager.Quarantined$ |
|
EndpointManager.ResendState |
|
EndpointManager.ResendState$ |
|
EndpointManager.Send |
|
EndpointManager.Send$ |
|
EndpointManager.ShutdownAndFlush$ |
|
EndpointManager.StartupFinished$ |
|
EndpointManager$ |
INTERNAL API
|
EndpointReader |
INTERNAL API
|
EndpointReader$ |
INTERNAL API
|
EndpointWriter |
INTERNAL API
|
EndpointWriter.AckIdleCheckTimer$ |
|
EndpointWriter.BackoffTimer$ |
|
EndpointWriter.FlushAndStop$ |
|
EndpointWriter.Handle |
|
EndpointWriter.Handle$ |
|
EndpointWriter.OutboundAck |
|
EndpointWriter.OutboundAck$ |
|
EndpointWriter.StoppedReading |
|
EndpointWriter.StoppedReading$ |
|
EndpointWriter.StopReading |
|
EndpointWriter.StopReading$ |
|
EndpointWriter.TakeOver |
This message signals that the current association maintained by the local EndpointWriter and EndpointReader is
to be overridden by a new inbound association.
|
EndpointWriter.TakeOver$ |
|
EndpointWriter.TookOver |
|
EndpointWriter.TookOver$ |
|
EndpointWriter$ |
INTERNAL API
|
EventPublisher |
INTERNAL API
|
FailureDetector.Clock |
Abstraction of a clock that returns time in milliseconds.
|
FailureDetector$ |
|
FailureDetectorLoader |
INTERNAL API
|
FailureDetectorLoader$ |
INTERNAL API
|
HasSequenceNumber$ |
|
HeartbeatHistory |
|
HeartbeatHistory$ |
|
HopelessAssociation$ |
|
InvalidAssociation$ |
|
MessageSerializer |
INTERNAL API
|
MessageSerializer$ |
INTERNAL API
|
PhiAccrualFailureDetector |
Implementation of 'The Phi Accrual Failure Detector' by Hayashibara et al.
|
QuarantinedEvent |
|
QuarantinedEvent$ |
|
RARP |
INTERNAL API
|
RARP$ |
INTERNAL API
|
ReliableDeliverySupervisor |
INTERNAL API
|
ReliableDeliverySupervisor.AttemptSysMsgRedelivery$ |
|
ReliableDeliverySupervisor.GotUid |
|
ReliableDeliverySupervisor.GotUid$ |
|
ReliableDeliverySupervisor.Idle$ |
|
ReliableDeliverySupervisor.IsIdle$ |
|
ReliableDeliverySupervisor.Ungate$ |
|
ReliableDeliverySupervisor$ |
INTERNAL API
|
RemoteActorRef |
INTERNAL API
Remote ActorRef that is used when referencing the Actor on a different node than its "home" node.
|
RemoteActorRefProvider |
INTERNAL API
Depending on this class is not supported, only the ActorRefProvider interface is supported.
|
RemoteActorRefProvider.Finished$ |
|
RemoteActorRefProvider.Idle$ |
|
RemoteActorRefProvider.Uninitialized$ |
|
RemoteActorRefProvider.WaitDaemonShutdown$ |
|
RemoteActorRefProvider.WaitTransportShutdown$ |
|
RemoteActorRefProvider$ |
INTERNAL API
|
RemoteDeployer |
INTERNAL API
|
RemoteDeploymentWatcher |
INTERNAL API
|
RemoteDeploymentWatcher.WatchRemote |
|
RemoteDeploymentWatcher.WatchRemote$ |
|
RemoteDeploymentWatcher$ |
INTERNAL API
|
RemoteMetricsExtension |
INTERNAL API
Extension that keeps track of remote metrics, such
as max size of different message types.
|
RemoteMetricsExtension$ |
INTERNAL API
Extension that keeps track of remote metrics, such
as max size of different message types.
|
RemoteMetricsOff |
INTERNAL API
|
RemoteMetricsOn |
INTERNAL API
|
RemoteScope |
|
RemoteScope$ |
|
RemoteSettings |
|
RemoteSystemDaemon |
INTERNAL API
|
RemoteTransport |
INTERNAL API
|
RemoteWatcher |
INTERNAL API
|
RemoteWatcher.ExpectedFirstHeartbeat |
|
RemoteWatcher.ExpectedFirstHeartbeat$ |
|
RemoteWatcher.Heartbeat$ |
|
RemoteWatcher.HeartbeatRsp |
|
RemoteWatcher.HeartbeatRsp$ |
|
RemoteWatcher.HeartbeatTick$ |
|
RemoteWatcher.ReapUnreachableTick$ |
|
RemoteWatcher.Stats |
|
RemoteWatcher.Stats$ |
|
RemoteWatcher.UnwatchRemote |
|
RemoteWatcher.UnwatchRemote$ |
|
RemoteWatcher.WatchRemote |
|
RemoteWatcher.WatchRemote$ |
|
RemoteWatcher$ |
INTERNAL API
|
Remoting |
INTERNAL API
|
Remoting.RegisterTransportActor |
|
Remoting.RegisterTransportActor$ |
|
Remoting.TransportSupervisor |
|
Remoting$ |
INTERNAL API
|
RemotingErrorEvent |
|
RemotingErrorEvent$ |
|
RemotingListenEvent |
|
RemotingListenEvent$ |
|
RemotingShutdownEvent |
|
RemotingShutdownEvent$ |
|
SeqNo |
|
SeqNo$ |
|
ShutDownAssociation$ |
|
WireFormats |
|
WireFormats.AckAndEnvelopeContainer |
Protobuf type AckAndEnvelopeContainer
|
WireFormats.AckAndEnvelopeContainer.Builder |
Protobuf type AckAndEnvelopeContainer
|
WireFormats.AcknowledgementInfo |
Protobuf type AcknowledgementInfo
|
WireFormats.AcknowledgementInfo.Builder |
Protobuf type AcknowledgementInfo
|
WireFormats.ActorRefData |
Protobuf type ActorRefData
|
WireFormats.ActorRefData.Builder |
Protobuf type ActorRefData
|
WireFormats.AddressData |
Protobuf type AddressData
|
WireFormats.AddressData.Builder |
Protobuf type AddressData
|
WireFormats.AkkaControlMessage |
Protobuf type AkkaControlMessage
|
WireFormats.AkkaControlMessage.Builder |
Protobuf type AkkaControlMessage
|
WireFormats.AkkaHandshakeInfo |
Protobuf type AkkaHandshakeInfo
|
WireFormats.AkkaHandshakeInfo.Builder |
Protobuf type AkkaHandshakeInfo
|
WireFormats.AkkaProtocolMessage |
Protobuf type AkkaProtocolMessage
|
WireFormats.AkkaProtocolMessage.Builder |
Protobuf type AkkaProtocolMessage
|
WireFormats.DaemonMsgCreateData |
Protobuf type DaemonMsgCreateData
|
WireFormats.DaemonMsgCreateData.Builder |
Protobuf type DaemonMsgCreateData
|
WireFormats.DeployData |
Protobuf type DeployData
|
WireFormats.DeployData.Builder |
Protobuf type DeployData
|
WireFormats.PropsData |
Protobuf type PropsData
|
WireFormats.PropsData.Builder |
Protobuf type PropsData
|
WireFormats.RemoteEnvelope |
Protobuf type RemoteEnvelope
|
WireFormats.RemoteEnvelope.Builder |
Protobuf type RemoteEnvelope
|
WireFormats.SerializedMessage |
Protobuf type SerializedMessage
|
WireFormats.SerializedMessage.Builder |
Protobuf type SerializedMessage
|