Skip navigation links
A B C E F H I L M N P R T U W 

A

Aegis - Class in io.confluent.aegis.proxy
The main class for the Aegis proxy.
Aegis(LogContext, AegisConfig) - Constructor for class io.confluent.aegis.proxy.Aegis
 
AegisConfig - Class in io.confluent.aegis.config
The Aegis configuration class.
AegisConfig(Properties) - Constructor for class io.confluent.aegis.config.AegisConfig
 
AegisConfig(Map<?, ?>) - Constructor for class io.confluent.aegis.config.AegisConfig
 
AegisConfig(String...) - Constructor for class io.confluent.aegis.config.AegisConfig
Initialize an AegisConfig based on some key/value pairs.
AegisConfig(Map<?, ?>, boolean) - Constructor for class io.confluent.aegis.config.AegisConfig
 

B

beginShutdown() - Method in class io.confluent.aegis.proxy.Aegis
 
BROKER_ENDPOINTS_CONFIG - Static variable in class io.confluent.aegis.config.AegisConfig
 
BROKER_ENDPOINTS_DOC - Static variable in class io.confluent.aegis.config.AegisConfig
 
brokerBootstrap() - Method in class io.confluent.aegis.proxy.WorkerPool
 
brokerEndpoint() - Method in class io.confluent.aegis.proxy.EndPointPair
 
brokerEndpointConfig() - Method in class io.confluent.aegis.proxy.EndPointPair
 
brokerIndex() - Method in class io.confluent.aegis.proxy.WorkerPool
 
BrokerReader - Class in io.confluent.aegis.proxy
Reads the Kafka responses sent back from the broker.
BrokerWriter - Class in io.confluent.aegis.proxy
Writes Kafka requests to the broker.
ByteBufAccessor - Class in io.confluent.aegis.common
 
ByteBufAccessor(ByteBuf) - Constructor for class io.confluent.aegis.common.ByteBufAccessor
 

C

channelActive(ChannelHandlerContext) - Method in class io.confluent.aegis.proxy.BrokerReader
 
close() - Method in class io.confluent.aegis.proxy.Flow
 
configNames() - Static method in class io.confluent.aegis.config.AegisConfig
 

E

EndPointPair - Class in io.confluent.aegis.proxy
A pair of endpoints.
EndPointPair(int, EndPoint, AegisConfig, EndPoint, AegisConfig) - Constructor for class io.confluent.aegis.proxy.EndPointPair
 
endPointPair() - Method in class io.confluent.aegis.proxy.WorkerPool
 
equals(Object) - Method in class io.confluent.aegis.proxy.Flow
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class io.confluent.aegis.proxy.BrokerReader
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class io.confluent.aegis.proxy.BrokerWriter
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class io.confluent.aegis.proxy.TenantReader
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class io.confluent.aegis.proxy.TenantWriter
 

F

Flow - Class in io.confluent.aegis.proxy
Represents a tenant connection and any associated resources, such as a broker connection.

H

hashCode() - Method in class io.confluent.aegis.proxy.Flow
 

I

index() - Method in class io.confluent.aegis.proxy.EndPointPair
 
io.confluent.aegis.common - package io.confluent.aegis.common
 
io.confluent.aegis.config - package io.confluent.aegis.config
 
io.confluent.aegis.proxy - package io.confluent.aegis.proxy
 

L

LISTENER_SECURITY_PROTOCOL_MAP_CONFIG - Static variable in class io.confluent.aegis.config.AegisConfig
 
LISTENER_SECURITY_PROTOCOL_MAP_DEFAULT - Static variable in class io.confluent.aegis.config.AegisConfig
 
LISTENER_SECURITY_PROTOCOL_MAP_DOC - Static variable in class io.confluent.aegis.config.AegisConfig
 
listenerSecurityProtocolMap() - Method in class io.confluent.aegis.config.AegisConfig
Returns a map of listener names to security protocols.

M

main(String[]) - Static method in class io.confluent.aegis.config.AegisConfig
 
main(String[]) - Static method in class io.confluent.aegis.proxy.Aegis
 

N

NUM_WORKER_POOL_THREADS_CONFIG - Static variable in class io.confluent.aegis.config.AegisConfig
 
NUM_WORKER_POOL_THREADS_DEFAULT - Static variable in class io.confluent.aegis.config.AegisConfig
 
NUM_WORKER_POOL_THREADS_DOC - Static variable in class io.confluent.aegis.config.AegisConfig
 

P

postProcessParsedConfig(Map<String, Object>) - Method in class io.confluent.aegis.config.AegisConfig
 

R

readArray(byte[]) - Method in class io.confluent.aegis.common.ByteBufAccessor
 
readByte() - Method in class io.confluent.aegis.common.ByteBufAccessor
 
readInt() - Method in class io.confluent.aegis.common.ByteBufAccessor
 
readLong() - Method in class io.confluent.aegis.common.ByteBufAccessor
 
readShort() - Method in class io.confluent.aegis.common.ByteBufAccessor
 
remove(Flow) - Method in class io.confluent.aegis.proxy.WorkerPool
 
resolveListenerConfig(String) - Method in class io.confluent.aegis.config.AegisConfig
Get the configuration for a particular listener.

T

TENANT_ENDPOINTS_CONFIG - Static variable in class io.confluent.aegis.config.AegisConfig
 
TENANT_ENDPOINTS_DOC - Static variable in class io.confluent.aegis.config.AegisConfig
 
tenantEndpoint() - Method in class io.confluent.aegis.proxy.EndPointPair
 
tenantEndpointConfig() - Method in class io.confluent.aegis.proxy.EndPointPair
 
TenantReader - Class in io.confluent.aegis.proxy
Reads Kafka requests received from the tenant.
TenantWriter - Class in io.confluent.aegis.proxy
Writes Kafka responses to the tenant.

U

unused() - Method in class io.confluent.aegis.config.AegisConfig
 

W

WorkerPool - Class in io.confluent.aegis.proxy
A netty thread pool associated with a particular pair of Aegis endpoints.
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class io.confluent.aegis.proxy.BrokerWriter
 
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class io.confluent.aegis.proxy.TenantWriter
 
writeArray(byte[]) - Method in class io.confluent.aegis.common.ByteBufAccessor
 
writeByte(byte) - Method in class io.confluent.aegis.common.ByteBufAccessor
 
writeInt(int) - Method in class io.confluent.aegis.common.ByteBufAccessor
 
writeLong(long) - Method in class io.confluent.aegis.common.ByteBufAccessor
 
Writer - Class in io.confluent.aegis.proxy
Writes a Kafka message to a channel.
writeShort(short) - Method in class io.confluent.aegis.common.ByteBufAccessor
 
A B C E F H I L M N P R T U W 
Skip navigation links