Package com.linkedin.alpini.netty4.pool
Interface ManagedChannelPool
-
- All Superinterfaces:
java.lang.AutoCloseable,io.netty.channel.pool.ChannelPool,ChannelPoolWithStats,java.io.Closeable
- All Known Implementing Classes:
FixedChannelPoolImpl,FixedFastChannelPoolImpl,Http2AwareChannelPool
public interface ManagedChannelPool extends ChannelPoolWithStats
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description io.netty.util.concurrent.Future<java.lang.Void>closeFuture()default longgetActiveStreamsLimitReachedCount()default longgetChannelReusePoolSize()Returns the current reuse channel pool size.intgetConnectedChannels()default longgetCurrentStreamChannelsReused()default intgetH2ActiveConnections()default io.netty.channel.group.ChannelGroupgetHttp2ChannelGroup()default longgetTotalAcquireRetries()default longgetTotalActiveStreamChannels()default longgetTotalActiveStreams()default longgetTotalStreamChannelsReused()default longgetTotalStreamCreations()io.netty.channel.pool.ChannelPoolHandlerhandler()Returns theChannelPoolHandlerthat will be notified for the different pool actions.default booleanisClosed()booleanisClosing()booleanisHealthy()-
Methods inherited from interface io.netty.channel.pool.ChannelPool
acquire, acquire, close, release, release
-
Methods inherited from interface com.linkedin.alpini.netty4.pool.ChannelPoolWithStats
getAcquiredChannelCount, getMaxConnections, getMaxPendingAcquires, getPendingAcquireCount, name
-
-
-
-
Method Detail
-
handler
io.netty.channel.pool.ChannelPoolHandler handler()
Returns theChannelPoolHandlerthat will be notified for the different pool actions.- Returns:
- the
ChannelPoolHandlerthat will be notified for the different pool actions
-
getConnectedChannels
int getConnectedChannels()
-
isHealthy
boolean isHealthy()
-
closeFuture
io.netty.util.concurrent.Future<java.lang.Void> closeFuture()
-
isClosing
boolean isClosing()
-
isClosed
default boolean isClosed()
- Specified by:
isClosedin interfaceChannelPoolWithStats
-
getTotalActiveStreams
default long getTotalActiveStreams()
-
getCurrentStreamChannelsReused
default long getCurrentStreamChannelsReused()
-
getTotalStreamChannelsReused
default long getTotalStreamChannelsReused()
-
getTotalStreamCreations
default long getTotalStreamCreations()
-
getChannelReusePoolSize
default long getChannelReusePoolSize()
Returns the current reuse channel pool size. Normally this should be 0 since we should be reusing as much as possible.- Returns:
- current reuse channel pool size
-
getActiveStreamsLimitReachedCount
default long getActiveStreamsLimitReachedCount()
-
getH2ActiveConnections
default int getH2ActiveConnections()
-
getHttp2ChannelGroup
default io.netty.channel.group.ChannelGroup getHttp2ChannelGroup()
-
getTotalAcquireRetries
default long getTotalAcquireRetries()
-
getTotalActiveStreamChannels
default long getTotalActiveStreamChannels()
-
-