Package com.linkedin.alpini.router.impl

Interface Router.Builder

All Known Implementing Classes:

Router4

Enclosing interface:

Router

public static interface Router.Builder

Field Summary

Fields

Modifier and Type	Field	Description
static final long	HANDSHAKE_TIMEOUT_MILLIS
static final long	MINIMUM_IDLE_TIMEOUT_MILLIS
static final int	MINIMUM_MAX_CHUNK_SIZE
static final long	MINIMUM_MAX_CONTENT_LENGTH
static final int	MINIMUM_MAX_HEADER_SIZE
static final int	MINIMUM_MAX_INITIAL_LINE_LENGTH

Method Summary

Modifier and Type	Method	Description
default <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	connectionCountRecorder(Consumer<Integer> recorder)
Router.Builder	connectionHandleMode(ConnectionHandleMode connectionHandleMode)
Router.Builder	connectionLimit(int connectionLimit)
Router.Builder	connectionLimit(IntSupplier connectionLimit)
default Router.Builder	enableInboundHttp2(boolean enableHttp2)
Router.Builder	executor(Executor executor)
Router.Builder	handshakeTimeout(long time, 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, 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> recorder)
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)
default Router.Builder	timeoutProcessor(TimeoutProcessor timeoutProcessor)
Router.Builder	timeoutProcessor(RouterTimeoutProcessor timeoutProcessor)
default Router.Builder	useCustomMultiplexHandler(boolean useCustomMultiplexHandler)
Router.Builder	workerExecutor(Executor workerExecutor)

Field Details

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 Details

nettyVersion

Netty nettyVersion()

name

Router.Builder name(@Nonnull
 String name)

resourceRegistry

Router.Builder resourceRegistry(@Nonnull
 ResourceRegistry resourceRegistry)

threadFactory

Router.Builder threadFactory(@Nonnull
 ThreadFactory threadFactory)

serverSocketChannel

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

bossPoolSize

Router.Builder bossPoolSize(@Nonnegative
 int bossPoolSize)

ioWorkerPoolSize

Router.Builder ioWorkerPoolSize(@Nonnegative
 int ioWorkerPoolSize)

executor

Router.Builder executor(@Nonnull
 Executor executor)

workerExecutor

Router.Builder workerExecutor(@Nonnull
 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
 IntSupplier connectionLimit)

connectionCountRecorder

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

rejectedConnectionCountRecorder

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

connectionHandleMode

Router.Builder connectionHandleMode(@Nonnull
 ConnectionHandleMode connectionHandleMode)

serverSocketOptions

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

serverSocketOptions

Router.Builder serverSocketOptions(@Nonnull
 String key,
 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
 TimeUnit unit)

handshakeTimeout

Router.Builder handshakeTimeout(@Nonnegative
 long time,
 @Nonnull
 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(Function<T,T> function)

pipelineFactory

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

beforeHttpServerCodec

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

beforeChunkAggregator

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

beforeIdleStateHandler

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

beforeHttpRequestHandler

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

ioWorkerPoolBuilder

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

bossPoolBuilder

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

build

@CheckReturnValue
Router build()