Package org.apache.cassandra.net

Interface Summary

Interface	Description
AsyncStreamingInputPlus.Consumer
AsyncStreamingOutputPlus.BufferSupplier
AsyncStreamingOutputPlus.Write
BackPressureState	Interface meant to track the back-pressure state per replica host.
BackPressureStrategy<S extends BackPressureState>	Back-pressure algorithm interface.
InboundMessageHandler.OnHandlerClosed
InboundMessageHandlers.GlobalMetricCallbacks
InboundMessageHandlers.MessageConsumer
IVerbHandler<T>	IVerbHandler provides the method that all verb handlers need to implement.
LatencyConsumer
LatencySubscribers.Subscriber
MessagingServiceMBean	MBean exposing MessagingService metrics plus allowing to enable/disable back-pressure.
OutboundSink.Sink
RequestCallback<T>	implementors of RequestCallback need to make sure that any public methods are threadsafe with respect to RequestCallback.onResponse(org.apache.cassandra.net.Message<T>) being called from the message service.
ResourceLimits.Limit	Represents permits to utilise a resource and ways to allocate and release them.

Class Summary

Class	Description
AsyncChannelOutputPlus	A DataOutputStreamPlus that writes ASYNCHRONOUSLY to a Netty Channel.
AsyncChannelPromise	See AsyncPromise and ChannelPromise This class is all boiler plate, just ensuring we return ourselves and invoke the correct Promise method.
AsyncMessageOutputPlus	A DataOutputStreamPlus that writes ASYNCHRONOUSLY to a Netty Channel.
AsyncOneResponse<T>	A callback specialized for returning a value from a single target; that is, this is for messages that we only send to one recipient.
AsyncPromise<V>	Netty's DefaultPromise uses a mutex to coordinate notifiers AND waiters between the eventLoop and the other threads.
AsyncStreamingInputPlus
AsyncStreamingOutputPlus	A DataOutputStreamPlus that writes ASYNCHRONOUSLY to a Netty Channel.
EndpointMessagingVersions	Map of hosts to their known current messaging versions.
ForwardingInfo	A container used to store a node -> message_id map for inter-DC write forwarding.
InboundConnectionInitiator
InboundConnectionSettings
InboundMessageHandler	Core logic for handling inbound message deserialization and execution (in tandem with FrameDecoder).
InboundMessageHandler.WaitQueue	A special-purpose wait queue to park inbound message handlers that failed to allocate reserve capacity for a message in.
InboundMessageHandlers	An aggregation of InboundMessageHandlers for all connections from a peer.
InboundSink	A message sink that all inbound messages go through.
LatencySubscribers	Callback that DynamicEndpointSnitch listens to in order to update host scores.
Message<T>	Immutable main unit of internode communication - what used to be MessageIn and MessageOut fused in one class.
Message.Builder<T>
Message.Header	Split into a separate object to allow partial message deserialization without wasting work and allocation afterwards, if the entire message is necessary and available.
Message.Serializer	Each message contains a header with several fixed fields, an optional key-value params section, and then the message payload itself.
MessagingService	MessagingService implements all internode communication - with the exception of SSTable streaming (for now).
MessagingServiceMBeanImpl
NoPayload	Empty message payload - primarily used for responses.
OutboundConnection	Represents a connection type to a peer, and handles the state transistions on the connection and the netty Channel.
OutboundConnectionInitiator<SuccessType extends OutboundConnectionInitiator.Result.Success>	A ChannelHandler to execute the send-side of the internode handshake protocol.
OutboundConnectionInitiator.Result<SuccessType extends OutboundConnectionInitiator.Result.Success>	The result of the handshake.
OutboundConnectionInitiator.Result.MessagingSuccess
OutboundConnectionInitiator.Result.StreamingSuccess
OutboundConnectionInitiator.Result.Success<SuccessType extends OutboundConnectionInitiator.Result.Success>
OutboundConnections	Groups a set of outbound connections to a given peer, and routes outgoing messages to the appropriate connection (based upon message's type or size).
OutboundConnectionSettings	A collection of settings to be passed around for outbound connections.
OutboundSink	A message sink that all outbound messages go through.
RateBasedBackPressure	Back-pressure algorithm based on rate limiting according to the ratio between incoming and outgoing rates, computed over a sliding time window with size equal to write RPC timeout.
RequestCallbacks	An expiring map of request callbacks.
ResourceLimits
ResourceLimits.Concurrent	A thread-safe permit container.
ResourceLimits.EndpointAndGlobal	A convenience class that groups a per-endpoint limit with the global one to allow allocating/releasing permits from/to both limits as one logical operation.
SharedDefaultFileRegion	Netty's DefaultFileRegion closes the underlying FileChannel as soon as the refCnt() for the region drops to zero, this is an implementation of the DefaultFileRegion that doesn't close the FileChannel.
SharedDefaultFileRegion.SharedFileChannel
SocketFactory	A factory for building Netty Channels.
StartupClusterConnectivityChecker

Enum Summary

Enum	Description
ConnectionCategory
ConnectionType
MessageFlag	Binary message flags to be passed as flags field of Message.
OutboundConnectionSettings.Framing
ParamType	Type names and serializers for various parameters that can be put in Message params map.
ResourceLimits.Outcome
Verb	Note that priorities except P0 are presently unused.
Verb.Priority

Exception Summary

Exception	Description
AsyncChannelOutputPlus.FlushException
AsyncStreamingInputPlus.InputTimeoutException
Message.InvalidLegacyProtocolMagic