io.stargate.db.dse.impl.interceptors

Class ProxyProtocolQueryInterceptor

java.lang.Object

io.stargate.db.dse.impl.interceptors.ProxyProtocolQueryInterceptor

All Implemented Interfaces:

QueryInterceptor

public class ProxyProtocolQueryInterceptor
extends Object
implements QueryInterceptor

A query interceptor that echos back the public IPs from the proxy protocol from `system.local`. `system.peers` is populated with A-records from a provided DNS name.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ProxyProtocolQueryInterceptor.Resolver A class that takes a name and resolves InetAddresss.

Field Summary

Fields

Modifier and Type	Field and Description
static String	PROXY_DNS_NAME
static int	PROXY_PORT
static long	RESOLVE_DELAY_SECS

Constructor Summary

Constructors

Constructor and Description
ProxyProtocolQueryInterceptor()
ProxyProtocolQueryInterceptor(ProxyProtocolQueryInterceptor.Resolver resolver, String proxyDnsName, int proxyPort, long resolveDelaySecs)
ProxyProtocolQueryInterceptor(QueryInterceptor wrapped)

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)

Methods inherited from class java.lang.Object

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

Field Detail

PROXY_DNS_NAME

public static final String PROXY_DNS_NAME

PROXY_PORT

public static final int PROXY_PORT

RESOLVE_DELAY_SECS

public static final long RESOLVE_DELAY_SECS

Constructor Detail

ProxyProtocolQueryInterceptor

public ProxyProtocolQueryInterceptor(QueryInterceptor wrapped)

ProxyProtocolQueryInterceptor

public ProxyProtocolQueryInterceptor()

ProxyProtocolQueryInterceptor

public ProxyProtocolQueryInterceptor(ProxyProtocolQueryInterceptor.Resolver resolver,
                                     String proxyDnsName,
                                     int proxyPort,
                                     long resolveDelaySecs)

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