MediaDriver
manages sending and receiving from the underlying media and handling
request from the Aeron clients.See: Description
Interface | Description |
---|---|
CongestionControl |
Strategy for applying congestion control to determine the receiverWindowLength of the Status Messages
|
CongestionControlSupplier | |
DriverManagedResource | |
FeedbackDelayGenerator |
Feedback delay generator.
|
FlowControl |
Strategy for applying flow control to the
Sender . |
FlowControlSupplier | |
LossHandler |
Handler for dealing with detected loss on a message stream.
|
ReceiveChannelEndpointSupplier | |
RetransmitSender |
Handler for sending a retransmit
|
SendChannelEndpointSupplier | |
Subscribable |
Stream source that can be observed by subscribers which identify themselves the position they have read up to.
|
Class | Description |
---|---|
AeronClient |
Aeron client library tracker.
|
ClientProxy |
Proxy for communicating from the driver to the client conductor.
|
Configuration |
Configuration options for the
MediaDriver . |
CongestionControlUtil | |
CounterLink |
Tracks a aeron client interest in a counter.
|
DataPacketDispatcher |
Handling of dispatching data packets to
PublicationImage s streams. |
DefaultCongestionControlSupplier | |
DefaultMulticastFlowControlSupplier | |
DefaultReceiveChannelEndpointSupplier |
Supply the default implementation of the
ReceiveChannelEndpoint . |
DefaultSendChannelEndpointSupplier |
Supply the default implementation of the
SendChannelEndpoint . |
DefaultUnicastFlowControlSupplier | |
DriverConductor |
Driver Conductor that takes commands from publishers and subscribers and orchestrates the media driver.
|
DriverConductorProxy |
Proxy for sending commands to the
DriverConductor . |
IpcPublication |
Encapsulation of a LogBuffer used directly between publishers and subscribers for IPC over shared memory.
|
LossDetector |
Detecting and handling of gaps in a message stream.
|
MaxMulticastFlowControl |
Default multicast sender flow control strategy.
|
MaxMulticastFlowControlSupplier | |
MediaDriver |
Main class for JVM-based media driver
|
MediaDriver.Context |
Configuration for the
MediaDriver that can be used to override Configuration . |
MinMulticastFlowControl |
Minimum multicast sender flow control strategy.
|
MinMulticastFlowControlSupplier | |
NetworkPublication |
Publication to be sent to connected subscribers.
|
NetworkPublicationThreadLocals | |
OptimalMulticastDelayGenerator |
Feedback delay used for NAKs as well as for some retransmission use cases.
|
PreferredMulticastFlowControl |
Minimum multicast sender flow control strategy only for preferred members.
|
PreferredMulticastFlowControlSupplier | |
PublicationImage |
State maintained for active sessionIds within a channel for receiver processing
|
PublicationLink |
Tracks a aeron client interest registration in a
NetworkPublication or IpcPublication . |
Receiver |
Receiver agent for JVM based media driver, uses an event loop with command buffer
|
ReceiverProxy |
Proxy for offering into the
Receiver Thread's command queue. |
RetransmitHandler |
Tracking and handling of retransmit request, NAKs, for senders, and receivers.
|
Sender |
Agent that iterates over
NetworkPublication s for sending them to registered subscribers. |
SenderProxy |
Proxy for offering into the Sender Thread's command queue.
|
StaticDelayGenerator |
Delay generator that simply returns a constant value (such as 0)
|
StaticWindowCongestionControl | |
SubscriberPosition |
Consumption position a subscriber has got to within a
SubscriptionLink . |
SubscriptionLink |
Subscription registration from a client used for liveness tracking
|
UnicastFlowControl |
Default unicast sender flow control strategy.
|
Enum | Description |
---|---|
NetworkPublication.State | |
ThreadingMode |
Threading mode to be employed by the
Agent s in the MediaDriver . |
MediaDriver
manages sending and receiving from the underlying media and handling
request from the Aeron clients. The media driver can run in-process, or out of process, from the Aeron clients.Copyright © 2014-2018 Real Logic Ltd. All Rights Reserved.