io.stargate.db.dse.impl.interceptors

Interface QueryInterceptor

All Known Implementing Classes:

DefaultQueryInterceptor, ProxyProtocolQueryInterceptor

public interface QueryInterceptor

An interface for intercepting queries and node lifecycle events. It's used to intercept `system.local` and `system.peers` queries and topology events for stargate nodes.

Method Summary

Modifier and Type	Method and Description
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	register(EventListener listener)

Method Detail

initialize

void initialize()

interceptQuery

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)

register

void register(EventListener listener)