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, BooleanSupplier shutdownFlag, BooleanSupplier busyAutoReadDisable, ScatterGatherRequestHandler4<H,P,K,R> scatterGatherRequestHandler)

Method Summary

Modifier and Type	Method	Description
Router4PipelineFactory<C>	addBeforeChunkAggregator(String name, Supplier<? extends io.netty.channel.ChannelHandler> supplier)
Router4PipelineFactory<C>	addBeforeChunkAggregator(Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)
Router4PipelineFactory<C>	addBeforeHttpRequestHandler(String name, Supplier<? extends io.netty.channel.ChannelHandler> supplier)
Router4PipelineFactory<C>	addBeforeHttpRequestHandler(Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)
Router4PipelineFactory<C>	addBeforeHttpServerCodec(String name, Supplier<? extends io.netty.channel.ChannelHandler> supplier)
Router4PipelineFactory<C>	addBeforeHttpServerCodec(Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)
Router4PipelineFactory<C>	addBeforeIdleStateHandler(String name, Supplier<? extends io.netty.channel.ChannelHandler> supplier)
Router4PipelineFactory<C>	addBeforeIdleStateHandler(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 Details

Router4PipelineFactory

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

Method Details

addBeforeHttpServerCodec

public Router4PipelineFactory<C> addBeforeHttpServerCodec(@Nonnull
 String name,
 @Nonnull
 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
 Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)

addBeforeChunkAggregator

public Router4PipelineFactory<C> addBeforeChunkAggregator(String name,
 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
 Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)

addBeforeIdleStateHandler

public Router4PipelineFactory<C> addBeforeIdleStateHandler(String name,
 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
 Consumer<io.netty.channel.ChannelPipeline> pipelineConsumer)

addBeforeHttpRequestHandler

public Router4PipelineFactory<C> addBeforeHttpRequestHandler(String name,
 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
 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>>