Class and Description |
---|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
Class and Description |
---|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
Verb
Note that priorities except P0 are presently unused.
|
Class and Description |
---|
AsyncStreamingOutputPlus
A
DataOutputStreamPlus that writes ASYNCHRONOUSLY to a Netty Channel. |
Class and Description |
---|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
Class and Description |
---|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
Class and Description |
---|
LatencySubscribers.Subscriber |
Class and Description |
---|
InboundMessageHandlers
An aggregation of
InboundMessageHandler s for all connections from a peer. |
InboundMessageHandlers.GlobalMetricCallbacks |
LatencyConsumer |
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
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).
|
Verb
Note that priorities except P0 are presently unused.
|
Class and Description |
---|
AbstractMessageHandler
Core logic for handling inbound message deserialization and execution (in tandem with
FrameDecoder ). |
AbstractMessageHandler.LargeMessage |
AbstractMessageHandler.OnHandlerClosed |
AbstractMessageHandler.WaitQueue
A special-purpose wait queue to park inbound message handlers that failed to allocate
reserve capacity for a message in.
|
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. |
AsyncOneResponse
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
Netty's DefaultPromise uses a mutex to coordinate notifiers AND waiters between the eventLoop and the other threads.
|
AsyncStreamingInputPlus.Consumer |
AsyncStreamingInputPlus.InputTimeoutException |
AsyncStreamingOutputPlus.BufferSupplier |
AsyncStreamingOutputPlus.Write |
BufferPoolAllocator
A trivial wrapper around BufferPool for integrating with Netty, but retaining ownership of pooling behaviour
that is integrated into Cassandra's other pooling.
|
ConnectionCategory |
ConnectionType |
Crc.InvalidCrc |
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.
|
FrameDecoder
A Netty inbound handler that decodes incoming frames and passes them forward to
InboundMessageHandler for processing. |
FrameDecoder.CorruptFrame
A corrupted frame was encountered; this represents the knowledge we have about this frame,
and whether or not the stream is recoverable.
|
FrameDecoder.Frame |
FrameDecoder.FrameProcessor |
FrameDecoder.IntactFrame
The payload bytes of a complete frame, i.e.
|
FrameDecoderCrc
Framing format that protects integrity of data in movement with CRCs (of both header and payload).
|
FrameDecoderLZ4
Framing format that compresses payloads with LZ4, and protects integrity of data in movement with CRCs
(of both header and payload).
|
FrameEncoder |
FrameEncoder.Payload
An abstraction useful for transparently allocating buffers that can be written to upstream
of the
FrameEncoder without knowledge of the encoder's frame layout, while ensuring
enough space to write the remainder of the frame's contents is reserved. |
FrameEncoder.PayloadAllocator |
FrameEncoderCrc
Please see
FrameDecoderCrc for description of the framing produced by this encoder. |
FrameEncoderLZ4
Please see
FrameDecoderLZ4 for description of the framing produced by this encoder. |
GlobalBufferPoolAllocator |
InboundConnectionSettings |
InboundMessageHandlers
An aggregation of
InboundMessageHandler s for all connections from a peer. |
InboundMessageHandlers.GlobalMetricCallbacks |
InboundMessageHandlers.MessageConsumer |
InboundSink
A message sink that all inbound messages go through.
|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
LatencyConsumer |
LatencySubscribers
Callback that
DynamicEndpointSnitch listens to in order
to update host scores. |
LatencySubscribers.Subscriber |
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
Message.Builder |
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.
|
MessageFlag
Binary message flags to be passed as
flags field of Message . |
MessagingService
MessagingService implements all internode communication - with the exception of SSTable streaming (for now).
|
MessagingService.Version |
MessagingServiceMBean
MBean exposing MessagingService metrics plus allowing to enable/disable back-pressure.
|
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.Result
The result of the handshake.
|
OutboundConnectionInitiator.Result.StreamingSuccess |
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.
|
OutboundConnectionSettings.Framing |
OutboundSink
A message sink that all outbound messages go through.
|
ParamType
Type names and serializers for various parameters that can be put in
Message params map. |
PingRequest
Indicates to the recipient which
ConnectionType should be used for the response. |
RequestCallback
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. |
RequestCallbacks
An expiring map of request callbacks.
|
ResourceLimits.Limit
Represents permits to utilise a resource and ways to allocate and release them.
|
ResourceLimits.Outcome |
ShareableBytes
A wrapper for possibly sharing portions of a single,
BufferPools.forNetworking() managed, ByteBuffer ;
optimised for the case where no sharing is necessary. |
SharedDefaultFileRegion.SharedFileChannel |
SocketFactory
A factory for building Netty
Channel s. |
StartupClusterConnectivityChecker |
Verb
Note that priorities except P0 are presently unused.
|
Verb.Kind |
Verb.Priority |
Class and Description |
---|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
Class and Description |
---|
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
Class and Description |
---|
Verb
Note that priorities except P0 are presently unused.
|
Class and Description |
---|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
NoPayload
Empty message payload - primarily used for responses.
|
Class and Description |
---|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
NoPayload
Empty message payload - primarily used for responses.
|
RequestCallback
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. |
Class and Description |
---|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
RequestCallback
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. |
Class and Description |
---|
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
RequestCallback
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. |
Class and Description |
---|
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
RequestCallback
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. |
Class and Description |
---|
IVerbHandler
IVerbHandler provides the method that all verb handlers need to implement.
|
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
OutboundConnectionSettings
A collection of settings to be passed around for outbound connections.
|
Class and Description |
---|
AsyncStreamingOutputPlus.Write |
OutboundConnectionSettings
A collection of settings to be passed around for outbound connections.
|
Class and Description |
---|
MessagingServiceMBean
MBean exposing MessagingService metrics plus allowing to enable/disable back-pressure.
|
OutboundConnectionSettings
A collection of settings to be passed around for outbound connections.
|
Class and Description |
---|
Message
Immutable main unit of internode communication - what used to be
MessageIn and MessageOut fused
in one class. |
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.
|
ParamType
Type names and serializers for various parameters that can be put in
Message params map. |
Class and Description |
---|
AbstractMessageHandler
Core logic for handling inbound message deserialization and execution (in tandem with
FrameDecoder ). |
BufferPoolAllocator
A trivial wrapper around BufferPool for integrating with Netty, but retaining ownership of pooling behaviour
that is integrated into Cassandra's other pooling.
|
FrameDecoder
A Netty inbound handler that decodes incoming frames and passes them forward to
InboundMessageHandler for processing. |
FrameDecoder.CorruptFrame
A corrupted frame was encountered; this represents the knowledge we have about this frame,
and whether or not the stream is recoverable.
|
FrameDecoder.Frame |
FrameDecoder.FrameProcessor |
FrameDecoder.IntactFrame
The payload bytes of a complete frame, i.e.
|
FrameEncoder |
FrameEncoder.PayloadAllocator |
ResourceLimits.Limit
Represents permits to utilise a resource and ways to allocate and release them.
|
ShareableBytes
A wrapper for possibly sharing portions of a single,
BufferPools.forNetworking() managed, ByteBuffer ;
optimised for the case where no sharing is necessary. |
Copyright © 2009-2022 The Apache Software Foundation