Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.metrics | |
org.apache.cassandra.net |
Modifier and Type | Method and Description |
---|---|
MessageOut<Mutation> |
Mutation.createMessage(MessagingService.Verb verb) |
Constructor and Description |
---|
DroppedMessageMetrics(MessagingService.Verb verb) |
Modifier and Type | Field and Description |
---|---|
MessagingService.Verb |
MessageIn.verb |
MessagingService.Verb |
MessageOut.verb |
static MessagingService.Verb[] |
MessagingService.verbValues |
Modifier and Type | Field and Description |
---|---|
static java.util.EnumMap<MessagingService.Verb,IVersionedSerializer<?>> |
MessagingService.callbackDeserializers
A Map of what kind of serializer to wire up to a REQUEST_RESPONSE callback, based on outbound Verb.
|
static java.util.EnumSet<MessagingService.Verb> |
MessagingService.DROPPABLE_VERBS
Verbs it's okay to drop if the request has been queued longer than the request timeout.
|
java.util.EnumMap<MessagingService.Verb,IVersionedSerializer<?>> |
MessagingService.verbSerializers
Messages we receive in IncomingTcpConnection have a Verb that tells us what kind of message it is.
|
static java.util.EnumMap<MessagingService.Verb,Stage> |
MessagingService.verbStages |
Modifier and Type | Method and Description |
---|---|
static MessagingService.Verb |
MessagingService.Verb.convertForMessagingServiceVersion(MessagingService.Verb verb,
int version) |
static MessagingService.Verb |
MessagingService.Verb.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static MessagingService.Verb[] |
MessagingService.Verb.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static MessagingService.Verb |
MessagingService.Verb.convertForMessagingServiceVersion(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) |
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) |
IVerbHandler |
MessagingService.getVerbHandler(MessagingService.Verb type)
This method returns the verb handler associated with the registered
verb.
|
void |
MessagingService.incrementDroppedMessages(MessagingService.Verb verb) |
void |
MessagingService.incrementDroppedMessages(MessagingService.Verb verb,
boolean isCrossNode) |
void |
MessagingService.incrementDroppedMessages(MessagingService.Verb verb,
long timeTaken) |
void |
MessagingService.incrementDroppedMessages(MessagingService.Verb verb,
long timeTaken,
boolean isCrossNode) |
void |
MessagingService.registerVerbHandlers(MessagingService.Verb verb,
IVerbHandler verbHandler)
Register a verb and the corresponding verb handler with the
Messaging Service.
|
Constructor and Description |
---|
MessageOut(java.net.InetAddress from,
MessagingService.Verb verb,
T payload,
IVersionedSerializer<T> serializer,
java.util.Map<java.lang.String,byte[]> parameters) |
MessageOut(MessagingService.Verb verb) |
MessageOut(MessagingService.Verb verb,
T payload,
IVersionedSerializer<T> serializer) |
Copyright © 2020 The Apache Software Foundation