Package | Description |
---|---|
org.apache.cassandra.transport | |
org.apache.cassandra.transport.messages |
Modifier and Type | Method and Description |
---|---|
java.util.Map<Message.Request,Message.Response> |
SimpleClient.execute(java.util.List<Message.Request> requests) |
protected org.apache.cassandra.transport.CQLMessageHandler.MessageConsumer<Message.Request> |
PipelineConfigurator.messageConsumer() |
protected org.apache.cassandra.transport.Message.Decoder<Message.Request> |
PipelineConfigurator.messageDecoder() |
Modifier and Type | Method and Description |
---|---|
protected void |
PreV5Handlers.LegacyDispatchHandler.channelRead0(io.netty.channel.ChannelHandlerContext ctx,
Message.Request request) |
void |
Dispatcher.dispatch(io.netty.channel.Channel channel,
Message.Request request,
org.apache.cassandra.transport.Dispatcher.FlushItemConverter forFlusher) |
Message.Response |
SimpleClient.execute(Message.Request request) |
Message.Response |
SimpleClient.execute(Message.Request request,
boolean throwOnErrorResponse) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<Message.Request,Message.Response> |
SimpleClient.execute(java.util.List<Message.Request> requests) |
Modifier and Type | Class and Description |
---|---|
class |
AuthResponse
A SASL token message sent from client to server.
|
class |
BatchMessage |
class |
ExecuteMessage |
class |
OptionsMessage
Message to indicate that the server is ready to receive requests.
|
class |
PrepareMessage |
class |
QueryMessage
A CQL query
|
class |
RegisterMessage |
class |
StartupMessage
The initial message of the protocol.
|
Copyright © 2009-2022 The Apache Software Foundation