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 long
getActiveStreamsLimitReachedCount()
default long
getChannelReusePoolSize()
Returns the current reuse channel pool size.int
getConnectedChannels()
default long
getCurrentStreamChannelsReused()
default int
getH2ActiveConnections()
default io.netty.channel.group.ChannelGroup
getHttp2ChannelGroup()
default long
getTotalAcquireRetries()
default long
getTotalActiveStreamChannels()
default long
getTotalActiveStreams()
default long
getTotalStreamChannelsReused()
default long
getTotalStreamCreations()
io.netty.channel.pool.ChannelPoolHandler
handler()
Returns theChannelPoolHandler
that will be notified for the different pool actions.default boolean
isClosed()
boolean
isClosing()
boolean
isHealthy()
-
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 theChannelPoolHandler
that will be notified for the different pool actions.- Returns:
- the
ChannelPoolHandler
that 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:
isClosed
in 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()
-
-