Package | Description |
---|---|
org.apache.cassandra.batchlog | |
org.apache.cassandra.db | |
org.apache.cassandra.gms | |
org.apache.cassandra.hints |
Hints subsystem consists of several components.
|
org.apache.cassandra.net | |
org.apache.cassandra.repair | |
org.apache.cassandra.service | |
org.apache.cassandra.service.paxos | |
org.apache.cassandra.streaming | |
org.apache.cassandra.tracing |
Modifier and Type | Method and Description |
---|---|
void |
BatchStoreVerbHandler.doVerb(MessageIn<Batch> message,
int id) |
void |
BatchRemoveVerbHandler.doVerb(MessageIn<java.util.UUID> message,
int id) |
Modifier and Type | Method and Description |
---|---|
void |
DefinitionsUpdateVerbHandler.doVerb(MessageIn<java.util.Collection<Mutation>> message,
int id) |
void |
CounterMutationVerbHandler.doVerb(MessageIn<CounterMutation> message,
int id) |
void |
MutationVerbHandler.doVerb(MessageIn<Mutation> message,
int id) |
void |
ReadRepairVerbHandler.doVerb(MessageIn<Mutation> message,
int id) |
void |
ReadCommandVerbHandler.doVerb(MessageIn<ReadCommand> message,
int id) |
void |
TruncateVerbHandler.doVerb(MessageIn<Truncation> message,
int id) |
void |
MigrationRequestVerbHandler.doVerb(MessageIn message,
int id) |
void |
SchemaCheckVerbHandler.doVerb(MessageIn message,
int id) |
Modifier and Type | Method and Description |
---|---|
void |
GossipDigestAckVerbHandler.doVerb(MessageIn<GossipDigestAck> message,
int id) |
void |
GossipDigestAck2VerbHandler.doVerb(MessageIn<GossipDigestAck2> message,
int id) |
void |
GossipDigestSynVerbHandler.doVerb(MessageIn<GossipDigestSyn> message,
int id) |
void |
GossipShutdownVerbHandler.doVerb(MessageIn message,
int id) |
Modifier and Type | Method and Description |
---|---|
void |
HintVerbHandler.doVerb(MessageIn<HintMessage> message,
int id) |
Modifier and Type | Method and Description |
---|---|
static <T> MessageIn<T> |
MessageIn.create(java.net.InetAddress from,
T payload,
java.util.Map<java.lang.String,byte[]> parameters,
MessagingService.Verb verb,
int version) |
static <T> MessageIn<T> |
MessageIn.create(java.net.InetAddress from,
T payload,
java.util.Map<java.lang.String,byte[]> parameters,
MessagingService.Verb verb,
int version,
long constructionTime) |
static <T2> MessageIn<T2> |
MessageIn.read(DataInputPlus in,
int version,
int id) |
static <T2> MessageIn<T2> |
MessageIn.read(DataInputPlus in,
int version,
int id,
long constructionTime) |
Modifier and Type | Method and Description |
---|---|
boolean |
IMessageSink.allowIncomingMessage(MessageIn message,
int id)
Allow or drop an incoming message
|
void |
IVerbHandler.doVerb(MessageIn<T> message,
int id)
This method delivers a message to the implementing class (if the implementing
class was registered by a call to MessagingService.registerVerbHandlers).
|
void |
ResponseVerbHandler.doVerb(MessageIn message,
int id) |
void |
MessagingService.incrementDroppedMessages(MessageIn message,
long timeTaken) |
void |
MessagingService.receive(MessageIn message,
int id) |
void |
AsyncOneResponse.response(MessageIn<T> response) |
void |
IAsyncCallback.response(MessageIn<T> msg) |
Constructor and Description |
---|
MessageDeliveryTask(MessageIn message,
int id) |
Modifier and Type | Method and Description |
---|---|
void |
RepairMessageVerbHandler.doVerb(MessageIn<RepairMessage> message,
int id) |
void |
AnticompactionTask.AnticompactionCallback.response(MessageIn msg) |
Modifier and Type | Field and Description |
---|---|
protected Accumulator<MessageIn<ReadResponse>> |
ResponseResolver.responses |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<MessageIn<ReadResponse>> |
ResponseResolver.getMessages() |
Modifier and Type | Method and Description |
---|---|
void |
EchoVerbHandler.doVerb(MessageIn<EchoMessage> message,
int id) |
void |
SnapshotVerbHandler.doVerb(MessageIn<SnapshotCommand> message,
int id) |
void |
DigestResolver.preprocess(MessageIn<ReadResponse> message) |
void |
ResponseResolver.preprocess(MessageIn<ReadResponse> message) |
void |
TruncateResponseHandler.response(MessageIn message) |
void |
AsyncRepairCallback.response(MessageIn<ReadResponse> message) |
void |
ReadCallback.response(MessageIn<ReadResponse> message) |
abstract void |
AbstractWriteResponseHandler.response(MessageIn<T> msg)
null message means "response from local write"
|
void |
BatchlogResponseHandler.response(MessageIn<T> msg) |
void |
DatacenterSyncWriteResponseHandler.response(MessageIn<T> message) |
void |
DatacenterWriteResponseHandler.response(MessageIn<T> message) |
void |
WriteResponseHandler.response(MessageIn<T> m) |
Modifier and Type | Method and Description |
---|---|
void |
CommitVerbHandler.doVerb(MessageIn<Commit> message,
int id) |
void |
PrepareVerbHandler.doVerb(MessageIn<Commit> message,
int id) |
void |
ProposeVerbHandler.doVerb(MessageIn<Commit> message,
int id) |
void |
ProposeCallback.response(MessageIn<java.lang.Boolean> msg) |
void |
PrepareCallback.response(MessageIn<PrepareResponse> message) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationFinishedVerbHandler.doVerb(MessageIn msg,
int id) |
Modifier and Type | Method and Description |
---|---|
TraceState |
Tracing.initializeFromMessage(MessageIn<?> message)
Determines the tracing context from a message.
|
Copyright © 2018 The Apache Software Foundation