io.stargate.db.cassandra.impl.interceptors

Class DefaultQueryInterceptor

java.lang.Object

io.stargate.db.cassandra.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(org.apache.cassandra.locator.InetAddressAndPort endpoint, org.apache.cassandra.gms.EndpointState currentState, org.apache.cassandra.gms.ApplicationState newStateKey, org.apache.cassandra.gms.VersionedValue newValue)
void	initialize()
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(org.apache.cassandra.locator.InetAddressAndPort endpoint, org.apache.cassandra.gms.EndpointState state)
void	onChange(org.apache.cassandra.locator.InetAddressAndPort endpoint, org.apache.cassandra.gms.ApplicationState state, org.apache.cassandra.gms.VersionedValue value)
void	onDead(org.apache.cassandra.locator.InetAddressAndPort endpoint, org.apache.cassandra.gms.EndpointState state)
void	onJoin(org.apache.cassandra.locator.InetAddressAndPort endpoint, org.apache.cassandra.gms.EndpointState state)
void	onRemove(org.apache.cassandra.locator.InetAddressAndPort endpoint)
void	onRestart(org.apache.cassandra.locator.InetAddressAndPort 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

Constructor Detail

DefaultQueryInterceptor

public DefaultQueryInterceptor()

Method Detail

initialize

public void initialize()

Specified by:

initialize in interface QueryInterceptor

interceptQuery

public 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(org.apache.cassandra.locator.InetAddressAndPort endpoint,
                   org.apache.cassandra.gms.EndpointState state)

Specified by:

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

beforeChange

public void beforeChange(org.apache.cassandra.locator.InetAddressAndPort 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(org.apache.cassandra.locator.InetAddressAndPort 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(org.apache.cassandra.locator.InetAddressAndPort endpoint,
                    org.apache.cassandra.gms.EndpointState state)

Specified by:

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

onDead

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

Specified by:

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

onRemove

public void onRemove(org.apache.cassandra.locator.InetAddressAndPort endpoint)

Specified by:

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

onRestart

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

Specified by:

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