| Interface | Description |
|---|---|
| BufferPool | |
| ChannelRegistration |
Implementations of this interface are sent as actor messages back to a channel actor as
a result of it having called
register on the ChannelRegistry. |
| ChannelRegistry |
Interface behind which we hide our selector management logic from the connection actors
|
| Dns.Command | |
| DnsProvider | |
| Inet.SocketOption |
SocketOption is a package of data (from the user) and associated
behavior (how to apply that to a channel).
|
| Inet.SocketOptionV2 | |
| Inet.SoForwarders | |
| Inet.SoJavaFactories | |
| IO.Extension | |
| PeriodicCacheCleanup | |
| SelectionHandler.HasFailureMessage | |
| Tcp.CloseCommand |
Common interface for all commands which aim to close down an open connection.
|
| Tcp.Command |
This is the common trait for all commands understood by TCP actors.
|
| Tcp.ConnectionClosed |
This is the common interface for all events which indicate that a connection
has been closed or half-closed.
|
| Tcp.Event |
Common interface for all events generated by the TCP layer actors.
|
| Tcp.Message |
The common interface for
Tcp.Command and Tcp.Event. |
| Tcp.Unbound |
The sender of an
Unbind command will receive confirmation through this
message once the listening socket has been closed. |
| Tcp.WritingResumed |
When
useResumeWriting is in effect as indicated in the Tcp.Register message,
the ResumeWriting command will be acknowledged by this message type, upon
which it is safe to send at least one write. |
| TcpConnection.ReadResult | |
| Udp.Command |
The common type of all commands supported by the UDP implementation.
|
| Udp.Event |
The common type of all events emitted by the UDP implementation.
|
| Udp.Message |
The common interface for
Udp.Command and Udp.Event. |
| Udp.SimpleSenderReady |
The “simple sender” sends this message type in response to a
Udp.SimpleSender query. |
| Udp.Unbound |
This message is sent by the listener actor in response to an
Unbind command
after the socket has been closed. |
| UdpConnected.Command |
The common type of all commands supported by the UDP implementation.
|
| UdpConnected.Connected |
This message is sent by the connection actor to the actor which sent the
UdpConnected.Connect message when the UDP socket has been bound to the local and
remote addresses given. |
| UdpConnected.Disconnected |
This message is sent by the connection actor to the actor which sent the
Disconnect message when the UDP socket has been closed. |
| UdpConnected.Event |
The common type of all events emitted by the UDP implementation.
|
| UdpConnected.Message |
The common interface for
UdpConnected.Command and UdpConnected.Event. |
| WithUdpSend |
INTERNAL API
|
| Class | Description |
|---|---|
| DirectByteBufferPool |
INTERNAL API
|
| DirectByteBufferPool$ |
INTERNAL API
|
| Dns | |
| Dns.Resolve | |
| Dns.Resolve$ | |
| Dns.Resolved | |
| Dns.Resolved$ | |
| Dns$ | |
| DnsExt | |
| Inet | |
| Inet.AbstractSocketOption |
Java API: AbstractSocketOption is a package of data (from the user) and associated
behavior (how to apply that to a channel).
|
| Inet.AbstractSocketOptionV2 |
Java API
|
| Inet.DatagramChannelCreator |
DatagramChannel creation behavior.
|
| Inet.DatagramChannelCreator$ | |
| Inet.SO$ | |
| Inet$ | |
| InetAddressDnsProvider | |
| InetAddressDnsResolver | |
| IO |
Entry point to Akka’s IO layer.
|
| IO$ |
Entry point to Akka’s IO layer.
|
| IpVersionSelector | |
| IpVersionSelector$ | |
| SelectionHandler | |
| SelectionHandler.ChannelAcceptable$ | |
| SelectionHandler.ChannelConnectable$ | |
| SelectionHandler.ChannelReadable$ | |
| SelectionHandler.ChannelWritable$ | |
| SelectionHandler.Retry | |
| SelectionHandler.Retry$ | |
| SelectionHandler.SelectorBasedManager | |
| SelectionHandler.WorkerForCommand | |
| SelectionHandler.WorkerForCommand$ | |
| SelectionHandler$ | |
| SelectionHandlerSettings | |
| SimpleDnsCache | |
| SimpleDnsCache$ | |
| SimpleDnsManager | |
| SimpleDnsManager$ | |
| Tcp |
TCP Extension for Akka’s IO layer.
|
| Tcp.Abort$ |
An abort operation will not flush pending writes and will issue a TCP ABORT
command to the O/S kernel which should result in a TCP_RST packet being sent
to the peer.
|
| Tcp.Aborted$ |
The connection has been aborted in response to an
Abort command. |
| Tcp.Bind |
The Bind message is send to the TCP manager actor, which is obtained via
TcpExt.manager() in order to bind to a listening socket. |
| Tcp.Bind$ | |
| Tcp.Bound |
The sender of a
Tcp.Bind command will—in case of success—receive confirmation
in this form. |
| Tcp.Bound$ | |
| Tcp.Close$ |
A normal close operation will first flush pending writes and then close the
socket.
|
| Tcp.Closed$ |
The connection has been closed normally in response to a
Close command. |
| Tcp.CommandFailed |
Whenever a command cannot be completed, the queried actor will reply with
this message, wrapping the original command which failed.
|
| Tcp.CommandFailed$ | |
| Tcp.CompoundWrite |
A write command which aggregates two other write commands.
|
| Tcp.CompoundWrite$ | |
| Tcp.ConfirmedClose$ |
A confirmed close operation will flush pending writes and half-close the
connection, waiting for the peer to close the other half.
|
| Tcp.ConfirmedClosed$ |
The connection has been half-closed by us and then half-close by the peer
in response to a
ConfirmedClose command. |
| Tcp.Connect |
The Connect message is sent to the TCP manager actor, which is obtained via
TcpExt.manager(). |
| Tcp.Connect$ | |
| Tcp.Connected |
The connection actor sends this message either to the sender of a
Tcp.Connect
command (for outbound) or to the handler for incoming connections designated
in the Tcp.Bind message. |
| Tcp.Connected$ | |
| Tcp.ErrorClosed |
The connection has been closed due to an IO error.
|
| Tcp.ErrorClosed$ | |
| Tcp.NoAck |
Each
Tcp.WriteCommand can optionally request a positive acknowledgment to be sent
to the commanding actor. |
| Tcp.NoAck$ |
Default
Tcp.NoAck instance which is used when no acknowledgment information is
explicitly provided. |
| Tcp.PeerClosed$ |
The peer has closed its writing half of the connection.
|
| Tcp.Received |
Whenever data are read from a socket they will be transferred within this
class to the handler actor which was designated in the
Tcp.Register message. |
| Tcp.Received$ | |
| Tcp.Register |
This message must be sent to a TCP connection actor after receiving the
Tcp.Connected message. |
| Tcp.Register$ | |
| Tcp.ResumeAccepting |
This message enables the accepting of the next connection if read throttling is enabled
for connection actors.
|
| Tcp.ResumeAccepting$ | |
| Tcp.ResumeReading$ |
This command needs to be sent to the connection actor after a
SuspendReading
command in order to resume reading from the socket. |
| Tcp.ResumeWriting$ |
When
useResumeWriting is in effect as was indicated in the Tcp.Register message
then this command needs to be sent to the connection actor in order to re-enable
writing after a Tcp.CommandFailed event. |
| Tcp.SimpleWriteCommand |
Common supertype of
Tcp.Write and Tcp.WriteFile. |
| Tcp.SO$ |
Scala API: this object contains all applicable socket options for TCP.
|
| Tcp.SuspendReading$ |
Sending this command to the connection actor will disable reading from the TCP
socket.
|
| Tcp.Unbind$ |
In order to close down a listening socket, send this message to that socket’s
actor (that is the actor which previously had sent the
Tcp.Bound message). |
| Tcp.Unbound$ | |
| Tcp.Write |
Write data to the TCP connection.
|
| Tcp.Write$ | |
| Tcp.WriteCommand |
Common interface for all write commands.
|
| Tcp.WriteCommand$ | |
| Tcp.WriteFile |
Write
count bytes starting at position from file at filePath to the connection. |
| Tcp.WriteFile$ | |
| Tcp.WritingResumed$ | |
| Tcp$ |
TCP Extension for Akka’s IO layer.
|
| TcpConnection |
Base class for TcpIncomingConnection and TcpOutgoingConnection.
|
| TcpConnection.AllRead$ | |
| TcpConnection.CloseInformation |
Used to transport information to the postStop method to notify
interested party about a connection close.
|
| TcpConnection.CloseInformation$ | |
| TcpConnection.ConnectionInfo |
Groups required connection-related data that are only available once the connection has been fully established.
|
| TcpConnection.ConnectionInfo$ | |
| TcpConnection.EmptyPendingWrite$ | |
| TcpConnection.EndOfStream$ | |
| TcpConnection.MoreDataWaiting$ | |
| TcpConnection.PendingWrite | |
| TcpConnection.UpdatePendingWriteAndThen | |
| TcpConnection.UpdatePendingWriteAndThen$ | |
| TcpConnection.WriteFileFailed | |
| TcpConnection.WriteFileFailed$ | |
| TcpConnection$ |
INTERNAL API
|
| TcpExt | |
| TcpIncomingConnection |
An actor handling the connection state machine for an incoming, already connected
SocketChannel.
|
| TcpListener |
INTERNAL API
|
| TcpListener.FailedRegisterIncoming | |
| TcpListener.FailedRegisterIncoming$ | |
| TcpListener.RegisterIncoming | |
| TcpListener.RegisterIncoming$ | |
| TcpListener$ |
INTERNAL API
|
| TcpManager |
INTERNAL API
|
| TcpMessage | |
| TcpMessage$ | |
| TcpOutgoingConnection |
An actor handling the connection state machine for an outgoing connection
to be established.
|
| TcpOutgoingConnection$ | |
| TcpSO |
Java API for accessing socket options.
|
| TcpSO$ |
Java API for accessing socket options.
|
| Udp |
UDP Extension for Akka’s IO layer.
|
| Udp.Bind |
Send this message to the
UdpExt.manager() in order to bind to the given
local port (or an automatically assigned one if the port number is zero). |
| Udp.Bind$ | |
| Udp.Bound |
This message is sent by the listener actor in response to a
Udp.Bind command. |
| Udp.Bound$ | |
| Udp.CommandFailed |
When a command fails it will be replied to with this message type,
wrapping the failing command object.
|
| Udp.CommandFailed$ | |
| Udp.NoAck |
Each
Udp.Send can optionally request a positive acknowledgment to be sent
to the commanding actor. |
| Udp.NoAck$ |
Default
Udp.NoAck instance which is used when no acknowledgment information is
explicitly provided. |
| Udp.Received |
When a listener actor receives a datagram from its socket it will send
it to the handler designated in the
Udp.Bind message using this message type. |
| Udp.Received$ | |
| Udp.ResumeReading$ |
This message must be sent to the listener actor to re-enable reading from
the socket after a
SuspendReading command. |
| Udp.Send |
This message is understood by the “simple sender” which can be obtained by
sending the
Udp.SimpleSender query to the UdpExt.manager() as well as by
the listener actors which are created in response to Udp.Bind. |
| Udp.Send$ | |
| Udp.SimpleSender |
Retrieve a reference to a “simple sender” actor of the UDP extension.
|
| Udp.SimpleSender$ | |
| Udp.SimpleSenderReady$ | |
| Udp.SO$ |
Scala API: This object provides access to all socket options applicable to UDP sockets.
|
| Udp.SuspendReading$ |
Send this message to a listener actor (which sent a
Udp.Bound message) to
have it stop reading datagrams from the network. |
| Udp.UdpSettings | |
| Udp.Unbind$ |
Send this message to the listener actor that previously sent a
Udp.Bound
message in order to close the listening socket. |
| Udp.Unbound$ | |
| Udp$ |
UDP Extension for Akka’s IO layer.
|
| UdpConnected |
UDP Extension for Akka’s IO layer.
|
| UdpConnected.CommandFailed |
When a command fails it will be replied to with this message type,
wrapping the failing command object.
|
| UdpConnected.CommandFailed$ | |
| UdpConnected.Connect |
Send this message to the
UdpExt.manager() in order to bind to a local
port (optionally with the chosen localAddress) and create a UDP socket
which is restricted to sending to and receiving from the given remoteAddress. |
| UdpConnected.Connect$ | |
| UdpConnected.Connected$ | |
| UdpConnected.Disconnect$ |
Send this message to a connection actor (which had previously sent the
UdpConnected.Connected message) in order to close the socket. |
| UdpConnected.Disconnected$ | |
| UdpConnected.NoAck |
Each
UdpConnected.Send can optionally request a positive acknowledgment to be sent
to the commanding actor. |
| UdpConnected.NoAck$ |
Default
UdpConnected.NoAck instance which is used when no acknowledgment information is
explicitly provided. |
| UdpConnected.Received |
When a connection actor receives a datagram from its socket it will send
it to the handler designated in the
Udp.Bind message using this message type. |
| UdpConnected.Received$ | |
| UdpConnected.ResumeReading$ |
This message must be sent to the listener actor to re-enable reading from
the socket after a
SuspendReading command. |
| UdpConnected.Send |
This message is understood by the connection actors to send data to their
designated destination.
|
| UdpConnected.Send$ | |
| UdpConnected.SuspendReading$ |
Send this message to a listener actor (which sent a
Udp.Bound message) to
have it stop reading datagrams from the network. |
| UdpConnected$ |
UDP Extension for Akka’s IO layer.
|
| UdpConnectedExt | |
| UdpConnectedManager |
INTERNAL API
|
| UdpConnectedMessage |
Java API: factory methods for the message types used when communicating with the UdpConnected service.
|
| UdpConnectedMessage$ |
Java API: factory methods for the message types used when communicating with the UdpConnected service.
|
| UdpConnection |
INTERNAL API
|
| UdpExt | |
| UdpListener |
INTERNAL API
|
| UdpManager |
INTERNAL API
|
| UdpMessage |
Java API: factory methods for the message types used when communicating with the Udp service.
|
| UdpMessage$ |
Java API: factory methods for the message types used when communicating with the Udp service.
|
| UdpSender |
INTERNAL API
|
| UdpSO | |
| UdpSO$ |