Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.hints |
Hints subsystem consists of several components.
|
org.apache.cassandra.net | |
org.apache.cassandra.repair.messages |
Modifier and Type | Method and Description |
---|---|
MessageOut<Mutation> |
Mutation.createMessage() |
MessageOut |
SnapshotCommand.createMessage() |
MessageOut<TruncateResponse> |
TruncateResponse.createMessage() |
MessageOut<Truncation> |
Truncation.createMessage() |
static MessageOut<WriteResponse> |
WriteResponse.createMessage() |
MessageOut<ReadCommand> |
PartitionRangeReadCommand.createMessage(int version) |
abstract MessageOut<ReadCommand> |
ReadCommand.createMessage(int version)
Creates a message for this command.
|
MessageOut<ReadCommand> |
SinglePartitionReadCommand.createMessage(int version) |
MessageOut<Mutation> |
Mutation.createMessage(MessagingService.Verb verb) |
MessageOut<CounterMutation> |
CounterMutation.makeMutationMessage() |
Modifier and Type | Method and Description |
---|---|
MessageOut<HintMessage> |
HintMessage.createMessageOut() |
Modifier and Type | Method and Description |
---|---|
MessageOut<T> |
MessageOut.withParameter(java.lang.String key,
byte[] value) |
Modifier and Type | Method and Description |
---|---|
int |
MessagingService.addCallback(IAsyncCallback cb,
MessageOut<?> message,
java.net.InetAddress to,
long timeout,
ConsistencyLevel consistencyLevel,
boolean allowHints) |
int |
MessagingService.addCallback(IAsyncCallback cb,
MessageOut message,
java.net.InetAddress to,
long timeout,
boolean failureCallback) |
boolean |
IMessageSink.allowOutgoingMessage(MessageOut message,
int id,
java.net.InetAddress to)
Allow or drop an outgoing message
|
void |
OutboundTcpConnection.enqueue(MessageOut<?> message,
int id) |
OutboundTcpConnection |
MessagingService.getConnection(java.net.InetAddress to,
MessageOut msg) |
void |
BackPressureState.onMessageSent(MessageOut<?> message)
Called when a message is sent to a replica.
|
void |
MessagingService.sendOneWay(MessageOut message,
java.net.InetAddress to) |
void |
MessagingService.sendOneWay(MessageOut message,
int id,
java.net.InetAddress to)
Send a message to a given endpoint.
|
void |
MessagingService.sendReply(MessageOut message,
int id,
java.net.InetAddress to) |
int |
MessagingService.sendRR(MessageOut<?> message,
java.net.InetAddress to,
AbstractWriteResponseHandler<?> handler,
boolean allowHints)
Send a mutation message or a Paxos Commit to a given endpoint.
|
<T> AsyncOneResponse<T> |
MessagingService.sendRR(MessageOut message,
java.net.InetAddress to) |
int |
MessagingService.sendRR(MessageOut message,
java.net.InetAddress to,
IAsyncCallback cb) |
int |
MessagingService.sendRR(MessageOut message,
java.net.InetAddress to,
IAsyncCallback cb,
long timeout,
boolean failureCallback)
Send a non-mutation message to a given endpoint.
|
int |
MessagingService.sendRRWithFailure(MessageOut message,
java.net.InetAddress to,
IAsyncCallbackWithFailure cb) |
void |
MessagingService.updateBackPressureOnSend(java.net.InetAddress host,
IAsyncCallback callback,
MessageOut<?> message)
Updates the back-pressure state on sending to the given host if enabled and the given message callback supports it.
|
Constructor and Description |
---|
WriteCallbackInfo(java.net.InetAddress target,
IAsyncCallback callback,
MessageOut message,
IVersionedSerializer<?> serializer,
ConsistencyLevel consistencyLevel,
boolean allowHints) |
Modifier and Type | Method and Description |
---|---|
MessageOut<RepairMessage> |
RepairMessage.createMessage() |
Copyright © 2020 The Apache Software Foundation