Package com.linkedin.alpini.router.impl

Interface Router

All Superinterfaces:

Shutdownable, ShutdownableResource

All Known Implementing Classes:

Router4Impl

public interface Router
extends ShutdownableResource

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	Router.Builder
static interface	Router.PipelineFactory<CHANNEL_HANDLER>

Method Summary

Modifier and Type	Method	Description
static <H,P extends ResourcePath<K>,K,R> Router.Builder	builder(ScatterGatherHelper<H,P,K,R,?,?,?> scatterGatherHelper)
int	getActiveStreams()
int	getConnectedCount()
AsyncFuture<java.net.SocketAddress>	getLocalAddress()
long	getRstErrorCount()
Netty	nettyVersion()
AsyncFuture<java.lang.Void>	setAcceptConnection(boolean enabled)
AsyncFuture<java.net.SocketAddress>	start(java.net.SocketAddress address)

Methods inherited from interface com.linkedin.alpini.base.registry.Shutdownable

shutdown, waitForShutdown, waitForShutdown

Methods inherited from interface com.linkedin.alpini.base.registry.ShutdownableResource

isShutdown, isTerminated

Method Detail

nettyVersion

Netty nettyVersion()

start

AsyncFuture<java.net.SocketAddress> start(@Nonnull
                                          java.net.SocketAddress address)

getLocalAddress

AsyncFuture<java.net.SocketAddress> getLocalAddress()

setAcceptConnection

AsyncFuture<java.lang.Void> setAcceptConnection(boolean enabled)

getConnectedCount

int getConnectedCount()

getActiveStreams

int getActiveStreams()

getRstErrorCount

long getRstErrorCount()

builder

static <H,P extends ResourcePath<K>,K,R> Router.Builder builder(@Nonnull
                                                                                  ScatterGatherHelper<H,P,K,R,?,?,?> scatterGatherHelper)