io.stargate.db.dse.impl.interceptors

Class DefaultQueryInterceptor

java.lang.Object

io.stargate.db.dse.impl.interceptors.DefaultQueryInterceptor

All Implemented Interfaces:

QueryInterceptor, org.apache.cassandra.gms.IEndpointStateChangeSubscriber

public class DefaultQueryInterceptor
extends Object
implements QueryInterceptor, org.apache.cassandra.gms.IEndpointStateChangeSubscriber

A default interceptor implementation that returns only stargate nodes for `system.peers` queries.

Constructor Summary

Constructors

Constructor and Description
DefaultQueryInterceptor()

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.cassandra.gms.IEndpointStateChangeSubscriber

afterRemove, onStarted

Constructor Detail

DefaultQueryInterceptor

public DefaultQueryInterceptor()

Method Detail

initialize

public void initialize()

Specified by:

initialize in interface QueryInterceptor

interceptQuery

public 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)

Specified by:

interceptQuery in interface QueryInterceptor

register

public void register(EventListener listener)

Specified by:

register in interface QueryInterceptor

onJoin

public void onJoin(InetAddress endpoint,
                   org.apache.cassandra.gms.EndpointState state)

Specified by:

onJoin in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriber

beforeChange

public void beforeChange(InetAddress endpoint,
                         org.apache.cassandra.gms.EndpointState currentState,
                         org.apache.cassandra.gms.ApplicationState newStateKey,
                         org.apache.cassandra.gms.VersionedValue newValue)

Specified by:

beforeChange in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriber

onChange

public void onChange(InetAddress endpoint,
                     org.apache.cassandra.gms.ApplicationState state,
                     org.apache.cassandra.gms.VersionedValue value)

Specified by:

onChange in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriber

onAlive

public void onAlive(InetAddress endpoint,
                    org.apache.cassandra.gms.EndpointState state)

Specified by:

onAlive in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriber

onDead

public void onDead(InetAddress endpoint,
                   org.apache.cassandra.gms.EndpointState state)

Specified by:

onDead in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriber

onRemove

public void onRemove(InetAddress endpoint)

Specified by:

onRemove in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriber

onRestart

public void onRestart(InetAddress endpoint,
                      org.apache.cassandra.gms.EndpointState state)

Specified by:

onRestart in interface org.apache.cassandra.gms.IEndpointStateChangeSubscriber