Uses of Package
org.apache.cassandra.net
Packages that use org.apache.cassandra.net
Package
Description
Hints subsystem consists of several components.
Non-blocking streaming with netty
-
Classes in org.apache.cassandra.net used by org.apache.cassandra.batchlogClassDescriptionIVerbHandler provides the method that all verb handlers need to implement.Immutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.dbClassDescriptionIVerbHandler provides the method that all verb handlers need to implement.Immutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class.Type names and serializers for various parameters that can be put inMessageparams map.Note that priorities except P0 are presently unused. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.gmsClassDescriptionIVerbHandler provides the method that all verb handlers need to implement.Immutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.hintsClassDescriptionIVerbHandler provides the method that all verb handlers need to implement.Immutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.locator
-
Classes in org.apache.cassandra.net used by org.apache.cassandra.metricsClassDescriptionAn aggregation of
InboundMessageHandlers for all connections from a peer.Immutable main unit of internode communication - what used to beMessageInandMessageOutfused in one class.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).Note that priorities except P0 are presently unused. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.netClassDescriptionCore logic for handling inbound message deserialization and execution (in tandem with
FrameDecoder).A special-purpose wait queue to park inbound message handlers that failed to allocate reserve capacity for a message in.ADataOutputStreamPlusthat writes ASYNCHRONOUSLY to a Netty Channel.SeeAsyncPromiseandChannelPromiseThis class is all boiler plate, just ensuring we return ourselves and invoke the correct Promise method.A callback specialized for returning a value from a single target; that is, this is for messages that we only send to one recipient.A trivial wrapper around BufferPool for integrating with Netty, but retaining ownership of pooling behaviour that is integrated into Cassandra's other pooling.Map of hosts to their known current messaging versions.A container used to store a node -> message_id map for inter-DC write forwarding.A Netty inbound handler that decodes incoming frames and passes them forward toInboundMessageHandlerfor processing.A corrupted frame was encountered; this represents the knowledge we have about this frame, and whether or not the stream is recoverable.The payload bytes of a complete frame, i.e.Framing format that protects integrity of data in movement with CRCs (of both header and payload).Framing format that compresses payloads with LZ4, and protects integrity of data in movement with CRCs (of both header and payload).An abstraction useful for transparently allocating buffers that can be written to upstream of theFrameEncoderwithout knowledge of the encoder's frame layout, while ensuring enough space to write the remainder of the frame's contents is reserved.Please seeFrameDecoderCrcfor description of the framing produced by this encoder.Please seeFrameDecoderLZ4for description of the framing produced by this encoder.A delegating future, that we can extend to provide subtly modified behaviour.An aggregation ofInboundMessageHandlers for all connections from a peer.A message sink that all inbound messages go through.IVerbHandler provides the method that all verb handlers need to implement.Callback thatDynamicEndpointSnitchlistens to in order to update host scores.Immutable main unit of internode communication - what used to beMessageInandMessageOutfused in one class.Split into a separate object to allow partial message deserialization without wasting work and allocation afterwards, if the entire message is necessary and available.Each message contains a header with several fixed fields, an optional key-value params section, and then the message payload itself.Binary message flags to be passed asflagsfield ofMessage.MessagingService implements all internode communication - with the exception of SSTable streaming (for now).MBean exposing MessagingService metrics plus allowing to enable/disable back-pressure.Empty message payload - primarily used for responses.Represents a connection type to a peer, and handles the state transistions on the connection and the nettyChannel.The result of the handshake.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).A collection of settings to be passed around for outbound connections.A message sink that all outbound messages go through.Type names and serializers for various parameters that can be put inMessageparams map.Indicates to the recipient whichConnectionTypeshould be used for the response.implementors ofRequestCallbackneed 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.An expiring map of request callbacks.Represents permits to utilise a resource and ways to allocate and release them.A wrapper for possibly sharing portions of a single,BufferPools.forNetworking()managed,ByteBuffer; optimised for the case where no sharing is necessary.A factory for building NettyChannels.Note that priorities except P0 are presently unused. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.repairClassDescriptionIVerbHandler provides the method that all verb handlers need to implement.Immutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.repair.consistentClassDescriptionImmutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.repair.messagesClassDescriptionImmutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class.implementors ofRequestCallbackneed 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.Note that priorities except P0 are presently unused. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.schemaClassDescriptionIVerbHandler provides the method that all verb handlers need to implement.Immutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class.MessagingService implements all internode communication - with the exception of SSTable streaming (for now).Empty message payload - primarily used for responses. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.serviceClassDescriptionIVerbHandler provides the method that all verb handlers need to implement.Immutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class.Empty message payload - primarily used for responses.implementors ofRequestCallbackneed 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.paxosClassDescriptionIVerbHandler provides the method that all verb handlers need to implement.Immutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class.Empty message payload - primarily used for responses.implementors ofRequestCallbackneed 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.cleanupClassDescriptionIVerbHandler provides the method that all verb handlers need to implement.Immutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class.implementors ofRequestCallbackneed 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.v1ClassDescriptionIVerbHandler provides the method that all verb handlers need to implement.Immutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class.implementors ofRequestCallbackneed 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.readsClassDescriptionImmutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class.implementors ofRequestCallbackneed 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.repairClassDescriptionImmutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class.implementors ofRequestCallbackneed 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.thresholds
-
Classes in org.apache.cassandra.net used by org.apache.cassandra.streamingClassDescriptionIVerbHandler provides the method that all verb handlers need to implement.Immutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class.A collection of settings to be passed around for outbound connections. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.streaming.asyncClassDescriptionA collection of settings to be passed around for outbound connections.
-
Classes in org.apache.cassandra.net used by org.apache.cassandra.toolsClassDescriptionMBean exposing MessagingService metrics plus allowing to enable/disable back-pressure.
-
Classes in org.apache.cassandra.net used by org.apache.cassandra.tracingClassDescriptionImmutable main unit of internode communication - what used to be
MessageInandMessageOutfused in one class.Split into a separate object to allow partial message deserialization without wasting work and allocation afterwards, if the entire message is necessary and available.Type names and serializers for various parameters that can be put inMessageparams map. -
Classes in org.apache.cassandra.net used by org.apache.cassandra.transportClassDescriptionCore logic for handling inbound message deserialization and execution (in tandem with
FrameDecoder).A trivial wrapper around BufferPool for integrating with Netty, but retaining ownership of pooling behaviour that is integrated into Cassandra's other pooling.A Netty inbound handler that decodes incoming frames and passes them forward toInboundMessageHandlerfor processing.A corrupted frame was encountered; this represents the knowledge we have about this frame, and whether or not the stream is recoverable.The payload bytes of a complete frame, i.e.Represents permits to utilise a resource and ways to allocate and release them.A wrapper for possibly sharing portions of a single,BufferPools.forNetworking()managed,ByteBuffer; optimised for the case where no sharing is necessary.