Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.metrics | |
org.apache.cassandra.net | |
org.apache.cassandra.repair.messages |
Modifier and Type | Method and Description |
---|---|
Verb |
PartitionRangeReadCommand.verb() |
abstract Verb |
ReadCommand.verb() |
Verb |
SinglePartitionReadCommand.verb() |
Modifier and Type | Field and Description |
---|---|
java.util.EnumMap<Verb,com.codahale.metrics.Timer> |
MessagingMetrics.internalLatency |
Modifier and Type | Method and Description |
---|---|
void |
MessagingMetrics.recordDroppedMessage(Verb verb,
long timeElapsed,
java.util.concurrent.TimeUnit timeUnit,
boolean isCrossNode) |
void |
MessagingMetrics.recordInternalLatency(Verb verb,
long timeTaken,
java.util.concurrent.TimeUnit units) |
void |
MessagingMetrics.recordInternodeDroppedMessage(Verb verb,
long timeElapsed,
java.util.concurrent.TimeUnit timeUnit) |
void |
MessagingMetrics.recordSelfDroppedMessage(Verb verb) |
void |
MessagingMetrics.recordSelfDroppedMessage(Verb verb,
long timeElapsed,
java.util.concurrent.TimeUnit timeUnit) |
Constructor and Description |
---|
DroppedMessageMetrics(Verb verb) |
Modifier and Type | Field and Description |
---|---|
Verb |
Message.Header.verb |
Modifier and Type | Field and Description |
---|---|
static java.util.List<Verb> |
Verb.VERBS |
Modifier and Type | Method and Description |
---|---|
static Verb |
Verb.fromId(int id) |
static Verb |
Verb.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static Verb[] |
Verb.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Verb |
Message.verb() |
Modifier and Type | Method and Description |
---|---|
static <T> Message.Builder<T> |
Message.builder(Verb verb,
T payload) |
static <T> Message<T> |
Message.internalResponse(Verb verb,
T payload) |
Message.Builder<T> |
Message.Builder.ofVerb(Verb verb) |
static <T> Message<T> |
Message.out(Verb verb,
T payload)
Make a request
Message with supplied verb and payload. |
static <T> Message<T> |
Message.out(Verb verb,
T payload,
long expiresAtNanos) |
static <T> Message<T> |
Message.outWithFlag(Verb verb,
T payload,
MessageFlag flag) |
static <T> Message<T> |
Message.outWithFlags(Verb verb,
T payload,
MessageFlag flag1,
MessageFlag flag2) |
void |
InboundMessageHandlers.GlobalMetricCallbacks.recordInternalLatency(Verb verb,
long timeElapsed,
java.util.concurrent.TimeUnit timeUnit) |
void |
InboundMessageHandlers.GlobalMetricCallbacks.recordInternodeDroppedMessage(Verb verb,
long timeElapsed,
java.util.concurrent.TimeUnit timeUnit) |
Modifier and Type | Method and Description |
---|---|
static void |
RepairMessage.sendMessageWithFailureCB(RepairMessage request,
Verb verb,
InetAddressAndPort endpoint,
RepairMessage.RepairFailureCallback failureCallback) |
Copyright © 2009-2022 The Apache Software Foundation