io.netty.channel.ChannelHandler
, io.netty.channel.ChannelInboundHandler
, io.netty.channel.ChannelOutboundHandler
, io.netty.handler.codec.http2.Http2LifecycleManager
@Internal
public abstract class GrpcHttp2ConnectionHandler
extends io.netty.handler.codec.http2.Http2ConnectionHandler
Http2ConnectionHandler
.Modifier and Type | Field | Description |
---|---|---|
protected io.netty.channel.ChannelPromise |
channelUnused |
Constructor | Description |
---|---|
GrpcHttp2ConnectionHandler(io.netty.channel.ChannelPromise channelUnused,
io.netty.handler.codec.http2.Http2ConnectionDecoder decoder,
io.netty.handler.codec.http2.Http2ConnectionEncoder encoder,
io.netty.handler.codec.http2.Http2Settings initialSettings) |
Modifier and Type | Method | Description |
---|---|---|
java.lang.String |
getAuthority() |
Returns the authority of the server.
|
io.grpc.Attributes |
getEagAttributes() |
Get the attributes of the EquivalentAddressGroup used to create this transport.
|
void |
handleProtocolNegotiationCompleted(io.grpc.Attributes attrs) |
Deprecated.
Use the two argument method instead.
|
void |
handleProtocolNegotiationCompleted(io.grpc.Attributes attrs,
io.grpc.InternalChannelz.Security securityInfo) |
Triggered on protocol negotiation completion.
|
void |
notifyUnused() |
Calling this method indicates that the channel will no longer be used.
|
bind, channelActive, channelInactive, channelReadComplete, channelWritabilityChanged, close, closeStream, closeStreamLocal, closeStreamRemote, connect, connection, decode, decoder, deregister, disconnect, encoder, exceptionCaught, flush, frameWriter, goAway, gracefulShutdownTimeoutMillis, gracefulShutdownTimeoutMillis, handlerAdded, handlerRemoved0, handleServerHeaderDecodeSizeError, isGracefulShutdownComplete, onConnectionError, onError, onHttpClientUpgrade, onHttpServerUpgrade, onStreamError, read, resetStream, write
actualReadableBytes, callDecode, channelRead, decodeLast, discardSomeReadBytes, handlerRemoved, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered
channelRegistered, channelUnregistered
public GrpcHttp2ConnectionHandler(io.netty.channel.ChannelPromise channelUnused, io.netty.handler.codec.http2.Http2ConnectionDecoder decoder, io.netty.handler.codec.http2.Http2ConnectionEncoder encoder, io.netty.handler.codec.http2.Http2Settings initialSettings)
@Deprecated public void handleProtocolNegotiationCompleted(io.grpc.Attributes attrs)
handleProtocolNegotiationCompleted(
Attributes, io.grpc.InternalChannelz.Security)
but with no InternalChannelz.Security
.public void handleProtocolNegotiationCompleted(io.grpc.Attributes attrs, io.grpc.InternalChannelz.Security securityInfo)
It must me called after negotiation is completed but before given handler is added to the channel.
attrs
- arbitrary attributes passed after protocol negotiation (eg. SSLSession).securityInfo
- informs channelz about the security protocol.public void notifyUnused()
Http2ConnectionHandler.close(io.netty.channel.ChannelHandlerContext, io.netty.channel.ChannelPromise)
on the channel, but leaving the channel alive. This is
useful if the channel will soon be deregistered from the executor and used in a non-Netty
context.public io.grpc.Attributes getEagAttributes()
public java.lang.String getAuthority()
java.lang.UnsupportedOperationException
- if on server-side