Package com.linkedin.venice.listener

Class HttpChannelInitializer

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

com.linkedin.venice.listener.HttpChannelInitializer

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

public class HttpChannelInitializer
extends io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor

Description

HttpChannelInitializer(ReadOnlyStoreRepository storeMetadataRepository, java.util.concurrent.CompletableFuture<HelixCustomizedViewOfflinePushRepository> customizedViewRepository, io.tehuti.metrics.MetricsRepository metricsRepository, java.util.Optional<SSLFactory> sslFactory, java.util.concurrent.Executor sslHandshakeExecutor, VeniceServerConfig serverConfig, java.util.Optional<StaticAccessController> routerAccessController, java.util.Optional<DynamicAccessController> storeAccessController, StorageReadRequestHandler requestHandler)

Method Summary

Modifier and Type	Method	Description
protected ReadQuotaEnforcementHandler	getQuotaEnforcer()
void	initChannel(io.netty.channel.socket.SocketChannel ch)
java.util.List<io.grpc.ServerInterceptor>	initGrpcInterceptors()	SSL Certificates can only be accessed easily via Server Interceptors for gRPC, so we create our acls here We can create aclInterceptor list as these handlers are already present within
VeniceServerGrpcRequestProcessor	initGrpcRequestProcessor()

Methods inherited from class io.netty.channel.ChannelInitializer

channelRegistered, exceptionCaught, handlerAdded, handlerRemoved

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, isSharable

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpChannelInitializer

public HttpChannelInitializer(ReadOnlyStoreRepository storeMetadataRepository,
                              java.util.concurrent.CompletableFuture<HelixCustomizedViewOfflinePushRepository> customizedViewRepository,
                              io.tehuti.metrics.MetricsRepository metricsRepository,
                              java.util.Optional<SSLFactory> sslFactory,
                              java.util.concurrent.Executor sslHandshakeExecutor,
                              VeniceServerConfig serverConfig,
                              java.util.Optional<StaticAccessController> routerAccessController,
                              java.util.Optional<DynamicAccessController> storeAccessController,
                              StorageReadRequestHandler requestHandler)

Method Detail

getQuotaEnforcer

protected ReadQuotaEnforcementHandler getQuotaEnforcer()

initChannel

public void initChannel(io.netty.channel.socket.SocketChannel ch)

Specified by:

initChannel in class io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

initGrpcRequestProcessor

public VeniceServerGrpcRequestProcessor initGrpcRequestProcessor()

initGrpcInterceptors

public java.util.List<io.grpc.ServerInterceptor> initGrpcInterceptors()

SSL Certificates can only be accessed easily via Server Interceptors for gRPC, so we create our acls here We can create aclInterceptor list as these handlers are already present within