Package | Description |
---|---|
org.apache.cassandra.audit | |
org.apache.cassandra.cql3 | |
org.apache.cassandra.fql | |
org.apache.cassandra.transport | |
org.apache.cassandra.transport.messages |
Modifier and Type | Method and Description |
---|---|
void |
AuditLogManager.batchSuccess(BatchStatement.Type batchType,
java.util.List<? extends CQLStatement> statements,
java.util.List<java.lang.String> queries,
java.util.List<java.util.List<java.nio.ByteBuffer>> values,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
void |
AuditLogManager.executeSuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
void |
AuditLogManager.querySuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
Modifier and Type | Method and Description |
---|---|
default void |
QueryEvents.Listener.batchSuccess(BatchStatement.Type batchType,
java.util.List<? extends CQLStatement> statements,
java.util.List<java.lang.String> queries,
java.util.List<java.util.List<java.nio.ByteBuffer>> values,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
default void |
QueryEvents.Listener.executeSuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
void |
QueryEvents.notifyBatchSuccess(BatchStatement.Type batchType,
java.util.List<? extends CQLStatement> statements,
java.util.List<java.lang.String> queries,
java.util.List<java.util.List<java.nio.ByteBuffer>> values,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
void |
QueryEvents.notifyExecuteSuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
void |
QueryEvents.notifyQuerySuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
default void |
QueryEvents.Listener.querySuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
Modifier and Type | Method and Description |
---|---|
void |
FullQueryLogger.batchSuccess(BatchStatement.Type type,
java.util.List<? extends CQLStatement> statements,
java.util.List<java.lang.String> queries,
java.util.List<java.util.List<java.nio.ByteBuffer>> values,
QueryOptions queryOptions,
QueryState queryState,
long batchTimeMillis,
Message.Response response)
Log an invocation of a batch of queries
|
void |
FullQueryLogger.executeSuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
void |
FullQueryLogger.querySuccess(CQLStatement statement,
java.lang.String query,
QueryOptions queryOptions,
QueryState queryState,
long queryTimeMillis,
Message.Response response)
Log a single CQL query
|
Modifier and Type | Method and Description |
---|---|
Message.Response |
SimpleClient.execute(Message.Request request) |
protected abstract Message.Response |
Message.Request.execute(QueryState queryState,
long queryStartNanoTime,
boolean traceRequest) |
Modifier and Type | Class and Description |
---|---|
class |
AuthChallenge
SASL challenge sent from client to server
|
class |
AuthenticateMessage
Message to indicate that the server is ready to receive requests.
|
class |
AuthSuccess
Indicates to the client that authentication has succeeded.
|
class |
ErrorMessage
Message to indicate an error to the client.
|
class |
EventMessage |
class |
ReadyMessage
Message to indicate that the server is ready to receive requests.
|
class |
ResultMessage |
static class |
ResultMessage.Prepared |
static class |
ResultMessage.Rows |
static class |
ResultMessage.SchemaChange |
static class |
ResultMessage.SetKeyspace |
static class |
ResultMessage.Void |
class |
SupportedMessage
Message to indicate that the server is ready to receive requests.
|
Modifier and Type | Method and Description |
---|---|
protected Message.Response |
AuthResponse.execute(QueryState queryState,
long queryStartNanoTime,
boolean traceRequest) |
protected Message.Response |
BatchMessage.execute(QueryState state,
long queryStartNanoTime,
boolean traceRequest) |
protected Message.Response |
ExecuteMessage.execute(QueryState state,
long queryStartNanoTime,
boolean traceRequest) |
protected Message.Response |
OptionsMessage.execute(QueryState state,
long queryStartNanoTime,
boolean traceRequest) |
protected Message.Response |
PrepareMessage.execute(QueryState state,
long queryStartNanoTime,
boolean traceRequest) |
protected Message.Response |
QueryMessage.execute(QueryState state,
long queryStartNanoTime,
boolean traceRequest) |
protected Message.Response |
RegisterMessage.execute(QueryState state,
long queryStartNanoTime,
boolean traceRequest) |
protected Message.Response |
StartupMessage.execute(QueryState state,
long queryStartNanoTime,
boolean traceRequest) |
Copyright © 2009-2020 The Apache Software Foundation