Uses of Package
org.apache.cassandra.net
-
Classes in org.apache.cassandra.net used by org.apache.cassandra.batchlog Class Description IVerbHandler IVerbHandler provides the method that all verb handlers need to implement.Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
fused in one class. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.db Class Description IVerbHandler IVerbHandler provides the method that all verb handlers need to implement.Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
fused in one class.Verb Note that priorities except P0 are presently unused. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.db.streaming Class Description AsyncStreamingOutputPlus ADataOutputStreamPlus
that writes ASYNCHRONOUSLY to a Netty Channel. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.gms Class Description IVerbHandler IVerbHandler provides the method that all verb handlers need to implement.Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
fused in one class. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.hints Class Description IVerbHandler IVerbHandler provides the method that all verb handlers need to implement.Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
fused in one class. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.locator Class Description LatencySubscribers.Subscriber -
Classes in org.apache.cassandra.net used by org.apache.cassandra.metrics Class Description InboundMessageHandlers An aggregation ofInboundMessageHandler
s for all connections from a peer.InboundMessageHandlers.GlobalMetricCallbacks LatencyConsumer Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
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. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.net Class Description AbstractMessageHandler Core logic for handling inbound message deserialization and execution (in tandem withFrameDecoder
).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 ADataOutputStreamPlus
that writes ASYNCHRONOUSLY to a Netty Channel.AsyncChannelPromise SeeAsyncPromise
andChannelPromise
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 toInboundMessageHandler
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 theFrameEncoder
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 seeFrameDecoderCrc
for description of the framing produced by this encoder.FrameEncoderLZ4 Please seeFrameDecoderLZ4
for description of the framing produced by this encoder.GlobalBufferPoolAllocator InboundConnectionSettings InboundMessageHandlers An aggregation ofInboundMessageHandler
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 thatDynamicEndpointSnitch
listens to in order to update host scores.LatencySubscribers.Subscriber Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
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 asflags
field ofMessage
.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 nettyChannel
.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 inMessage
params map.PingRequest Indicates to the recipient whichConnectionType
should be used for the response.RequestCallback implementors ofRequestCallback
need to make sure that any public methods are threadsafe with respect toRequestCallback.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 NettyChannel
s.StartupClusterConnectivityChecker Verb Note that priorities except P0 are presently unused.Verb.Kind Verb.Priority -
Classes in org.apache.cassandra.net used by org.apache.cassandra.repair Class Description IVerbHandler IVerbHandler provides the method that all verb handlers need to implement.Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
fused in one class. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.repair.consistent Class Description Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
fused in one class. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.schema Class Description IVerbHandler IVerbHandler provides the method that all verb handlers need to implement.Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
fused in one class.NoPayload Empty message payload - primarily used for responses. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.service Class Description IVerbHandler IVerbHandler provides the method that all verb handlers need to implement.Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
fused in one class.NoPayload Empty message payload - primarily used for responses.RequestCallback implementors ofRequestCallback
need to make sure that any public methods are threadsafe with respect toRequestCallback.onResponse(org.apache.cassandra.net.Message<T>)
being called from the message service. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.service.paxos Class Description IVerbHandler IVerbHandler provides the method that all verb handlers need to implement.Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
fused in one class.RequestCallback implementors ofRequestCallback
need to make sure that any public methods are threadsafe with respect toRequestCallback.onResponse(org.apache.cassandra.net.Message<T>)
being called from the message service. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.service.reads Class Description Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
fused in one class.RequestCallback implementors ofRequestCallback
need to make sure that any public methods are threadsafe with respect toRequestCallback.onResponse(org.apache.cassandra.net.Message<T>)
being called from the message service. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.service.reads.repair Class Description Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
fused in one class.RequestCallback implementors ofRequestCallback
need to make sure that any public methods are threadsafe with respect toRequestCallback.onResponse(org.apache.cassandra.net.Message<T>)
being called from the message service. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.streaming Class Description IVerbHandler IVerbHandler provides the method that all verb handlers need to implement.Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
fused in one class.OutboundConnectionSettings A collection of settings to be passed around for outbound connections. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.streaming.async Class Description AsyncStreamingOutputPlus.Write OutboundConnectionSettings A collection of settings to be passed around for outbound connections. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.tools Class 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. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.tracing Class Description Message Immutable main unit of internode communication - what used to beMessageIn
andMessageOut
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 inMessage
params map. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.transport Class Description AbstractMessageHandler Core logic for handling inbound message deserialization and execution (in tandem withFrameDecoder
).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 toInboundMessageHandler
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.