Package com.linkedin.alpini.router.impl.netty4

Class Router4PipelineFactory<C extends io.netty.channel.Channel>

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

com.linkedin.alpini.netty4.handlers.ChannelInitializer<C>

com.linkedin.alpini.netty4.handlers.BasicServerChannelInitializer<C,Router4PipelineFactory<C>>

com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory<C>

All Implemented Interfaces:

RouterPipelineFactory<io.netty.channel.ChannelHandler>, io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

public class Router4PipelineFactory<C extends io.netty.channel.Channel>
extends BasicServerChannelInitializer<C,Router4PipelineFactory<C>>
implements RouterPipelineFactory<io.netty.channel.ChannelHandler>

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields inherited from class com.linkedin.alpini.netty4.handlers.BasicServerChannelInitializer

_activeStreamsCountHandler, _http2SettingsFrameLogger

Constructor Summary

Constructors

Constructor	Description
Router4PipelineFactory(ConnectionLimitHandler connectionLimit, ActiveStreamsCountHandler activeStreamsCountHandler, Http2SettingsFrameLogger http2SettingsFrameLogger, io.netty.util.Timer idleTimer, java.util.function.BooleanSupplier shutdownFlag, java.util.function.BooleanSupplier busyAutoReadDisable, ScatterGatherRequestHandler4<H,P,K,R> scatterGatherRequestHandler)

Method Summary

Modifier and Type	Method	Description
Router4PipelineFactory<C>	addBeforeChunkAggregator(java.lang.String name, java.util.function.Supplier<? extends io.netty.channel.ChannelHandler> supplier)
Router4PipelineFactory<C>	addBeforeChunkAggregator(java.util.function.Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)
Router4PipelineFactory<C>	addBeforeHttpRequestHandler(java.lang.String name, java.util.function.Supplier<? extends io.netty.channel.ChannelHandler> supplier)
Router4PipelineFactory<C>	addBeforeHttpRequestHandler(java.util.function.Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)
Router4PipelineFactory<C>	addBeforeHttpServerCodec(java.lang.String name, java.util.function.Supplier<? extends io.netty.channel.ChannelHandler> supplier)
Router4PipelineFactory<C>	addBeforeHttpServerCodec(java.util.function.Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)
Router4PipelineFactory<C>	addBeforeIdleStateHandler(java.lang.String name, java.util.function.Supplier<? extends io.netty.channel.ChannelHandler> supplier)
Router4PipelineFactory<C>	addBeforeIdleStateHandler(java.util.function.Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)
protected void	beforeChunkAggregator(io.netty.channel.ChannelPipeline pipeline)
protected void	beforeHttpRequestHandler(io.netty.channel.ChannelPipeline pipeline)
protected void	beforeHttpServerCodec(io.netty.channel.ChannelPipeline pipeline)
protected void	beforeIdleStateHandler(io.netty.channel.ChannelPipeline pipeline)
protected Http2PipelineInitializer.BuilderSupplier	getHttp2PipelineInitializerBuilderSupplier()
Router4PipelineFactory<C>	setHttp2PipelineInitializer(Http2PipelineInitializer.BuilderSupplier supplier)

Methods inherited from class com.linkedin.alpini.netty4.handlers.BasicServerChannelInitializer

afterHttpServerCodec, createHttp2PipelineInitializer, enableInboundHttp2, factory, getMaxChunkSize, getMaxHeaderSize, getMaxInitialLineLength, getServerHttp2Settings, handshakeConnectionTimeoutMillis, http2HeaderTableSize, http2InitialWindowSize, http2MaxConcurrentStreams, http2MaxFrameSize, http2MaxHeaderListSize, idleConnectionTimeoutMillis, initChannel, isUseCustomMultiplexHandler, isValidateHeaders, maxChunkSize, maxContentLength, maxHeaderSize, maxInitialLineLength, useCustomMultiplexHandler

Methods inherited from class com.linkedin.alpini.netty4.handlers.ChannelInitializer

channelRegistered, currentContext, 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

Router4PipelineFactory

public Router4PipelineFactory(@Nonnull
                              ConnectionLimitHandler connectionLimit,
                              @Nonnull
                              ActiveStreamsCountHandler activeStreamsCountHandler,
                              @Nonnull
                              Http2SettingsFrameLogger http2SettingsFrameLogger,
                              @Nonnull
                              io.netty.util.Timer idleTimer,
                              @Nonnull
                              java.util.function.BooleanSupplier shutdownFlag,
                              @Nonnull
                              java.util.function.BooleanSupplier busyAutoReadDisable,
                              @Nonnull
                              ScatterGatherRequestHandler4<H,P,K,R> scatterGatherRequestHandler)

Method Detail

addBeforeHttpServerCodec

public Router4PipelineFactory<C> addBeforeHttpServerCodec(@Nonnull
                                                          java.lang.String name,
                                                          @Nonnull
                                                          java.util.function.Supplier<? extends io.netty.channel.ChannelHandler> supplier)

Specified by:

addBeforeHttpServerCodec in interface RouterPipelineFactory<C extends io.netty.channel.Channel>

addBeforeHttpServerCodec

public Router4PipelineFactory<C> addBeforeHttpServerCodec(@Nonnull
                                                          java.util.function.Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)

addBeforeChunkAggregator

public Router4PipelineFactory<C> addBeforeChunkAggregator(java.lang.String name,
                                                          java.util.function.Supplier<? extends io.netty.channel.ChannelHandler> supplier)

Specified by:

addBeforeChunkAggregator in interface RouterPipelineFactory<C extends io.netty.channel.Channel>

addBeforeChunkAggregator

public Router4PipelineFactory<C> addBeforeChunkAggregator(@Nonnull
                                                          java.util.function.Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)

addBeforeIdleStateHandler

public Router4PipelineFactory<C> addBeforeIdleStateHandler(java.lang.String name,
                                                           java.util.function.Supplier<? extends io.netty.channel.ChannelHandler> supplier)

Specified by:

addBeforeIdleStateHandler in interface RouterPipelineFactory<C extends io.netty.channel.Channel>

addBeforeIdleStateHandler

public Router4PipelineFactory<C> addBeforeIdleStateHandler(@Nonnull
                                                           java.util.function.Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)

addBeforeHttpRequestHandler

public Router4PipelineFactory<C> addBeforeHttpRequestHandler(java.lang.String name,
                                                             java.util.function.Supplier<? extends io.netty.channel.ChannelHandler> supplier)

Specified by:

addBeforeHttpRequestHandler in interface RouterPipelineFactory<C extends io.netty.channel.Channel>

addBeforeHttpRequestHandler

public Router4PipelineFactory<C> addBeforeHttpRequestHandler(@Nonnull
                                                             java.util.function.Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)

setHttp2PipelineInitializer

public Router4PipelineFactory<C> setHttp2PipelineInitializer(Http2PipelineInitializer.BuilderSupplier supplier)

getHttp2PipelineInitializerBuilderSupplier

protected Http2PipelineInitializer.BuilderSupplier getHttp2PipelineInitializerBuilderSupplier()

Overrides:

getHttp2PipelineInitializerBuilderSupplier in class BasicServerChannelInitializer<C extends io.netty.channel.Channel,Router4PipelineFactory<C extends io.netty.channel.Channel>>

beforeHttpServerCodec

protected void beforeHttpServerCodec(@Nonnull
                                     io.netty.channel.ChannelPipeline pipeline)

Overrides:

beforeHttpServerCodec in class BasicServerChannelInitializer<C extends io.netty.channel.Channel,Router4PipelineFactory<C extends io.netty.channel.Channel>>

beforeChunkAggregator

protected void beforeChunkAggregator(@Nonnull
                                     io.netty.channel.ChannelPipeline pipeline)

Overrides:

beforeChunkAggregator in class BasicServerChannelInitializer<C extends io.netty.channel.Channel,Router4PipelineFactory<C extends io.netty.channel.Channel>>

beforeIdleStateHandler

protected void beforeIdleStateHandler(@Nonnull
                                      io.netty.channel.ChannelPipeline pipeline)

Overrides:

beforeIdleStateHandler in class BasicServerChannelInitializer<C extends io.netty.channel.Channel,Router4PipelineFactory<C extends io.netty.channel.Channel>>

beforeHttpRequestHandler

protected void beforeHttpRequestHandler(@Nonnull
                                        io.netty.channel.ChannelPipeline pipeline)

Overrides:

beforeHttpRequestHandler in class BasicServerChannelInitializer<C extends io.netty.channel.Channel,Router4PipelineFactory<C extends io.netty.channel.Channel>>