Package com.linkedin.alpini.router.impl
Interface Router.Builder
-
-
Field Summary
Fields Modifier and Type Field Description static long
HANDSHAKE_TIMEOUT_MILLIS
static long
MINIMUM_IDLE_TIMEOUT_MILLIS
static int
MINIMUM_MAX_CHUNK_SIZE
static long
MINIMUM_MAX_CONTENT_LENGTH
static int
MINIMUM_MAX_HEADER_SIZE
static int
MINIMUM_MAX_INITIAL_LINE_LENGTH
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default <T> Router.Builder
addBootstrapFilter(java.util.function.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.BuilderbeforeChunkAggregator(java.lang.Class<CHANNEL_PIPELINE> pipelineClass, java.util.function.Consumer<CHANNEL_PIPELINE> consumer)
<CHANNEL_PIPELINE>
Router.BuilderbeforeHttpRequestHandler(java.lang.Class<CHANNEL_PIPELINE> pipelineClass, java.util.function.Consumer<CHANNEL_PIPELINE> consumer)
<CHANNEL_PIPELINE>
Router.BuilderbeforeHttpServerCodec(java.lang.Class<CHANNEL_PIPELINE> pipelineClass, java.util.function.Consumer<CHANNEL_PIPELINE> consumer)
<CHANNEL_PIPELINE>
Router.BuilderbeforeIdleStateHandler(java.lang.Class<CHANNEL_PIPELINE> pipelineClass, java.util.function.Consumer<CHANNEL_PIPELINE> consumer)
<POOL_TYPE>
Router.BuilderbossPoolBuilder(java.lang.Class<POOL_TYPE> poolClass, java.util.function.Function<java.util.concurrent.Executor,POOL_TYPE> builder)
Router.Builder
bossPoolSize(int bossPoolSize)
Router
build()
Router.Builder
connectionLimit(int connectionLimit)
Router.Builder
connectionLimit(java.util.function.IntSupplier connectionLimit)
default Router.Builder
enableInboundHttp2(boolean enableHttp2)
Router.Builder
executor(java.util.concurrent.Executor executor)
Router.Builder
handshakeTimeout(long time, java.util.concurrent.TimeUnit unit)
default Router.Builder
http2HeaderTableSize(int http2HeaderTableSize)
default Router.Builder
http2InitialWindowSize(int http2InitialWindowSize)
default Router.Builder
http2MaxConcurrentStreams(int maxConcurrentStreams)
default Router.Builder
http2MaxFrameSize(int http2MaxFrameSize)
default Router.Builder
http2MaxHeaderListSize(int http2MaxHeaderListSize)
Router.Builder
idleTimeout(long time, java.util.concurrent.TimeUnit unit)
<POOL_TYPE>
Router.BuilderioWorkerPoolBuilder(java.lang.Class<POOL_TYPE> poolClass, java.util.function.Function<java.util.concurrent.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(java.lang.String name)
Netty
nettyVersion()
<CHANNEL_HANDLER>
Router.PipelineFactory<CHANNEL_HANDLER>pipelineFactory(java.lang.Class<CHANNEL_HANDLER> handlerClass)
Router.Builder
resourceRegistry(ResourceRegistry resourceRegistry)
Router.Builder
serverSocketChannel(java.lang.Class<?> serverSocketChannel)
Router.Builder
serverSocketOptions(java.lang.String key, java.lang.Object value)
Router.Builder
serverSocketOptions(java.util.Map<java.lang.String,java.lang.Object> serverSocketOptions)
Router.Builder
threadFactory(java.util.concurrent.ThreadFactory threadFactory)
default Router.Builder
timeoutProcessor(TimeoutProcessor timeoutProcessor)
Router.Builder
timeoutProcessor(RouterTimeoutProcessor timeoutProcessor)
default Router.Builder
useCustomMultiplexHandler(boolean useCustomMultiplexHandler)
Router.Builder
workerExecutor(java.util.concurrent.Executor workerExecutor)
-
-
-
Field Detail
-
MINIMUM_MAX_HEADER_SIZE
static final int MINIMUM_MAX_HEADER_SIZE
- See Also:
- Constant Field Values
-
MINIMUM_MAX_INITIAL_LINE_LENGTH
static final int MINIMUM_MAX_INITIAL_LINE_LENGTH
- See Also:
- Constant Field Values
-
MINIMUM_MAX_CHUNK_SIZE
static final int MINIMUM_MAX_CHUNK_SIZE
- See Also:
- Constant Field Values
-
MINIMUM_MAX_CONTENT_LENGTH
static final long MINIMUM_MAX_CONTENT_LENGTH
- See Also:
- Constant Field Values
-
MINIMUM_IDLE_TIMEOUT_MILLIS
static final long MINIMUM_IDLE_TIMEOUT_MILLIS
- See Also:
- Constant Field Values
-
HANDSHAKE_TIMEOUT_MILLIS
static final long HANDSHAKE_TIMEOUT_MILLIS
- See Also:
- Constant Field Values
-
-
Method Detail
-
nettyVersion
Netty nettyVersion()
-
name
Router.Builder name(@Nonnull java.lang.String name)
-
resourceRegistry
Router.Builder resourceRegistry(@Nonnull ResourceRegistry resourceRegistry)
-
threadFactory
Router.Builder threadFactory(@Nonnull java.util.concurrent.ThreadFactory threadFactory)
-
serverSocketChannel
Router.Builder serverSocketChannel(@Nonnull java.lang.Class<?> serverSocketChannel)
-
bossPoolSize
Router.Builder bossPoolSize(@Nonnegative int bossPoolSize)
-
ioWorkerPoolSize
Router.Builder ioWorkerPoolSize(@Nonnegative int ioWorkerPoolSize)
-
executor
Router.Builder executor(@Nonnull java.util.concurrent.Executor executor)
-
workerExecutor
Router.Builder workerExecutor(@Nonnull java.util.concurrent.Executor workerExecutor)
-
appWorkerCorePoolSize
Router.Builder appWorkerCorePoolSize(@Nonnegative int corePoolSize)
-
appWorkerChannelMaxMemorySize
Router.Builder appWorkerChannelMaxMemorySize(@Nonnegative long maxChannelMemorySize)
-
appWorkerTotalMaxMemorySize
Router.Builder appWorkerTotalMaxMemorySize(@Nonnegative long maxTotalMemorySize)
-
appWorkerKeepAliveSeconds
Router.Builder appWorkerKeepAliveSeconds(@Nonnegative long appWorkerKeepAliveSeconds)
-
timeoutProcessor
Router.Builder timeoutProcessor(@Nonnull RouterTimeoutProcessor timeoutProcessor)
-
timeoutProcessor
default Router.Builder timeoutProcessor(@Nonnull TimeoutProcessor timeoutProcessor)
-
connectionLimit
Router.Builder connectionLimit(@Nonnegative int connectionLimit)
-
connectionLimit
Router.Builder connectionLimit(@Nonnull java.util.function.IntSupplier connectionLimit)
-
serverSocketOptions
Router.Builder serverSocketOptions(java.util.Map<java.lang.String,java.lang.Object> serverSocketOptions)
-
serverSocketOptions
Router.Builder serverSocketOptions(@Nonnull java.lang.String key, java.lang.Object value)
-
maxHeaderSize
Router.Builder maxHeaderSize(@Nonnegative int maxHeaderSize)
-
maxInitialLineLength
Router.Builder maxInitialLineLength(@Nonnegative int maxInitialLineLength)
-
maxChunkSize
Router.Builder maxChunkSize(@Nonnegative int maxChunkSize)
-
maxContentLength
Router.Builder maxContentLength(@Nonnegative long maxContentLength)
-
idleTimeout
Router.Builder idleTimeout(@Nonnegative long time, @Nonnull java.util.concurrent.TimeUnit unit)
-
handshakeTimeout
Router.Builder handshakeTimeout(@Nonnegative long time, @Nonnull java.util.concurrent.TimeUnit unit)
-
enableInboundHttp2
default Router.Builder enableInboundHttp2(boolean enableHttp2)
-
http2MaxConcurrentStreams
default Router.Builder http2MaxConcurrentStreams(int maxConcurrentStreams)
-
http2MaxFrameSize
default Router.Builder http2MaxFrameSize(int http2MaxFrameSize)
-
http2InitialWindowSize
default Router.Builder http2InitialWindowSize(int http2InitialWindowSize)
-
http2HeaderTableSize
default Router.Builder http2HeaderTableSize(int http2HeaderTableSize)
-
http2MaxHeaderListSize
default Router.Builder http2MaxHeaderListSize(int http2MaxHeaderListSize)
-
useCustomMultiplexHandler
default Router.Builder useCustomMultiplexHandler(boolean useCustomMultiplexHandler)
-
addBootstrapFilter
default <T> Router.Builder addBootstrapFilter(java.util.function.Function<T,T> function)
-
pipelineFactory
<CHANNEL_HANDLER> Router.PipelineFactory<CHANNEL_HANDLER> pipelineFactory(@Nonnull java.lang.Class<CHANNEL_HANDLER> handlerClass)
-
beforeHttpServerCodec
<CHANNEL_PIPELINE> Router.Builder beforeHttpServerCodec(@Nonnull java.lang.Class<CHANNEL_PIPELINE> pipelineClass, @Nonnull java.util.function.Consumer<CHANNEL_PIPELINE> consumer)
-
beforeChunkAggregator
<CHANNEL_PIPELINE> Router.Builder beforeChunkAggregator(@Nonnull java.lang.Class<CHANNEL_PIPELINE> pipelineClass, @Nonnull java.util.function.Consumer<CHANNEL_PIPELINE> consumer)
-
beforeIdleStateHandler
<CHANNEL_PIPELINE> Router.Builder beforeIdleStateHandler(@Nonnull java.lang.Class<CHANNEL_PIPELINE> pipelineClass, @Nonnull java.util.function.Consumer<CHANNEL_PIPELINE> consumer)
-
beforeHttpRequestHandler
<CHANNEL_PIPELINE> Router.Builder beforeHttpRequestHandler(@Nonnull java.lang.Class<CHANNEL_PIPELINE> pipelineClass, @Nonnull java.util.function.Consumer<CHANNEL_PIPELINE> consumer)
-
ioWorkerPoolBuilder
<POOL_TYPE> Router.Builder ioWorkerPoolBuilder(@Nonnull java.lang.Class<POOL_TYPE> poolClass, @Nonnull java.util.function.Function<java.util.concurrent.Executor,POOL_TYPE> builder)
-
bossPoolBuilder
<POOL_TYPE> Router.Builder bossPoolBuilder(@Nonnull java.lang.Class<POOL_TYPE> poolClass, @Nonnull java.util.function.Function<java.util.concurrent.Executor,POOL_TYPE> builder)
-
build
@CheckReturnValue Router build()
-
-