| Package | Description |
|---|---|
| org.apache.cassandra.batchlog | |
| org.apache.cassandra.config | |
| org.apache.cassandra.db | |
| org.apache.cassandra.db.streaming |
File transfer
|
| org.apache.cassandra.gms | |
| org.apache.cassandra.hints |
Hints subsystem consists of several components.
|
| org.apache.cassandra.locator | |
| org.apache.cassandra.metrics | |
| org.apache.cassandra.net | |
| org.apache.cassandra.repair | |
| org.apache.cassandra.repair.consistent | |
| org.apache.cassandra.schema | |
| org.apache.cassandra.service | |
| org.apache.cassandra.service.paxos | |
| org.apache.cassandra.service.reads | |
| org.apache.cassandra.service.reads.repair | |
| org.apache.cassandra.streaming | |
| org.apache.cassandra.streaming.async |
Non-blocking streaming with netty
|
| org.apache.cassandra.tools | |
| org.apache.cassandra.tracing |
| 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 |
|---|
| BackPressureStrategy
Back-pressure algorithm interface.
|
| 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
InboundMessageHandlers 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 |
|---|
| 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 |
| BackPressureState
Interface meant to track the back-pressure state per replica host.
|
| BackPressureStrategy
Back-pressure algorithm interface.
|
| ConnectionCategory |
| ConnectionType |
| 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.
|
| 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. |
| 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).
|
| 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. |
| 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 |
| SharedDefaultFileRegion.SharedFileChannel |
| SocketFactory
A factory for building Netty
Channels. |
| StartupClusterConnectivityChecker |
| Verb
Note that priorities except P0 are presently unused.
|
| 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 |
|---|
| 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. |
Copyright © 2009-2019 The Apache Software Foundation