@Internal
public abstract class GrpcHttp2ConnectionHandler
extends io.netty.handler.codec.http2.Http2ConnectionHandler
Http2ConnectionHandler
.Modifier and Type | Field and Description |
---|---|
protected io.netty.channel.ChannelPromise |
channelUnused |
Modifier | Constructor and Description |
---|---|
protected |
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,
io.grpc.ChannelLogger negotiationLogger) |
Modifier and Type | Method and Description |
---|---|
String |
getAuthority()
Returns the authority of the server.
|
io.grpc.Attributes |
getEagAttributes()
Get the attributes of the EquivalentAddressGroup used to create this transport.
|
io.grpc.ChannelLogger |
getNegotiationLogger()
Returns the channel logger for the given channel context.
|
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
@Nullable protected final io.netty.channel.ChannelPromise channelUnused
protected 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, io.grpc.ChannelLogger negotiationLogger)
@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 io.grpc.ChannelLogger getNegotiationLogger()
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 String getAuthority()
UnsupportedOperationException
- if on server-side