Package akka.remote.artery

Interface Summary

Interface	Description
AeronSource.ResourceLifecycle
ArteryMessage	INTERNAL API: marker trait for protobuf-serializable artery messages
Association.QueueWrapper
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.InboundCompressionAccess	Materialized value of Encoder which allows safely calling into the stage to interfact with compression tables.
Decoder.InboundCompressionAccessImpl
Encoder.OutboundCompressionAccess
EventClock	INTERNAL API
EventSink	INTERNAL API
FlightRecorderReader.Entry
FlightRecorderReader.LogState
FlightRecorderStatus	INTERNAL API
HeaderBuilder	INTERNAL API
InboundContext	INTERNAL API Inbound API that is used by the stream stages.
InboundControlJunction.CallbackMessage
InboundControlJunction.ControlMessageObserver
InboundControlJunction.ControlMessageSubject	Observer subject for inbound control messages.
InboundEnvelope	INTERNAL API
OutboundContext	INTERNAL API Outbound association API that is used by the stream stages.
OutboundControlJunction.OutboundControlIngress
OutboundEnvelope	INTERNAL API
Reply	INTERNAL API: Marker trait for reply messages
SendQueue.ProducerApi<T>
SendQueue.QueueValue<T>
SystemMessageDelivery.AckedDeliveryMessage
TaskRunner.Command

Class Summary

Class	Description
ActorRefResolveCacheWithAddress	INTERNAL API
ActorSystemTerminating	INTERNAL API
ActorSystemTerminating$
ActorSystemTerminatingAck	INTERNAL API
ActorSystemTerminatingAck$
AeronErrorLog	Application to print out errors recorded in the command-and-control (cnc) file is maintained by media driver in shared memory.
AeronSink	INTERNAL API param: channel eg.
AeronSink$	INTERNAL API
AeronSource	INTERNAL API param: channel eg.
AeronSource.Fragments
AeronSource.MessageHandler
AeronSource$	INTERNAL API
ArterySettings	INTERNAL API
ArterySettings.Compression	INTERNAL API
ArterySettings.Compression$
ArterySettings$	INTERNAL API
ArteryTransport	INTERNAL API
ArteryTransport.InboundStreamMatValues
ArteryTransport.InboundStreamMatValues$
ArteryTransport$	INTERNAL API
Association	INTERNAL API
Association.DisabledQueueWrapper$
Association.LazyQueueWrapper
Association.LazyQueueWrapper$
Association.OutboundStreamMatValues
Association.OutboundStreamMatValues$
Association.QueueWrapperImpl
Association.QueueWrapperImpl$
Association$	INTERNAL API
AssociationRegistry	INTERNAL API
AssociationState	INTERNAL API
AssociationState.QuarantinedTimestamp
AssociationState.QuarantinedTimestamp$
AssociationState$	INTERNAL API
ByteFlag	INTERNAL API
ByteFlag$	INTERNAL API
CacheStatistics	INTERNAL API
CacheStatistics$
Decoder	INTERNAL API
Decoder$	INTERNAL API
Deserializer	INTERNAL API
Encoder	INTERNAL API
Encoder$	INTERNAL API
EnvelopeBuffer	INTERNAL API
EnvelopeBuffer$	INTERNAL API
EnvelopeBufferPool	INTERNAL API
EventClockImpl	INTERNAL API
FastHash	INTERNAL API
FastHash$	INTERNAL API
FlightRecorder	INTERNAL API
FlightRecorder$	INTERNAL API
FlightRecorderDump	Internal API
FlightRecorderDump$	Internal API
FlightRecorderEvents	INTERNAL API
FlightRecorderEvents$	INTERNAL API
FlightRecorderReader	Internal API
FlightRecorderReader.Empty$
FlightRecorderReader.Live$
FlightRecorderReader.SectionParameters
FlightRecorderReader.SectionParameters$
FlightRecorderReader.Snapshot$
FlightRecorderReader$	Internal API
FlushOnShutdown	INTERNAL API
FlushOnShutdown.Timeout$
FlushOnShutdown$	INTERNAL API
HeaderBuilder$	INTERNAL API
HeaderBuilderImpl	INTERNAL API
IgnoreEventSink	INTERNAL API
IgnoreEventSink$	INTERNAL API
ImmutableLongMap<A>	INTERNAL API Specialized Map for primitive Long keys to avoid allocations (boxing).
ImmutableLongMap$	INTERNAL API
InboundControlJunction	INTERNAL API
InboundControlJunction.Attach
InboundControlJunction.Attach$
InboundControlJunction.Dettach
InboundControlJunction.Dettach$
InboundControlJunction$	INTERNAL API
InboundEnvelope$	INTERNAL API
InboundHandshake	INTERNAL API
InboundQuarantineCheck	INTERNAL API
InboundTestStage	INTERNAL API
LruBoundedCache<K,V>	INTERNAL API
MessageDispatcher	INTERNAL API
ObjectPool<A>	INTERNAL API
OutboundControlJunction	INTERNAL API
OutboundControlJunction$	INTERNAL API
OutboundEnvelope$	INTERNAL API
OutboundHandshake	INTERNAL API
OutboundHandshake.HandshakeReq
OutboundHandshake.HandshakeReq$
OutboundHandshake.HandshakeRsp
OutboundHandshake.HandshakeRsp$
OutboundHandshake$	INTERNAL API
OutboundTestStage	INTERNAL API
Quarantined	INTERNAL API
Quarantined$
RemoteInstrument	INTERNAL API
RemoteInstruments	INTERNAL API
RemoteInstruments$	INTERNAL API
RestartCounter	INTERNAL API: Thread safe "restarts with duration" counter
RestartCounter.State
RestartCounter.State$
RestartCounter$	INTERNAL API
ReusableInboundEnvelope	INTERNAL API
ReusableInboundEnvelope$	INTERNAL API
ReusableOutboundEnvelope	INTERNAL API
ReusableOutboundEnvelope$	INTERNAL API
RollingEventLogSection	INTERNAL API
RollingEventLogSection$	INTERNAL API
Running
Running$
SendQueue<T>	INTERNAL API
SendQueue$	INTERNAL API
SerializationFormatCache	INTERNAL API
SharedTestState	INTERNAL API: Thread safe mutable state that is shared among the test stages.
ShutDown
ShutDown$
SnapshotInProgress
SnapshotInProgress$
SynchronizedEventSink	INTERNAL API
SystemMessageAcker	INTERNAL API
SystemMessageDelivery	INTERNAL API
SystemMessageDelivery.Ack
SystemMessageDelivery.Ack$
SystemMessageDelivery.ClearSystemMessageDelivery$
SystemMessageDelivery.Nack
SystemMessageDelivery.Nack$
SystemMessageDelivery.SystemMessageEnvelope
SystemMessageDelivery.SystemMessageEnvelope$
SystemMessageDelivery$	INTERNAL API
TaskRunner	INTERNAL API
TaskRunner.Add
TaskRunner.Add$
TaskRunner.CommandQueue
TaskRunner.Remove
TaskRunner.Remove$
TaskRunner.Shutdown$
TaskRunner$	INTERNAL API
TestManagementCommands
TestManagementCommands.FailInboundStreamOnce	INTERNAL API
TestManagementCommands.FailInboundStreamOnce$
TestManagementCommands$
TestState	INTERNAL API
TestState$

Exception Summary

Exception	Description
AeronSink.GaveUpMessageException
AeronSink.PublicationClosedException
ArteryTransport.AeronTerminated
ArteryTransport.ShutdownSignal$
ArteryTransport.ShuttingDown$
Decoder.AccessInboundCompressionFailed
Encoder.AccessOutboundCompressionFailed
OutboundHandshake.HandshakeTimeoutException	Stream is failed with this exception if the handshake is not completed within the handshake timeout.
OutOfBuffersException	INTERNAL API
SystemMessageDelivery.GaveUpSystemMessageException