JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
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(int)
- Method in class io.confluent.aegis.common.
ByteBufAccessor
readByte()
- Method in class io.confluent.aegis.common.
ByteBufAccessor
readByteBuffer(int)
- Method in class io.confluent.aegis.common.
ByteBufAccessor
readDouble()
- 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
readUnsignedVarint()
- Method in class io.confluent.aegis.common.
ByteBufAccessor
remaining()
- 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
writeByte(byte)
- Method in class io.confluent.aegis.common.
ByteBufAccessor
writeByteArray(byte[])
- Method in class io.confluent.aegis.common.
ByteBufAccessor
writeByteBuffer(ByteBuffer)
- Method in class io.confluent.aegis.common.
ByteBufAccessor
writeDouble(double)
- 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
writeUnsignedVarint(int)
- 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
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes