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

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

java.lang.Object

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

All Implemented Interfaces:

Router.Builder, Router.PipelineFactory<io.netty.channel.ChannelHandler>

public class Router4<C extends io.netty.channel.Channel>
extends Object
implements Router.Builder, Router.PipelineFactory<io.netty.channel.ChannelHandler>

Field Summary

Fields inherited from interface com.linkedin.alpini.router.impl.Router.Builder

HANDSHAKE_TIMEOUT_MILLIS, MINIMUM_IDLE_TIMEOUT_MILLIS, MINIMUM_MAX_CHUNK_SIZE, MINIMUM_MAX_CONTENT_LENGTH, MINIMUM_MAX_HEADER_SIZE, MINIMUM_MAX_INITIAL_LINE_LENGTH

Constructor Summary

Constructors

Constructor	Description
Router4(ScatterGatherHelper scatterGatherHelper)

Method Summary

Modifier and Type	Method	Description
Router.PipelineFactory<io.netty.channel.ChannelHandler>	addBeforeChunkAggregator(String name, Supplier<? extends io.netty.channel.ChannelHandler> supplier)
Router.PipelineFactory<io.netty.channel.ChannelHandler>	addBeforeHttpRequestHandler(String name, Supplier<? extends io.netty.channel.ChannelHandler> supplier)
Router.PipelineFactory<io.netty.channel.ChannelHandler>	addBeforeHttpServerCodec(String name, Supplier<? extends io.netty.channel.ChannelHandler> supplier)
Router.PipelineFactory<io.netty.channel.ChannelHandler>	addBeforeIdleStateHandler(String name, Supplier<? extends io.netty.channel.ChannelHandler> supplier)
<T> Router.Builder	addBootstrapFilter(Function<T,T> function)
Router.Builder	appWorkerChannelMaxMemorySize(long maxChannelMemorySize)
Router.Builder	appWorkerCorePoolSize(int corePoolSize)
Router.Builder	appWorkerKeepAliveSeconds(long appWorkerKeepAliveSeconds)
Router.Builder	appWorkerTotalMaxMemorySize(long maxTotalMemorySize)
<CHANNEL_PIPELINE> Router.Builder	beforeChunkAggregator(Class<CHANNEL_PIPELINE> pipelineClass, Consumer<CHANNEL_PIPELINE> consumer)
<CHANNEL_PIPELINE> Router.Builder	beforeHttpRequestHandler(Class<CHANNEL_PIPELINE> pipelineClass, Consumer<CHANNEL_PIPELINE> consumer)
<CHANNEL_PIPELINE> Router.Builder	beforeHttpServerCodec(Class<CHANNEL_PIPELINE> pipelineClass, Consumer<CHANNEL_PIPELINE> consumer)
<CHANNEL_PIPELINE> Router.Builder	beforeIdleStateHandler(Class<CHANNEL_PIPELINE> pipelineClass, Consumer<CHANNEL_PIPELINE> consumer)
<POOL_TYPE> Router.Builder	bossPoolBuilder(Class<POOL_TYPE> poolClass, Function<Executor,POOL_TYPE> builder)
Router.Builder	bossPoolSize(int bossPoolSize)
Router	build()
Router.Builder	builder()
Router.Builder	connectionCountRecorder(Consumer<Integer> connectionCountConsumer)
Router.Builder	connectionHandleMode(ConnectionHandleMode connectionHandleMode)
Router.Builder	connectionLimit(int connectionLimit)	Allow 0 limit to reject all connections as well as testing.
Router.Builder	connectionLimit(IntSupplier connectionLimit)
Router.Builder	enableInboundHttp2(boolean enableHttp2)
Router.Builder	executor(Executor executor)
<R extends ShutdownableResource, F extends ResourceRegistry.Factory<R>> F	factory(Class<F> clazz)
Router.Builder	handshakeTimeout(long time, TimeUnit unit)
Router.Builder	http2HeaderTableSize(int http2HeaderTableSize)
Router.Builder	http2InitialWindowSize(int http2InitialWindowSize)
Router.Builder	http2MaxConcurrentStreams(int http2MaxConcurrentStreams)
Router.Builder	http2MaxFrameSize(int http2MaxFrameSize)
Router.Builder	http2MaxHeaderListSize(int http2MaxHeaderListSize)
Router.Builder	idleTimeout(long time, TimeUnit unit)
<POOL_TYPE> Router.Builder	ioWorkerPoolBuilder(Class<POOL_TYPE> poolClass, Function<Executor,POOL_TYPE> builder)
Router.Builder	ioWorkerPoolSize(int ioWorkerPoolSize)
Router.Builder	maxChunkSize(int maxChunkSize)
Router.Builder	maxContentLength(long maxContentLength)
Router.Builder	maxHeaderSize(int maxHeaderSize)
Router.Builder	maxInitialLineLength(int maxInitialLineLength)
Router.Builder	name(String name)
Netty	nettyVersion()
<CHANNEL_HANDLER> Router.PipelineFactory<CHANNEL_HANDLER>	pipelineFactory(Class<CHANNEL_HANDLER> handlerClass)
Router.Builder	rejectedConnectionCountRecorder(Consumer<Integer> rejectedConnectionCountRecorderr)
Router.Builder	resourceRegistry(ResourceRegistry resourceRegistry)
Router.Builder	serverSocketChannel(Class<?> serverSocketChannel)
Router.Builder	serverSocketOptions(String key, Object value)
Router.Builder	serverSocketOptions(Map<String,Object> serverSocketOptions)
Router.Builder	threadFactory(ThreadFactory threadFactory)
Router.Builder	timeoutProcessor(RouterTimeoutProcessor timeoutProcessor)
Router.Builder	useCustomMultiplexHandler(boolean useCustomMultiplexHandler)
Router.Builder	workerExecutor(Executor workerExecutor)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.alpini.router.impl.Router.Builder

timeoutProcessor

Constructor Details

Router4

public Router4(@Nonnull
 ScatterGatherHelper scatterGatherHelper)

Method Details

nettyVersion

public Netty nettyVersion()

Specified by:

nettyVersion in interface Router.Builder

name

public Router.Builder name(@Nonnull
 String name)

Specified by:

name in interface Router.Builder

resourceRegistry

public Router.Builder resourceRegistry(@Nonnull
 ResourceRegistry resourceRegistry)

Specified by:

resourceRegistry in interface Router.Builder

threadFactory

public Router.Builder threadFactory(@Nonnull
 ThreadFactory threadFactory)

Specified by:

threadFactory in interface Router.Builder

serverSocketChannel

public Router.Builder serverSocketChannel(@Nonnull
 Class<?> serverSocketChannel)

Specified by:

serverSocketChannel in interface Router.Builder

bossPoolSize

public Router.Builder bossPoolSize(int bossPoolSize)

Specified by:

bossPoolSize in interface Router.Builder

ioWorkerPoolSize

public Router.Builder ioWorkerPoolSize(int ioWorkerPoolSize)

Specified by:

ioWorkerPoolSize in interface Router.Builder

ioWorkerPoolBuilder

public <POOL_TYPE> Router.Builder ioWorkerPoolBuilder(@Nonnull
 Class<POOL_TYPE> poolClass,
 @Nonnull
 Function<Executor,POOL_TYPE> builder)

Specified by:

ioWorkerPoolBuilder in interface Router.Builder

bossPoolBuilder

public <POOL_TYPE> Router.Builder bossPoolBuilder(@Nonnull
 Class<POOL_TYPE> poolClass,
 @Nonnull
 Function<Executor,POOL_TYPE> builder)

Specified by:

bossPoolBuilder in interface Router.Builder

executor

public Router.Builder executor(@Nonnull
 Executor executor)

Specified by:

executor in interface Router.Builder

workerExecutor

public Router.Builder workerExecutor(@Nonnull
 Executor workerExecutor)

Specified by:

workerExecutor in interface Router.Builder

appWorkerCorePoolSize

public Router.Builder appWorkerCorePoolSize(int corePoolSize)

Specified by:

appWorkerCorePoolSize in interface Router.Builder

appWorkerChannelMaxMemorySize

public Router.Builder appWorkerChannelMaxMemorySize(long maxChannelMemorySize)

Specified by:

appWorkerChannelMaxMemorySize in interface Router.Builder

appWorkerTotalMaxMemorySize

public Router.Builder appWorkerTotalMaxMemorySize(long maxTotalMemorySize)

Specified by:

appWorkerTotalMaxMemorySize in interface Router.Builder

appWorkerKeepAliveSeconds

public Router.Builder appWorkerKeepAliveSeconds(long appWorkerKeepAliveSeconds)

Specified by:

appWorkerKeepAliveSeconds in interface Router.Builder

timeoutProcessor

public Router.Builder timeoutProcessor(@Nonnull
 RouterTimeoutProcessor timeoutProcessor)

Specified by:

timeoutProcessor in interface Router.Builder

connectionLimit

public Router.Builder connectionLimit(int connectionLimit)

Allow 0 limit to reject all connections as well as testing.

Specified by:

connectionLimit in interface Router.Builder

connectionLimit

public Router.Builder connectionLimit(@Nonnull
 IntSupplier connectionLimit)

Specified by:

connectionLimit in interface Router.Builder

connectionCountRecorder

public Router.Builder connectionCountRecorder(@Nonnull
 Consumer<Integer> connectionCountConsumer)

Specified by:

connectionCountRecorder in interface Router.Builder

rejectedConnectionCountRecorder

public Router.Builder rejectedConnectionCountRecorder(@Nonnull
 Consumer<Integer> rejectedConnectionCountRecorderr)

Specified by:

rejectedConnectionCountRecorder in interface Router.Builder

connectionHandleMode

public Router.Builder connectionHandleMode(@Nonnull
 ConnectionHandleMode connectionHandleMode)

Specified by:

connectionHandleMode in interface Router.Builder

serverSocketOptions

public Router.Builder serverSocketOptions(Map<String,Object> serverSocketOptions)

Specified by:

serverSocketOptions in interface Router.Builder

serverSocketOptions

public Router.Builder serverSocketOptions(@Nonnull
 String key,
 Object value)

Specified by:

serverSocketOptions in interface Router.Builder

maxHeaderSize

public Router.Builder maxHeaderSize(@Nonnegative
 int maxHeaderSize)

Specified by:

maxHeaderSize in interface Router.Builder

maxInitialLineLength

public Router.Builder maxInitialLineLength(@Nonnegative
 int maxInitialLineLength)

Specified by:

maxInitialLineLength in interface Router.Builder

maxChunkSize

public Router.Builder maxChunkSize(@Nonnegative
 int maxChunkSize)

Specified by:

maxChunkSize in interface Router.Builder

maxContentLength

public Router.Builder maxContentLength(@Nonnegative
 long maxContentLength)

Specified by:

maxContentLength in interface Router.Builder

idleTimeout

public Router.Builder idleTimeout(@Nonnegative
 long time,
 @Nonnull
 TimeUnit unit)

Specified by:

idleTimeout in interface Router.Builder

handshakeTimeout

public Router.Builder handshakeTimeout(@Nonnegative
 long time,
 @Nonnull
 TimeUnit unit)

Specified by:

handshakeTimeout in interface Router.Builder

enableInboundHttp2

public Router.Builder enableInboundHttp2(boolean enableHttp2)

Specified by:

enableInboundHttp2 in interface Router.Builder

useCustomMultiplexHandler

public Router.Builder useCustomMultiplexHandler(boolean useCustomMultiplexHandler)

Specified by:

useCustomMultiplexHandler in interface Router.Builder

http2MaxConcurrentStreams

public Router.Builder http2MaxConcurrentStreams(int http2MaxConcurrentStreams)

Specified by:

http2MaxConcurrentStreams in interface Router.Builder

http2MaxFrameSize

public Router.Builder http2MaxFrameSize(int http2MaxFrameSize)

Specified by:

http2MaxFrameSize in interface Router.Builder

http2InitialWindowSize

public Router.Builder http2InitialWindowSize(int http2InitialWindowSize)

Specified by:

http2InitialWindowSize in interface Router.Builder

http2HeaderTableSize

public Router.Builder http2HeaderTableSize(int http2HeaderTableSize)

Specified by:

http2HeaderTableSize in interface Router.Builder

http2MaxHeaderListSize

public Router.Builder http2MaxHeaderListSize(int http2MaxHeaderListSize)

Specified by:

http2MaxHeaderListSize in interface Router.Builder

addBootstrapFilter

public <T> Router.Builder addBootstrapFilter(Function<T,T> function)

Specified by:

addBootstrapFilter in interface Router.Builder

pipelineFactory

public <CHANNEL_HANDLER>
Router.PipelineFactory<CHANNEL_HANDLER> pipelineFactory(@Nonnull
 Class<CHANNEL_HANDLER> handlerClass)

Specified by:

pipelineFactory in interface Router.Builder

beforeHttpServerCodec

public <CHANNEL_PIPELINE> Router.Builder beforeHttpServerCodec(@Nonnull
 Class<CHANNEL_PIPELINE> pipelineClass,
 @Nonnull
 Consumer<CHANNEL_PIPELINE> consumer)

Specified by:

beforeHttpServerCodec in interface Router.Builder

beforeChunkAggregator

public <CHANNEL_PIPELINE> Router.Builder beforeChunkAggregator(@Nonnull
 Class<CHANNEL_PIPELINE> pipelineClass,
 @Nonnull
 Consumer<CHANNEL_PIPELINE> consumer)

Specified by:

beforeChunkAggregator in interface Router.Builder

beforeIdleStateHandler

public <CHANNEL_PIPELINE> Router.Builder beforeIdleStateHandler(@Nonnull
 Class<CHANNEL_PIPELINE> pipelineClass,
 @Nonnull
 Consumer<CHANNEL_PIPELINE> consumer)

Specified by:

beforeIdleStateHandler in interface Router.Builder

beforeHttpRequestHandler

public <CHANNEL_PIPELINE> Router.Builder beforeHttpRequestHandler(@Nonnull
 Class<CHANNEL_PIPELINE> pipelineClass,
 @Nonnull
 Consumer<CHANNEL_PIPELINE> consumer)

Specified by:

beforeHttpRequestHandler in interface Router.Builder

addBeforeHttpServerCodec

public Router.PipelineFactory<io.netty.channel.ChannelHandler> addBeforeHttpServerCodec(@Nonnull
 String name,
 @Nonnull
 Supplier<? extends io.netty.channel.ChannelHandler> supplier)

Specified by:

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

addBeforeChunkAggregator

public Router.PipelineFactory<io.netty.channel.ChannelHandler> addBeforeChunkAggregator(@Nonnull
 String name,
 @Nonnull
 Supplier<? extends io.netty.channel.ChannelHandler> supplier)

Specified by:

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

addBeforeIdleStateHandler

public Router.PipelineFactory<io.netty.channel.ChannelHandler> addBeforeIdleStateHandler(@Nonnull
 String name,
 @Nonnull
 Supplier<? extends io.netty.channel.ChannelHandler> supplier)

Specified by:

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

addBeforeHttpRequestHandler

public Router.PipelineFactory<io.netty.channel.ChannelHandler> addBeforeHttpRequestHandler(@Nonnull
 String name,
 @Nonnull
 Supplier<? extends io.netty.channel.ChannelHandler> supplier)

Specified by:

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

builder

public Router.Builder builder()

Specified by:

builder in interface Router.PipelineFactory<C extends io.netty.channel.Channel>

factory

public <R extends ShutdownableResource,
F extends ResourceRegistry.Factory<R>>
F factory(@Nonnull
 Class<F> clazz)

build

public Router build()

Specified by:

build in interface Router.Builder