public class DefaultQueryInterceptor extends Object implements QueryInterceptor, org.apache.cassandra.gms.IEndpointStateChangeSubscriber
| Constructor and Description |
|---|
DefaultQueryInterceptor() |
| Modifier and Type | Method and Description |
|---|---|
void |
beforeChange(InetAddress endpoint,
org.apache.cassandra.gms.EndpointState currentState,
org.apache.cassandra.gms.ApplicationState newStateKey,
org.apache.cassandra.gms.VersionedValue newValue) |
void |
initialize() |
io.reactivex.Single<org.apache.cassandra.transport.messages.ResultMessage> |
interceptQuery(org.apache.cassandra.cql3.CQLStatement statement,
org.apache.cassandra.service.QueryState state,
org.apache.cassandra.cql3.QueryOptions options,
Map<String,ByteBuffer> customPayload,
long queryStartNanoTime) |
void |
onAlive(InetAddress endpoint,
org.apache.cassandra.gms.EndpointState state) |
void |
onChange(InetAddress endpoint,
org.apache.cassandra.gms.ApplicationState state,
org.apache.cassandra.gms.VersionedValue value) |
void |
onDead(InetAddress endpoint,
org.apache.cassandra.gms.EndpointState state) |
void |
onJoin(InetAddress endpoint,
org.apache.cassandra.gms.EndpointState state) |
void |
onRemove(InetAddress endpoint) |
void |
onRestart(InetAddress endpoint,
org.apache.cassandra.gms.EndpointState state) |
void |
register(EventListener listener) |
public void initialize()
initialize in interface QueryInterceptorpublic io.reactivex.Single<org.apache.cassandra.transport.messages.ResultMessage> interceptQuery(org.apache.cassandra.cql3.CQLStatement statement,
org.apache.cassandra.service.QueryState state,
org.apache.cassandra.cql3.QueryOptions options,
Map<String,ByteBuffer> customPayload,
long queryStartNanoTime)
interceptQuery in interface QueryInterceptorpublic void register(EventListener listener)
register in interface QueryInterceptorpublic void onJoin(InetAddress endpoint, org.apache.cassandra.gms.EndpointState state)
onJoin in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriberpublic void beforeChange(InetAddress endpoint, org.apache.cassandra.gms.EndpointState currentState, org.apache.cassandra.gms.ApplicationState newStateKey, org.apache.cassandra.gms.VersionedValue newValue)
beforeChange in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriberpublic void onChange(InetAddress endpoint, org.apache.cassandra.gms.ApplicationState state, org.apache.cassandra.gms.VersionedValue value)
onChange in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriberpublic void onAlive(InetAddress endpoint, org.apache.cassandra.gms.EndpointState state)
onAlive in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriberpublic void onDead(InetAddress endpoint, org.apache.cassandra.gms.EndpointState state)
onDead in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriberpublic void onRemove(InetAddress endpoint)
onRemove in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriberpublic void onRestart(InetAddress endpoint, org.apache.cassandra.gms.EndpointState state)
onRestart in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriberCopyright © 2020. All rights reserved.