Click or drag to resize
Akka.NETAkka.Remote Namespace
The Akka.Remote namespace contains classes that provide for interacting to remote actors.
Public classAddressUid
Extension that holds a UID that is assigned as a random 'Int'. The UID is intended to be used together with an Address to be able to distinguish restarted actor system using the same host and port.
Public classAddressUidExtension
IExtension provider for AddressUid
Public classAkkaProtocolSettings
Public classAssociatedEvent
Public classAssociationErrorEvent
Public classAssociationEvent
Public classDeadline
This class represents the latest date or time by which an operation should be completed.
Public classDeadlineFailureDetector
This class represents a FailureDetector that uses an absolute timeout of missing heartbeats to trigger unavailability.
Public classDefaultFailureDetectorRegistryT
Public classDisassociatedEvent
Public classFailureDetector
A failure detector must be a thread-safe, mutable construct that registers heartbeat events of a resource and is able to decide the availability of that monitored resource
Public classFailureDetectorLoader
INTERNAL API Utility class to create FailureDetector instances via reflection.
Public classMessageSerializer
Class MessageSerializer.
Public classPhiAccrualFailureDetector
Implementation of 'The Phi Accrual Failure Detector' by Hayashibara et al. as defined in their paper: [] The suspicion level of failure is given by a value called φ (phi). The basic idea of the φ failure detector is to express the value of φ on a scale that is dynamically adjusted to reflect current network conditions. A configurable threshold is used to decide if φ is considered to be a failure. The value of φ is calculated as:
φ = -log10(1 - F(timeSinceLastHeartbeat)
where F is the cumulative distribution function of a normal distribution with mean and standard deviation estimated from historical heartbeat inter-arrival times.
Public classQuarantinedEvent
Public classRemoteActorRef
Class RemoteActorRef.
Public classRemoteActorRefProvider
Public classRemoteSettings
This class represents configuration information used when setting up remoting.
Public classRemoteSettingsTransportSettings
Public classRemoteTransport
INTERNAL API. The remote transport is responsible for sending and receiving messages. Each transport has an address, which it should provide in Serialization.CurrentTransportInformation (thread-local) while serializing ActorReferences (which might also be part of messages). This address must be available (i.e. fully initialized) by the time the first message is received or when the Start() method returns, whichever happens first.
Public classRemoteTransportException
This exception is thrown when a general failure within a RemoteTransport occurs, such as the inability to start, wrong configuration, etc...
Public classRemoteWatcher
INTERNAL API Remote nodes with actors that are watched are monitored by this actor to be able to detect network failures and process crashes. RemoteActorRefProvider intercepts Watch and Unwatch system messages and sends corresponding RemoteWatcherWatchRemote and RemoteWatcherUnwatchRemote to this actor. For a new node to be watched this actor periodically sends RemoteWatcherHeartbeat to the peer actor on the other node, which replies with RemoteWatcherHeartbeatRsp message back. The failure detector on the watching side monitors these heartbeat messages. If arrival of heartbeat messages stops it will be detected and this actor will publish AddressTerminated to the AddressTerminatedTopic. When all actors on a node have been unwatched it will stop sending heartbeat messages. For bi-directional watch between two nodes the same thing will be established in both directions, but independent of each other.
Public classRemoteWatcherExpectedFirstHeartbeat
Public classRemoteWatcherHeartbeat
Public classRemoteWatcherHeartbeatRsp
Public classRemoteWatcherHeartbeatTick
Public classRemoteWatcherReapUnreachableTick
Public classRemoteWatcherStats
Public classRemoteWatcherUnwatchRemote
Public classRemoteWatcherWatchCommand
Public classRemoteWatcherWatchRemote
Public classRemotingErrorEvent
Public classRemotingLifecycleEvent
Remote lifecycle events that are published to the EventStream when initialization / connect / disconnect events that occur during network operations
Public classRemotingListenEvent
Public classRemotingShutdownEvent
Public classThisActorSystemQuarantinedEvent
Public interfaceIFailureDetectorRegistryT
Interface for a registry of Akka FailureDetectors. New resources are implicitly registered when heartbeat is first called with the resource given as parameter.
Public delegateClock
Abstraction of a clock that returns time in milliseconds. Can only be used to measure the elapsed time and is not related to any other notion of system or wall-clock time.