Package | Description |
---|---|
org.apache.cassandra.batchlog | |
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 |
---|
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 |
---|
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 |
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
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 |
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 |
---|
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-2020 The Apache Software Foundation