Package org.apache.pekko.remote.artery

package org.apache.pekko.remote.artery

Related Packages

Package	Description
org.apache.pekko.remote
org.apache.pekko.remote.artery.aeron
org.apache.pekko.remote.artery.compress
org.apache.pekko.remote.artery.jfr
org.apache.pekko.remote.artery.tcp
org.apache.pekko.remote.routing
org.apache.pekko.remote.serialization
org.apache.pekko.remote.testconductor
org.apache.pekko.remote.testkit
org.apache.pekko.remote.transport

Class	Description
ActorSystemTerminating$
ActorSystemTerminatingAck$
ArteryMessage	INTERNAL API: marker trait for protobuf-serializable artery messages
ArterySettings$	INTERNAL API
ArteryTransport$	INTERNAL API
Association$	INTERNAL API
AssociationState$	INTERNAL API
ByteFlag$	INTERNAL API
CacheStatistics$
ControlMessage	INTERNAL API Marker trait for control messages that can be sent via the system message sub-channel but don't need full reliable delivery.
Decoder$	INTERNAL API
Encoder$	INTERNAL API
EnvelopeBuffer$	INTERNAL API
Flush	INTERNAL API
Flush$	INTERNAL API
FlushAck$
FlushBeforeDeathWatchNotification$	INTERNAL API
FlushOnShutdown$	INTERNAL API
GracefulShutdownQuarantinedEvent
GracefulShutdownQuarantinedEvent$
HeaderBuilder	INTERNAL API
HeaderBuilder$	INTERNAL API
ImmutableLongMap$	INTERNAL API
InboundContext	INTERNAL API Inbound API that is used by the stream operators.
InboundControlJunction$	INTERNAL API
InboundEnvelope	INTERNAL API
InboundEnvelope$	INTERNAL API
NoOpRemotingFlightRecorder	JFR is only available under certain circumstances (JDK11 for now, possible OpenJDK 8 in the future) so therefore the default on JDK 8 needs to be a no-op flight recorder.
NoOpRemotingFlightRecorder$	JFR is only available under certain circumstances (JDK11 for now, possible OpenJDK 8 in the future) so therefore the default on JDK 8 needs to be a no-op flight recorder.
OutboundContext	INTERNAL API Outbound association API that is used by the stream operators.
OutboundControlJunction$	INTERNAL API
OutboundEnvelope	INTERNAL API
OutboundEnvelope$	INTERNAL API
OutboundHandshake$	INTERNAL API
Quarantined$
QuarantinedEvent
QuarantinedEvent$
RemoteInstrument	INTERNAL API
RemoteInstruments$	INTERNAL API
RemotingFlightRecorder	INTERNAL API
RemotingFlightRecorder$	INTERNAL API
Reply	INTERNAL API: Marker trait for reply messages
RestartCounter$	INTERNAL API
ReusableInboundEnvelope$	INTERNAL API
ReusableOutboundEnvelope$	INTERNAL API
SendQueue$	INTERNAL API
SystemMessageAcker$	INTERNAL API
SystemMessageDelivery$	INTERNAL API
TestManagementCommands
TestManagementCommands.FailInboundStreamOnce	INTERNAL API
TestManagementCommands.FailInboundStreamOnce$
TestManagementCommands$
TestState$
ThisActorSystemQuarantinedEvent
ThisActorSystemQuarantinedEvent$