META-INF/
META-INF/MANIFEST.MF
io/
io/grpc/
io/grpc/netty/
io/grpc/netty/AbstractHttp2Headers.classAbstractHttp2Headers.java
package io.grpc.netty
abstract io.grpc.netty.AbstractHttp2Headers extends java.lang.Object implements io.netty.handler.codec.http2.Http2Headers {
void ()
public int size ()
public boolean isEmpty ()
public java.util.Set names ()
public java.lang.CharSequence get (java.lang.CharSequence)
CharSequence name
public java.lang.CharSequence get (java.lang.CharSequence, java.lang.CharSequence)
CharSequence name
CharSequence defaultValue
public java.lang.CharSequence getAndRemove (java.lang.CharSequence)
CharSequence name
public java.lang.CharSequence getAndRemove (java.lang.CharSequence, java.lang.CharSequence)
CharSequence name
CharSequence defaultValue
public java.util.List getAll (java.lang.CharSequence)
CharSequence name
public java.util.List getAllAndRemove (java.lang.CharSequence)
CharSequence name
public java.lang.Boolean getBoolean (java.lang.CharSequence)
CharSequence name
public boolean getBoolean (java.lang.CharSequence, boolean)
CharSequence name
boolean defaultValue
public java.lang.Byte getByte (java.lang.CharSequence)
CharSequence name
public byte getByte (java.lang.CharSequence, byte)
CharSequence name
byte defaultValue
public java.lang.Character getChar (java.lang.CharSequence)
CharSequence name
public char getChar (java.lang.CharSequence, char)
CharSequence name
char defaultValue
public java.lang.Short getShort (java.lang.CharSequence)
CharSequence name
public short getShort (java.lang.CharSequence, short)
CharSequence name
short defaultValue
public java.lang.Integer getInt (java.lang.CharSequence)
CharSequence name
public int getInt (java.lang.CharSequence, int)
CharSequence name
int defaultValue
public java.lang.Long getLong (java.lang.CharSequence)
CharSequence name
public long getLong (java.lang.CharSequence, long)
CharSequence name
long defaultValue
public java.lang.Float getFloat (java.lang.CharSequence)
CharSequence name
public float getFloat (java.lang.CharSequence, float)
CharSequence name
float defaultValue
public java.lang.Double getDouble (java.lang.CharSequence)
CharSequence name
public double getDouble (java.lang.CharSequence, double)
CharSequence name
double defaultValue
public java.lang.Long getTimeMillis (java.lang.CharSequence)
CharSequence name
public long getTimeMillis (java.lang.CharSequence, long)
CharSequence name
long defaultValue
public java.lang.Boolean getBooleanAndRemove (java.lang.CharSequence)
CharSequence name
public boolean getBooleanAndRemove (java.lang.CharSequence, boolean)
CharSequence name
boolean defaultValue
public java.lang.Byte getByteAndRemove (java.lang.CharSequence)
CharSequence name
public byte getByteAndRemove (java.lang.CharSequence, byte)
CharSequence name
byte defaultValue
public java.lang.Character getCharAndRemove (java.lang.CharSequence)
CharSequence name
public char getCharAndRemove (java.lang.CharSequence, char)
CharSequence name
char defaultValue
public java.lang.Short getShortAndRemove (java.lang.CharSequence)
CharSequence name
public short getShortAndRemove (java.lang.CharSequence, short)
CharSequence name
short defaultValue
public java.lang.Integer getIntAndRemove (java.lang.CharSequence)
CharSequence name
public int getIntAndRemove (java.lang.CharSequence, int)
CharSequence name
int defaultValue
public java.lang.Long getLongAndRemove (java.lang.CharSequence)
CharSequence name
public long getLongAndRemove (java.lang.CharSequence, long)
CharSequence name
long defaultValue
public java.lang.Float getFloatAndRemove (java.lang.CharSequence)
CharSequence name
public float getFloatAndRemove (java.lang.CharSequence, float)
CharSequence name
float defaultValue
public java.lang.Double getDoubleAndRemove (java.lang.CharSequence)
CharSequence name
public double getDoubleAndRemove (java.lang.CharSequence, double)
CharSequence name
double defaultValue
public java.lang.Long getTimeMillisAndRemove (java.lang.CharSequence)
CharSequence name
public long getTimeMillisAndRemove (java.lang.CharSequence, long)
CharSequence name
long defaultValue
public boolean contains (java.lang.CharSequence)
CharSequence name
public boolean contains (java.lang.CharSequence, java.lang.CharSequence)
CharSequence name
CharSequence value
public boolean containsObject (java.lang.CharSequence, java.lang.Object)
CharSequence name
Object value
public boolean containsBoolean (java.lang.CharSequence, boolean)
CharSequence name
boolean value
public boolean containsByte (java.lang.CharSequence, byte)
CharSequence name
byte value
public boolean containsChar (java.lang.CharSequence, char)
CharSequence name
char value
public boolean containsShort (java.lang.CharSequence, short)
CharSequence name
short value
public boolean containsInt (java.lang.CharSequence, int)
CharSequence name
int value
public boolean containsLong (java.lang.CharSequence, long)
CharSequence name
long value
public boolean containsFloat (java.lang.CharSequence, float)
CharSequence name
float value
public boolean containsDouble (java.lang.CharSequence, double)
CharSequence name
double value
public boolean containsTimeMillis (java.lang.CharSequence, long)
CharSequence name
long value
public transient io.netty.handler.codec.http2.Http2Headers add (java.lang.CharSequence, java.lang.CharSequence[])
CharSequence name
CharSequence[] values
public io.netty.handler.codec.http2.Http2Headers add (io.netty.handler.codec.Headers)
io.netty.handler.codec.Headers headers
public io.netty.handler.codec.http2.Http2Headers add (java.lang.CharSequence, java.lang.CharSequence)
CharSequence name
CharSequence value
public io.netty.handler.codec.http2.Http2Headers add (java.lang.CharSequence, java.lang.Iterable)
CharSequence name
Iterable values
public io.netty.handler.codec.http2.Http2Headers addObject (java.lang.CharSequence, java.lang.Object)
CharSequence name
Object value
public io.netty.handler.codec.http2.Http2Headers addObject (java.lang.CharSequence, java.lang.Iterable)
CharSequence name
Iterable values
public transient io.netty.handler.codec.http2.Http2Headers addObject (java.lang.CharSequence, java.lang.Object[])
CharSequence name
Object[] values
public io.netty.handler.codec.http2.Http2Headers addBoolean (java.lang.CharSequence, boolean)
CharSequence name
boolean value
public io.netty.handler.codec.http2.Http2Headers addByte (java.lang.CharSequence, byte)
CharSequence name
byte value
public io.netty.handler.codec.http2.Http2Headers addChar (java.lang.CharSequence, char)
CharSequence name
char value
public io.netty.handler.codec.http2.Http2Headers addShort (java.lang.CharSequence, short)
CharSequence name
short value
public io.netty.handler.codec.http2.Http2Headers addInt (java.lang.CharSequence, int)
CharSequence name
int value
public io.netty.handler.codec.http2.Http2Headers addLong (java.lang.CharSequence, long)
CharSequence name
long value
public io.netty.handler.codec.http2.Http2Headers addFloat (java.lang.CharSequence, float)
CharSequence name
float value
public io.netty.handler.codec.http2.Http2Headers addDouble (java.lang.CharSequence, double)
CharSequence name
double value
public io.netty.handler.codec.http2.Http2Headers addTimeMillis (java.lang.CharSequence, long)
CharSequence name
long value
public io.netty.handler.codec.http2.Http2Headers set (io.netty.handler.codec.Headers)
io.netty.handler.codec.Headers headers
public io.netty.handler.codec.http2.Http2Headers set (java.lang.CharSequence, java.lang.CharSequence)
CharSequence name
CharSequence value
public io.netty.handler.codec.http2.Http2Headers set (java.lang.CharSequence, java.lang.Iterable)
CharSequence name
Iterable values
public transient io.netty.handler.codec.http2.Http2Headers set (java.lang.CharSequence, java.lang.CharSequence[])
CharSequence name
CharSequence[] values
public io.netty.handler.codec.http2.Http2Headers setObject (java.lang.CharSequence, java.lang.Object)
CharSequence name
Object value
public io.netty.handler.codec.http2.Http2Headers setObject (java.lang.CharSequence, java.lang.Iterable)
CharSequence name
Iterable values
public transient io.netty.handler.codec.http2.Http2Headers setObject (java.lang.CharSequence, java.lang.Object[])
CharSequence name
Object[] values
public io.netty.handler.codec.http2.Http2Headers setBoolean (java.lang.CharSequence, boolean)
CharSequence name
boolean value
public io.netty.handler.codec.http2.Http2Headers setByte (java.lang.CharSequence, byte)
CharSequence name
byte value
public io.netty.handler.codec.http2.Http2Headers setChar (java.lang.CharSequence, char)
CharSequence name
char value
public io.netty.handler.codec.http2.Http2Headers setShort (java.lang.CharSequence, short)
CharSequence name
short value
public io.netty.handler.codec.http2.Http2Headers setInt (java.lang.CharSequence, int)
CharSequence name
int value
public io.netty.handler.codec.http2.Http2Headers setLong (java.lang.CharSequence, long)
CharSequence name
long value
public io.netty.handler.codec.http2.Http2Headers setFloat (java.lang.CharSequence, float)
CharSequence name
float value
public io.netty.handler.codec.http2.Http2Headers setDouble (java.lang.CharSequence, double)
CharSequence name
double value
public io.netty.handler.codec.http2.Http2Headers setTimeMillis (java.lang.CharSequence, long)
CharSequence name
long value
public io.netty.handler.codec.http2.Http2Headers setAll (io.netty.handler.codec.Headers)
io.netty.handler.codec.Headers headers
public boolean remove (java.lang.CharSequence)
CharSequence name
public io.netty.handler.codec.http2.Http2Headers clear ()
public java.util.Iterator iterator ()
public io.netty.handler.codec.http2.Http2Headers method (java.lang.CharSequence)
CharSequence value
public java.lang.CharSequence method ()
public io.netty.handler.codec.http2.Http2Headers scheme (java.lang.CharSequence)
CharSequence value
public java.lang.CharSequence scheme ()
public io.netty.handler.codec.http2.Http2Headers authority (java.lang.CharSequence)
CharSequence value
public java.lang.CharSequence authority ()
public io.netty.handler.codec.http2.Http2Headers path (java.lang.CharSequence)
CharSequence value
public java.lang.CharSequence path ()
public io.netty.handler.codec.http2.Http2Headers status (java.lang.CharSequence)
CharSequence value
public java.lang.CharSequence status ()
public volatile io.netty.handler.codec.Headers clear ()
public volatile boolean remove (java.lang.Object)
public volatile io.netty.handler.codec.Headers setAll (io.netty.handler.codec.Headers)
public volatile io.netty.handler.codec.Headers set (io.netty.handler.codec.Headers)
public volatile io.netty.handler.codec.Headers setTimeMillis (java.lang.Object, long)
public volatile io.netty.handler.codec.Headers setDouble (java.lang.Object, double)
public volatile io.netty.handler.codec.Headers setFloat (java.lang.Object, float)
public volatile io.netty.handler.codec.Headers setLong (java.lang.Object, long)
public volatile io.netty.handler.codec.Headers setInt (java.lang.Object, int)
public volatile io.netty.handler.codec.Headers setShort (java.lang.Object, short)
public volatile io.netty.handler.codec.Headers setChar (java.lang.Object, char)
public volatile io.netty.handler.codec.Headers setByte (java.lang.Object, byte)
public volatile io.netty.handler.codec.Headers setBoolean (java.lang.Object, boolean)
public volatile io.netty.handler.codec.Headers setObject (java.lang.Object, java.lang.Object[])
public volatile io.netty.handler.codec.Headers setObject (java.lang.Object, java.lang.Iterable)
public volatile io.netty.handler.codec.Headers setObject (java.lang.Object, java.lang.Object)
public volatile io.netty.handler.codec.Headers set (java.lang.Object, java.lang.Object[])
public volatile io.netty.handler.codec.Headers set (java.lang.Object, java.lang.Iterable)
public volatile io.netty.handler.codec.Headers set (java.lang.Object, java.lang.Object)
public volatile io.netty.handler.codec.Headers add (io.netty.handler.codec.Headers)
public volatile io.netty.handler.codec.Headers addTimeMillis (java.lang.Object, long)
public volatile io.netty.handler.codec.Headers addDouble (java.lang.Object, double)
public volatile io.netty.handler.codec.Headers addFloat (java.lang.Object, float)
public volatile io.netty.handler.codec.Headers addLong (java.lang.Object, long)
public volatile io.netty.handler.codec.Headers addInt (java.lang.Object, int)
public volatile io.netty.handler.codec.Headers addShort (java.lang.Object, short)
public volatile io.netty.handler.codec.Headers addChar (java.lang.Object, char)
public volatile io.netty.handler.codec.Headers addByte (java.lang.Object, byte)
public volatile io.netty.handler.codec.Headers addBoolean (java.lang.Object, boolean)
public volatile io.netty.handler.codec.Headers addObject (java.lang.Object, java.lang.Object[])
public volatile io.netty.handler.codec.Headers addObject (java.lang.Object, java.lang.Iterable)
public volatile io.netty.handler.codec.Headers addObject (java.lang.Object, java.lang.Object)
public volatile io.netty.handler.codec.Headers add (java.lang.Object, java.lang.Object[])
public volatile io.netty.handler.codec.Headers add (java.lang.Object, java.lang.Iterable)
public volatile io.netty.handler.codec.Headers add (java.lang.Object, java.lang.Object)
public volatile boolean containsTimeMillis (java.lang.Object, long)
public volatile boolean containsDouble (java.lang.Object, double)
public volatile boolean containsFloat (java.lang.Object, float)
public volatile boolean containsLong (java.lang.Object, long)
public volatile boolean containsInt (java.lang.Object, int)
public volatile boolean containsShort (java.lang.Object, short)
public volatile boolean containsChar (java.lang.Object, char)
public volatile boolean containsByte (java.lang.Object, byte)
public volatile boolean containsBoolean (java.lang.Object, boolean)
public volatile boolean containsObject (java.lang.Object, java.lang.Object)
public volatile boolean contains (java.lang.Object, java.lang.Object)
public volatile boolean contains (java.lang.Object)
public volatile long getTimeMillisAndRemove (java.lang.Object, long)
public volatile java.lang.Long getTimeMillisAndRemove (java.lang.Object)
public volatile double getDoubleAndRemove (java.lang.Object, double)
public volatile java.lang.Double getDoubleAndRemove (java.lang.Object)
public volatile float getFloatAndRemove (java.lang.Object, float)
public volatile java.lang.Float getFloatAndRemove (java.lang.Object)
public volatile long getLongAndRemove (java.lang.Object, long)
public volatile java.lang.Long getLongAndRemove (java.lang.Object)
public volatile int getIntAndRemove (java.lang.Object, int)
public volatile java.lang.Integer getIntAndRemove (java.lang.Object)
public volatile short getShortAndRemove (java.lang.Object, short)
public volatile java.lang.Short getShortAndRemove (java.lang.Object)
public volatile char getCharAndRemove (java.lang.Object, char)
public volatile java.lang.Character getCharAndRemove (java.lang.Object)
public volatile byte getByteAndRemove (java.lang.Object, byte)
public volatile java.lang.Byte getByteAndRemove (java.lang.Object)
public volatile boolean getBooleanAndRemove (java.lang.Object, boolean)
public volatile java.lang.Boolean getBooleanAndRemove (java.lang.Object)
public volatile long getTimeMillis (java.lang.Object, long)
public volatile java.lang.Long getTimeMillis (java.lang.Object)
public volatile double getDouble (java.lang.Object, double)
public volatile java.lang.Double getDouble (java.lang.Object)
public volatile float getFloat (java.lang.Object, float)
public volatile java.lang.Float getFloat (java.lang.Object)
public volatile long getLong (java.lang.Object, long)
public volatile java.lang.Long getLong (java.lang.Object)
public volatile int getInt (java.lang.Object, int)
public volatile java.lang.Integer getInt (java.lang.Object)
public volatile short getShort (java.lang.Object, short)
public volatile java.lang.Short getShort (java.lang.Object)
public volatile char getChar (java.lang.Object, char)
public volatile java.lang.Character getChar (java.lang.Object)
public volatile byte getByte (java.lang.Object, byte)
public volatile java.lang.Byte getByte (java.lang.Object)
public volatile boolean getBoolean (java.lang.Object, boolean)
public volatile java.lang.Boolean getBoolean (java.lang.Object)
public volatile java.util.List getAllAndRemove (java.lang.Object)
public volatile java.util.List getAll (java.lang.Object)
public volatile java.lang.Object getAndRemove (java.lang.Object, java.lang.Object)
public volatile java.lang.Object getAndRemove (java.lang.Object)
public volatile java.lang.Object get (java.lang.Object, java.lang.Object)
public volatile java.lang.Object get (java.lang.Object)
}
io/grpc/netty/ClientTransportLifecycleManager.classClientTransportLifecycleManager.java
package io.grpc.netty
final io.grpc.netty.ClientTransportLifecycleManager extends java.lang.Object {
private final io.grpc.internal.ManagedClientTransport$Listener listener
private boolean transportReady
private boolean transportShutdown
private boolean transportInUse
private io.grpc.Status shutdownStatus
private Throwable shutdownThrowable
private boolean transportTerminated
public void (io.grpc.internal.ManagedClientTransport$Listener)
io.grpc.internal.ManagedClientTransport$Listener listener
public void notifyReady ()
public void notifyShutdown (io.grpc.Status)
io.grpc.Status s
public void notifyInUse (boolean)
boolean inUse
public void notifyTerminated (io.grpc.Status)
io.grpc.Status s
public io.grpc.Status getShutdownStatus ()
public java.lang.Throwable getShutdownThrowable ()
}
io/grpc/netty/ForcefulCloseCommand.classForcefulCloseCommand.java
package io.grpc.netty
io.grpc.netty.ForcefulCloseCommand extends io.grpc.netty.WriteQueue$AbstractQueuedCommand {
private final io.grpc.Status status
public void (io.grpc.Status)
io.grpc.Status status
public io.grpc.Status getStatus ()
}
io/grpc/netty/WriteQueue$1.classWriteQueue.java
package io.grpc.netty
io.grpc.netty.WriteQueue$1 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.netty.WriteQueue this$0
void (io.grpc.netty.WriteQueue)
io.grpc.netty.WriteQueue this$0
public void run ()
}
io/grpc/netty/WriteQueue$AbstractQueuedCommand.classWriteQueue.java
package io.grpc.netty
abstract io.grpc.netty.WriteQueue$AbstractQueuedCommand extends java.lang.Object implements io.grpc.netty.WriteQueue$QueuedCommand {
private io.netty.channel.ChannelPromise promise
void ()
public final void promise (io.netty.channel.ChannelPromise)
io.netty.channel.ChannelPromise promise
public final io.netty.channel.ChannelPromise promise ()
}
io/grpc/netty/WriteQueue$QueuedCommand.classWriteQueue.java
package io.grpc.netty
abstract io.grpc.netty.WriteQueue$QueuedCommand extends java.lang.Object {
public abstract io.netty.channel.ChannelPromise promise ()
public abstract void promise (io.netty.channel.ChannelPromise)
}
io/grpc/netty/WriteQueue.classWriteQueue.java
package io.grpc.netty
io.grpc.netty.WriteQueue extends java.lang.Object {
static final int DEQUE_CHUNK_SIZE
private final Runnable later
private final io.netty.channel.Channel channel
private final java.util.concurrent.BlockingQueue queue
private final java.util.concurrent.atomic.AtomicBoolean scheduled
private final java.util.ArrayDeque writeChunk
public void (io.netty.channel.Channel)
io.netty.channel.Channel channel
void scheduleFlush ()
io.netty.channel.ChannelFuture enqueue (io.grpc.netty.WriteQueue$QueuedCommand, boolean)
io.grpc.netty.WriteQueue$QueuedCommand command
boolean flush
io.netty.channel.ChannelFuture enqueue (io.grpc.netty.WriteQueue$QueuedCommand, io.netty.channel.ChannelPromise, boolean)
io.grpc.netty.WriteQueue$QueuedCommand command
io.netty.channel.ChannelPromise promise
boolean flush
private void flush ()
io.grpc.netty.WriteQueue$QueuedCommand cmd
boolean flushed
static void access$000 (io.grpc.netty.WriteQueue)
io.grpc.netty.WriteQueue x0
}
io/grpc/netty/GracefulCloseCommand.classGracefulCloseCommand.java
package io.grpc.netty
io.grpc.netty.GracefulCloseCommand extends io.grpc.netty.WriteQueue$AbstractQueuedCommand {
private final io.grpc.Status status
public void (io.grpc.Status)
io.grpc.Status status
public io.grpc.Status getStatus ()
}
io/grpc/netty/GrpcSslContexts$1.classGrpcSslContexts.java
package io.grpc.netty
io.grpc.netty.GrpcSslContexts$1 extends java.lang.Object {
static final int[] $SwitchMap$io$netty$handler$ssl$SslProvider
static void ()
}
io/grpc/netty/GrpcSslContexts.classGrpcSslContexts.java
package io.grpc.netty
public io.grpc.netty.GrpcSslContexts extends java.lang.Object {
static final String HTTP2_VERSION
private static io.netty.handler.ssl.ApplicationProtocolConfig ALPN
private static io.netty.handler.ssl.ApplicationProtocolConfig NPN
private static io.netty.handler.ssl.ApplicationProtocolConfig NPN_AND_ALPN
private void ()
public static io.netty.handler.ssl.SslContextBuilder forClient ()
public static io.netty.handler.ssl.SslContextBuilder forServer (java.io.File, java.io.File)
java.io.File keyCertChainFile
java.io.File keyFile
public static io.netty.handler.ssl.SslContextBuilder forServer (java.io.File, java.io.File, java.lang.String)
java.io.File keyCertChainFile
java.io.File keyFile
String keyPassword
public static io.netty.handler.ssl.SslContextBuilder configure (io.netty.handler.ssl.SslContextBuilder)
io.netty.handler.ssl.SslContextBuilder builder
public static io.netty.handler.ssl.SslContextBuilder configure (io.netty.handler.ssl.SslContextBuilder, io.netty.handler.ssl.SslProvider)
io.netty.handler.ssl.SslContextBuilder builder
io.netty.handler.ssl.SslProvider provider
private static io.netty.handler.ssl.SslProvider defaultSslProvider ()
private static io.netty.handler.ssl.ApplicationProtocolConfig selectApplicationProtocolConfig (io.netty.handler.ssl.SslProvider)
io.netty.handler.ssl.SslProvider provider
static void ensureAlpnAndH2Enabled (io.netty.handler.ssl.ApplicationProtocolNegotiator)
io.netty.handler.ssl.ApplicationProtocolNegotiator alpnNegotiator
static void ()
}
io/grpc/netty/JettyTlsUtil.classJettyTlsUtil.java
package io.grpc.netty
final io.grpc.netty.JettyTlsUtil extends java.lang.Object {
private void ()
static boolean isJettyAlpnConfigured ()
ClassNotFoundException e
static boolean isJettyNpnConfigured ()
ClassNotFoundException e
}
io/grpc/netty/NegotiationType.classNegotiationType.java
package io.grpc.netty
public final io.grpc.netty.NegotiationType extends java.lang.Enum {
public static final io.grpc.netty.NegotiationType TLS
public static final io.grpc.netty.NegotiationType PLAINTEXT_UPGRADE
public static final io.grpc.netty.NegotiationType PLAINTEXT
private static final io.grpc.netty.NegotiationType[] $VALUES
public static io.grpc.netty.NegotiationType[] values ()
public static io.grpc.netty.NegotiationType valueOf (java.lang.String)
String name
private void (java.lang.String, int)
static void ()
}
io/grpc/netty/NettyChannelProvider.classNettyChannelProvider.java
package io.grpc.netty
public final io.grpc.netty.NettyChannelProvider extends io.grpc.ManagedChannelProvider {
public void ()
public boolean isAvailable ()
public int priority ()
public io.grpc.netty.NettyChannelBuilder builderForAddress (java.lang.String, int)
String name
int port
public io.grpc.netty.NettyChannelBuilder builderForTarget (java.lang.String)
String target
public volatile io.grpc.ManagedChannelBuilder builderForTarget (java.lang.String)
public volatile io.grpc.ManagedChannelBuilder builderForAddress (java.lang.String, int)
}
io/grpc/netty/NettyChannelBuilder$NettyTransportFactory.classNettyChannelBuilder.java
package io.grpc.netty
public final io.grpc.netty.NettyChannelBuilder$NettyTransportFactory extends java.lang.Object implements io.grpc.internal.ClientTransportFactory {
private final Class channelType
private final io.grpc.netty.NegotiationType negotiationType
private final io.grpc.netty.ProtocolNegotiator protocolNegotiator
private final io.netty.handler.ssl.SslContext sslContext
private final io.netty.channel.EventLoopGroup group
private final boolean usingSharedGroup
private final int flowControlWindow
private final int maxMessageSize
private final int maxHeaderListSize
private boolean closed
private void (java.lang.Class, io.grpc.netty.NegotiationType, io.grpc.netty.ProtocolNegotiator, io.netty.handler.ssl.SslContext, io.netty.channel.EventLoopGroup, int, int, int)
Class channelType
io.grpc.netty.NegotiationType negotiationType
io.grpc.netty.ProtocolNegotiator protocolNegotiator
io.netty.handler.ssl.SslContext sslContext
io.netty.channel.EventLoopGroup group
int flowControlWindow
int maxMessageSize
int maxHeaderListSize
public io.grpc.internal.ConnectionClientTransport newClientTransport (java.net.SocketAddress, java.lang.String, java.lang.String)
String[] parts
int port
java.net.InetSocketAddress proxyAddress
java.net.SocketAddress serverAddress
String authority
String userAgent
io.grpc.netty.ProtocolNegotiator negotiator
String proxy
public io.grpc.internal.ConnectionClientTransport newClientTransport (java.net.SocketAddress, java.lang.String, java.lang.String, io.grpc.netty.ProtocolNegotiator)
java.net.SocketAddress serverAddress
String authority
String userAgent
io.grpc.netty.ProtocolNegotiator negotiator
public void close ()
void (java.lang.Class, io.grpc.netty.NegotiationType, io.grpc.netty.ProtocolNegotiator, io.netty.handler.ssl.SslContext, io.netty.channel.EventLoopGroup, int, int, int, io.grpc.netty.NettyChannelBuilder$1)
Class x0
io.grpc.netty.NegotiationType x1
io.grpc.netty.ProtocolNegotiator x2
io.netty.handler.ssl.SslContext x3
io.netty.channel.EventLoopGroup x4
int x5
int x6
int x7
io.grpc.netty.NettyChannelBuilder$1 x8
}
io/grpc/netty/NettyChannelBuilder$1.classNettyChannelBuilder.java
package io.grpc.netty
io.grpc.netty.NettyChannelBuilder$1 extends java.lang.Object {
static final int[] $SwitchMap$io$grpc$netty$NegotiationType
static void ()
}
io/grpc/netty/NettyChannelBuilder.classNettyChannelBuilder.java
package io.grpc.netty
public io.grpc.netty.NettyChannelBuilder extends io.grpc.internal.AbstractManagedChannelImplBuilder {
public static final int DEFAULT_FLOW_CONTROL_WINDOW
private io.grpc.netty.NegotiationType negotiationType
private io.grpc.netty.ProtocolNegotiator protocolNegotiator
private Class channelType
private io.netty.channel.EventLoopGroup eventLoopGroup
private io.netty.handler.ssl.SslContext sslContext
private int flowControlWindow
private int maxMessageSize
private int maxHeaderListSize
public static io.grpc.netty.NettyChannelBuilder forAddress (java.net.SocketAddress)
java.net.SocketAddress serverAddress
public static io.grpc.netty.NettyChannelBuilder forAddress (java.lang.String, int)
String host
int port
public static io.grpc.netty.NettyChannelBuilder forTarget (java.lang.String)
String target
protected void (java.lang.String, int)
String host
int port
protected void (java.lang.String)
String target
protected void (java.net.SocketAddress)
java.net.SocketAddress address
private static java.lang.String getAuthorityFromAddress (java.net.SocketAddress)
java.net.InetSocketAddress inetAddress
java.net.SocketAddress address
public final io.grpc.netty.NettyChannelBuilder channelType (java.lang.Class)
Class channelType
public final io.grpc.netty.NettyChannelBuilder negotiationType (io.grpc.netty.NegotiationType)
io.grpc.netty.NegotiationType type
public final io.grpc.netty.NettyChannelBuilder protocolNegotiator (io.grpc.netty.ProtocolNegotiator)
io.grpc.netty.ProtocolNegotiator protocolNegotiator
public final io.grpc.netty.NettyChannelBuilder eventLoopGroup (io.netty.channel.EventLoopGroup)
io.netty.channel.EventLoopGroup eventLoopGroup
public final io.grpc.netty.NettyChannelBuilder sslContext (io.netty.handler.ssl.SslContext)
io.netty.handler.ssl.SslContext sslContext
public final io.grpc.netty.NettyChannelBuilder flowControlWindow (int)
int flowControlWindow
public final io.grpc.netty.NettyChannelBuilder maxMessageSize (int)
int maxMessageSize
public final io.grpc.netty.NettyChannelBuilder maxHeaderListSize (int)
int maxHeaderListSize
public final io.grpc.netty.NettyChannelBuilder usePlaintext (boolean)
boolean skipNegotiation
protected io.grpc.internal.ClientTransportFactory buildTransportFactory ()
protected io.grpc.Attributes getNameResolverParams ()
int defaultPort
int defaultPort
int defaultPort
static io.grpc.netty.ProtocolNegotiator createProtocolNegotiator (java.lang.String, io.grpc.netty.NegotiationType, io.netty.handler.ssl.SslContext)
javax.net.ssl.SSLException ex
String authority
io.grpc.netty.NegotiationType negotiationType
io.netty.handler.ssl.SslContext sslContext
public volatile io.grpc.ManagedChannelBuilder usePlaintext (boolean)
}
io/grpc/netty/ProtocolNegotiator$Handler.classProtocolNegotiator.java
package io.grpc.netty
public abstract io.grpc.netty.ProtocolNegotiator$Handler extends java.lang.Object implements io.netty.channel.ChannelHandler {
public abstract io.netty.util.AsciiString scheme ()
}
io/grpc/netty/ProtocolNegotiator.classProtocolNegotiator.java
package io.grpc.netty
public abstract io.grpc.netty.ProtocolNegotiator extends java.lang.Object {
public abstract io.grpc.netty.ProtocolNegotiator$Handler newHandler (io.netty.handler.codec.http2.Http2ConnectionHandler)
}
io/grpc/netty/NettyServer$1$1.classNettyServer.java
package io.grpc.netty
io.grpc.netty.NettyServer$1$1 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final io.grpc.netty.NettyServer$1 this$1
void (io.grpc.netty.NettyServer$1)
io.grpc.netty.NettyServer$1 this$1
public void operationComplete (io.netty.channel.ChannelFuture)
io.netty.channel.ChannelFuture future
public volatile void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
}
io/grpc/netty/NettyServer$1.classNettyServer.java
package io.grpc.netty
io.grpc.netty.NettyServer$1 extends io.netty.channel.ChannelInitializer {
final io.grpc.netty.NettyServer this$0
void (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer this$0
public void initChannel (io.netty.channel.Channel) throws java.lang.Exception
io.netty.channel.Channel ch
io.grpc.netty.NettyServerTransport transport
io.grpc.internal.ServerTransportListener transportListener
}
io/grpc/netty/NettyServer$2.classNettyServer.java
package io.grpc.netty
io.grpc.netty.NettyServer$2 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final io.grpc.netty.NettyServer this$0
void (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer this$0
public void operationComplete (io.netty.channel.ChannelFuture) throws java.lang.Exception
io.netty.channel.ChannelFuture future
public volatile void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
}
io/grpc/netty/NettyServer$EventLoopReferenceCounter.classNettyServer.java
package io.grpc.netty
io.grpc.netty.NettyServer$EventLoopReferenceCounter extends io.netty.util.AbstractReferenceCounted {
final io.grpc.netty.NettyServer this$0
void (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer this$0
protected void deallocate ()
public io.netty.util.ReferenceCounted touch (java.lang.Object)
Object hint
}
io/grpc/netty/NettyServer.classNettyServer.java
package io.grpc.netty
io.grpc.netty.NettyServer extends java.lang.Object implements io.grpc.internal.InternalServer {
private static final java.util.logging.Logger log
private final java.net.SocketAddress address
private final Class channelType
private final io.grpc.netty.ProtocolNegotiator protocolNegotiator
private final int maxStreamsPerConnection
private final boolean usingSharedBossGroup
private final boolean usingSharedWorkerGroup
private io.netty.channel.EventLoopGroup bossGroup
private io.netty.channel.EventLoopGroup workerGroup
private io.grpc.internal.ServerListener listener
private io.netty.channel.Channel channel
private final int flowControlWindow
private final int maxMessageSize
private final int maxHeaderListSize
private final io.netty.util.ReferenceCounted eventLoopReferenceCounter
void (java.net.SocketAddress, java.lang.Class, io.netty.channel.EventLoopGroup, io.netty.channel.EventLoopGroup, io.grpc.netty.ProtocolNegotiator, int, int, int, int)
java.net.SocketAddress address
Class channelType
io.netty.channel.EventLoopGroup bossGroup
io.netty.channel.EventLoopGroup workerGroup
io.grpc.netty.ProtocolNegotiator protocolNegotiator
int maxStreamsPerConnection
int flowControlWindow
int maxMessageSize
int maxHeaderListSize
public int getPort ()
java.net.SocketAddress localAddr
public void start (io.grpc.internal.ServerListener) throws java.io.IOException
InterruptedException ex
io.grpc.internal.ServerListener serverListener
io.netty.bootstrap.ServerBootstrap b
io.netty.channel.ChannelFuture future
public void shutdown ()
private void allocateSharedGroups ()
static io.netty.util.ReferenceCounted access$000 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static io.grpc.netty.ProtocolNegotiator access$100 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static int access$200 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static int access$300 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static int access$400 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static int access$500 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static io.netty.channel.Channel access$600 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static io.grpc.internal.ServerListener access$700 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static java.util.logging.Logger access$800 ()
static boolean access$900 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static io.netty.channel.EventLoopGroup access$1000 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static io.netty.channel.EventLoopGroup access$1002 (io.grpc.netty.NettyServer, io.netty.channel.EventLoopGroup)
io.grpc.netty.NettyServer x0
io.netty.channel.EventLoopGroup x1
static boolean access$1100 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static io.netty.channel.EventLoopGroup access$1200 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static io.netty.channel.EventLoopGroup access$1202 (io.grpc.netty.NettyServer, io.netty.channel.EventLoopGroup)
io.grpc.netty.NettyServer x0
io.netty.channel.EventLoopGroup x1
static void ()
}
io/grpc/netty/NettyServerProvider.classNettyServerProvider.java
package io.grpc.netty
public final io.grpc.netty.NettyServerProvider extends io.grpc.ServerProvider {
public void ()
protected boolean isAvailable ()
protected int priority ()
protected io.grpc.netty.NettyServerBuilder builderForPort (int)
int port
protected volatile io.grpc.ServerBuilder builderForPort (int)
}
io/grpc/netty/NettyServerBuilder.classNettyServerBuilder.java
package io.grpc.netty
public final io.grpc.netty.NettyServerBuilder extends io.grpc.internal.AbstractServerImplBuilder {
public static final int DEFAULT_FLOW_CONTROL_WINDOW
private final java.net.SocketAddress address
private Class channelType
private io.netty.channel.EventLoopGroup bossEventLoopGroup
private io.netty.channel.EventLoopGroup workerEventLoopGroup
private io.netty.handler.ssl.SslContext sslContext
private io.grpc.netty.ProtocolNegotiator protocolNegotiator
private int maxConcurrentCallsPerConnection
private int flowControlWindow
private int maxMessageSize
private int maxHeaderListSize
public static io.grpc.netty.NettyServerBuilder forPort (int)
int port
public static io.grpc.netty.NettyServerBuilder forAddress (java.net.SocketAddress)
java.net.SocketAddress address
private void (int)
int port
private void (java.net.SocketAddress)
java.net.SocketAddress address
public io.grpc.netty.NettyServerBuilder channelType (java.lang.Class)
Class channelType
public io.grpc.netty.NettyServerBuilder bossEventLoopGroup (io.netty.channel.EventLoopGroup)
io.netty.channel.EventLoopGroup group
public io.grpc.netty.NettyServerBuilder workerEventLoopGroup (io.netty.channel.EventLoopGroup)
io.netty.channel.EventLoopGroup group
public io.grpc.netty.NettyServerBuilder sslContext (io.netty.handler.ssl.SslContext)
io.netty.handler.ssl.SslContext sslContext
public final io.grpc.netty.NettyServerBuilder protocolNegotiator (io.grpc.netty.ProtocolNegotiator)
io.grpc.netty.ProtocolNegotiator protocolNegotiator
public io.grpc.netty.NettyServerBuilder maxConcurrentCallsPerConnection (int)
int maxCalls
public io.grpc.netty.NettyServerBuilder flowControlWindow (int)
int flowControlWindow
public io.grpc.netty.NettyServerBuilder maxMessageSize (int)
int maxMessageSize
public io.grpc.netty.NettyServerBuilder maxHeaderListSize (int)
int maxHeaderListSize
protected io.grpc.netty.NettyServer buildTransportServer ()
io.grpc.netty.ProtocolNegotiator negotiator
public io.grpc.netty.NettyServerBuilder useTransportSecurity (java.io.File, java.io.File)
javax.net.ssl.SSLException e
java.io.File certChain
java.io.File privateKey
protected volatile io.grpc.internal.InternalServer buildTransportServer ()
public volatile io.grpc.ServerBuilder useTransportSecurity (java.io.File, java.io.File)
}
io/grpc/netty/NettyWritableBuffer.classNettyWritableBuffer.java
package io.grpc.netty
io.grpc.netty.NettyWritableBuffer extends java.lang.Object implements io.grpc.internal.WritableBuffer {
private final io.netty.buffer.ByteBuf bytebuf
void (io.netty.buffer.ByteBuf)
io.netty.buffer.ByteBuf bytebuf
public void write (byte[], int, int)
byte[] src
int srcIndex
int length
public void write (byte)
byte b
public int writableBytes ()
public int readableBytes ()
public void release ()
io.netty.buffer.ByteBuf bytebuf ()
}
io/grpc/netty/NettyWritableBufferAllocator.classNettyWritableBufferAllocator.java
package io.grpc.netty
io.grpc.netty.NettyWritableBufferAllocator extends java.lang.Object implements io.grpc.internal.WritableBufferAllocator {
private static final int MIN_BUFFER
private static final int MAX_BUFFER
private final io.netty.buffer.ByteBufAllocator allocator
void (io.netty.buffer.ByteBufAllocator)
io.netty.buffer.ByteBufAllocator allocator
public io.grpc.internal.WritableBuffer allocate (int)
int capacityHint
}
io/grpc/netty/SendGrpcFrameCommand.classSendGrpcFrameCommand.java
package io.grpc.netty
io.grpc.netty.SendGrpcFrameCommand extends io.netty.buffer.DefaultByteBufHolder implements io.grpc.netty.WriteQueue$QueuedCommand {
private final io.grpc.netty.StreamIdHolder stream
private final boolean endStream
private io.netty.channel.ChannelPromise promise
void (io.grpc.netty.StreamIdHolder, io.netty.buffer.ByteBuf, boolean)
io.grpc.netty.StreamIdHolder stream
io.netty.buffer.ByteBuf content
boolean endStream
int streamId ()
boolean endStream ()
public io.netty.buffer.ByteBufHolder copy ()
public io.netty.buffer.ByteBufHolder duplicate ()
public io.grpc.netty.SendGrpcFrameCommand retain ()
public io.grpc.netty.SendGrpcFrameCommand retain (int)
int increment
public io.grpc.netty.SendGrpcFrameCommand touch ()
public io.grpc.netty.SendGrpcFrameCommand touch (java.lang.Object)
Object hint
public boolean equals (java.lang.Object)
Object that
io.grpc.netty.SendGrpcFrameCommand thatCmd
public java.lang.String toString ()
public int hashCode ()
int hash
public io.netty.channel.ChannelPromise promise ()
public void promise (io.netty.channel.ChannelPromise)
io.netty.channel.ChannelPromise promise
public volatile io.netty.buffer.ByteBufHolder touch (java.lang.Object)
public volatile io.netty.buffer.ByteBufHolder touch ()
public volatile io.netty.buffer.ByteBufHolder retain (int)
public volatile io.netty.buffer.ByteBufHolder retain ()
public volatile io.netty.util.ReferenceCounted touch (java.lang.Object)
public volatile io.netty.util.ReferenceCounted touch ()
public volatile io.netty.util.ReferenceCounted retain (int)
public volatile io.netty.util.ReferenceCounted retain ()
}
io/grpc/netty/StreamIdHolder.classStreamIdHolder.java
package io.grpc.netty
abstract io.grpc.netty.StreamIdHolder extends java.lang.Object {
public abstract java.lang.Integer id ()
}
io/grpc/netty/SendPingCommand.classSendPingCommand.java
package io.grpc.netty
io.grpc.netty.SendPingCommand extends io.grpc.netty.WriteQueue$AbstractQueuedCommand {
private final io.grpc.internal.ClientTransport$PingCallback callback
private final java.util.concurrent.Executor executor
void (io.grpc.internal.ClientTransport$PingCallback, java.util.concurrent.Executor)
io.grpc.internal.ClientTransport$PingCallback callback
java.util.concurrent.Executor executor
io.grpc.internal.ClientTransport$PingCallback callback ()
java.util.concurrent.Executor executor ()
}
io/grpc/netty/AbstractNettyHandler.classAbstractNettyHandler.java
package io.grpc.netty
abstract io.grpc.netty.AbstractNettyHandler extends io.netty.handler.codec.http2.Http2ConnectionHandler {
private static long GRACEFUL_SHUTDOWN_TIMEOUT
private int initialConnectionWindow
private io.netty.channel.ChannelHandlerContext ctx
void (io.netty.handler.codec.http2.Http2ConnectionDecoder, io.netty.handler.codec.http2.Http2ConnectionEncoder, io.netty.handler.codec.http2.Http2Settings)
io.netty.handler.codec.http2.Http2ConnectionDecoder decoder
io.netty.handler.codec.http2.Http2ConnectionEncoder encoder
io.netty.handler.codec.http2.Http2Settings initialSettings
public void handlerAdded (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
public void channelActive (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
public final void exceptionCaught (io.netty.channel.ChannelHandlerContext, java.lang.Throwable) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
Throwable cause
io.netty.handler.codec.http2.Http2Exception embedded
protected final io.netty.channel.ChannelHandlerContext ctx ()
private void sendInitialConnectionWindow () throws io.netty.handler.codec.http2.Http2Exception
io.netty.handler.codec.http2.Http2Stream connectionStream
int currentSize
int delta
static void ()
}
io/grpc/netty/CancelClientStreamCommand.classCancelClientStreamCommand.java
package io.grpc.netty
io.grpc.netty.CancelClientStreamCommand extends io.grpc.netty.WriteQueue$AbstractQueuedCommand {
private final io.grpc.netty.NettyClientStream stream
private final io.grpc.Status reason
void (io.grpc.netty.NettyClientStream, io.grpc.Status)
io.grpc.netty.NettyClientStream stream
io.grpc.Status reason
io.grpc.netty.NettyClientStream stream ()
io.grpc.Status reason ()
}
io/grpc/netty/NettyClientStream$1.classNettyClientStream.java
package io.grpc.netty
io.grpc.netty.NettyClientStream$1 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final io.grpc.netty.NettyClientStream this$0
void (io.grpc.netty.NettyClientStream)
io.grpc.netty.NettyClientStream this$0
public void operationComplete (io.netty.channel.ChannelFuture) throws java.lang.Exception
io.grpc.Status s
io.netty.channel.ChannelFuture future
public volatile void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
}
io/grpc/netty/NettyClientStream$2.classNettyClientStream.java
package io.grpc.netty
io.grpc.netty.NettyClientStream$2 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final int val$numBytes
final io.grpc.netty.NettyClientStream this$0
void (io.grpc.netty.NettyClientStream, int)
io.grpc.netty.NettyClientStream this$0
public void operationComplete (io.netty.channel.ChannelFuture) throws java.lang.Exception
io.netty.channel.ChannelFuture future
public volatile void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
}
io/grpc/netty/NettyClientStream.classNettyClientStream.java
package io.grpc.netty
abstract io.grpc.netty.NettyClientStream extends io.grpc.internal.Http2ClientStream implements io.grpc.netty.StreamIdHolder {
private final io.grpc.MethodDescriptor method
private io.grpc.Metadata headers
private final io.netty.channel.Channel channel
private final io.grpc.netty.NettyClientHandler handler
private final io.netty.util.AsciiString scheme
private final io.netty.util.AsciiString userAgent
private io.netty.util.AsciiString authority
private io.netty.handler.codec.http2.Http2Stream http2Stream
private Integer id
private io.grpc.netty.WriteQueue writeQueue
void (io.grpc.MethodDescriptor, io.grpc.Metadata, io.netty.channel.Channel, io.grpc.netty.NettyClientHandler, int, io.netty.util.AsciiString, io.netty.util.AsciiString, io.netty.util.AsciiString)
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
io.netty.channel.Channel channel
io.grpc.netty.NettyClientHandler handler
int maxMessageSize
io.netty.util.AsciiString authority
io.netty.util.AsciiString scheme
io.netty.util.AsciiString userAgent
public void setAuthority (java.lang.String)
String authority
public void start (io.grpc.internal.ClientStreamListener)
io.grpc.internal.ClientStreamListener listener
io.netty.util.AsciiString defaultPath
io.netty.handler.codec.http2.Http2Headers http2Headers
io.netty.channel.ChannelFutureListener failureListener
public void transportReportStatus (io.grpc.Status, boolean, io.grpc.Metadata)
io.grpc.Status newStatus
boolean stopDelivery
io.grpc.Metadata trailers
protected abstract io.grpc.Status statusFromFailedFuture (io.netty.channel.ChannelFuture)
public void request (int)
int numMessages
public java.lang.Integer id ()
public void id (int)
int id
public void setHttp2Stream (io.netty.handler.codec.http2.Http2Stream)
io.netty.handler.codec.http2.Http2Stream http2Stream
public io.netty.handler.codec.http2.Http2Stream http2Stream ()
void transportHeadersReceived (io.netty.handler.codec.http2.Http2Headers, boolean)
io.netty.handler.codec.http2.Http2Headers headers
boolean endOfStream
void transportDataReceived (io.netty.buffer.ByteBuf, boolean)
io.netty.buffer.ByteBuf frame
boolean endOfStream
protected void sendCancel (io.grpc.Status)
io.grpc.Status reason
protected void sendFrame (io.grpc.internal.WritableBuffer, boolean, boolean)
io.grpc.internal.WritableBuffer frame
boolean endOfStream
boolean flush
io.netty.buffer.ByteBuf bytebuf
int numBytes
protected void returnProcessedBytes (int)
int processedBytes
public volatile java.lang.Object id ()
static void access$000 (io.grpc.netty.NettyClientStream, int)
io.grpc.netty.NettyClientStream x0
int x1
}
io/grpc/netty/NettyClientHandler$1.classNettyClientHandler.java
package io.grpc.netty
io.grpc.netty.NettyClientHandler$1 extends io.netty.handler.codec.http2.Http2ConnectionAdapter {
final io.grpc.netty.NettyClientHandler this$0
void (io.grpc.netty.NettyClientHandler)
io.grpc.netty.NettyClientHandler this$0
public void onGoAwayReceived (int, long, io.netty.buffer.ByteBuf)
int lastStreamId
long errorCode
io.netty.buffer.ByteBuf debugData
public void onStreamAdded (io.netty.handler.codec.http2.Http2Stream)
io.netty.handler.codec.http2.Http2Stream stream
public void onStreamRemoved (io.netty.handler.codec.http2.Http2Stream)
io.netty.handler.codec.http2.Http2Stream stream
}
io/grpc/netty/NettyClientHandler$2.classNettyClientHandler.java
package io.grpc.netty
io.grpc.netty.NettyClientHandler$2 extends java.lang.Object implements io.netty.handler.codec.http2.Http2StreamVisitor {
final io.grpc.netty.NettyClientHandler this$0
void (io.grpc.netty.NettyClientHandler)
io.grpc.netty.NettyClientHandler this$0
public boolean visit (io.netty.handler.codec.http2.Http2Stream) throws io.netty.handler.codec.http2.Http2Exception
io.netty.handler.codec.http2.Http2Stream stream
io.grpc.netty.NettyClientStream clientStream
}
io/grpc/netty/NettyClientHandler$3.classNettyClientHandler.java
package io.grpc.netty
io.grpc.netty.NettyClientHandler$3 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final int val$streamId
final io.grpc.netty.NettyClientStream val$stream
final io.netty.channel.ChannelPromise val$promise
final io.grpc.netty.NettyClientHandler this$0
void (io.grpc.netty.NettyClientHandler, int, io.grpc.netty.NettyClientStream, io.netty.channel.ChannelPromise)
io.grpc.netty.NettyClientHandler this$0
public void operationComplete (io.netty.channel.ChannelFuture) throws java.lang.Exception
io.netty.handler.codec.http2.Http2Stream http2Stream
io.netty.handler.codec.http2.StreamBufferingEncoder$Http2GoAwayException e
Throwable cause
io.netty.channel.ChannelFuture future
public volatile void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
}
io/grpc/netty/NettyClientHandler$4.classNettyClientHandler.java
package io.grpc.netty
io.grpc.netty.NettyClientHandler$4 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final io.grpc.internal.Http2Ping val$finalPing
final io.grpc.netty.NettyClientHandler this$0
void (io.grpc.netty.NettyClientHandler, io.grpc.internal.Http2Ping)
io.grpc.netty.NettyClientHandler this$0
public void operationComplete (io.netty.channel.ChannelFuture) throws java.lang.Exception
io.netty.channel.ChannelFuture future
public volatile void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
}
io/grpc/netty/NettyClientHandler$5.classNettyClientHandler.java
package io.grpc.netty
io.grpc.netty.NettyClientHandler$5 extends java.lang.Object implements io.netty.handler.codec.http2.Http2StreamVisitor {
final io.grpc.netty.ForcefulCloseCommand val$msg
final io.netty.channel.ChannelHandlerContext val$ctx
final io.grpc.netty.NettyClientHandler this$0
void (io.grpc.netty.NettyClientHandler, io.grpc.netty.ForcefulCloseCommand, io.netty.channel.ChannelHandlerContext)
io.grpc.netty.NettyClientHandler this$0
public boolean visit (io.netty.handler.codec.http2.Http2Stream) throws io.netty.handler.codec.http2.Http2Exception
io.netty.handler.codec.http2.Http2Stream stream
io.grpc.netty.NettyClientStream clientStream
}
io/grpc/netty/NettyClientHandler$6.classNettyClientHandler.java
package io.grpc.netty
io.grpc.netty.NettyClientHandler$6 extends java.lang.Object implements io.netty.handler.codec.http2.Http2StreamVisitor {
final int val$lastKnownStream
final io.grpc.Status val$goAwayStatus
final io.grpc.netty.NettyClientHandler this$0
void (io.grpc.netty.NettyClientHandler, int, io.grpc.Status)
io.grpc.netty.NettyClientHandler this$0
public boolean visit (io.netty.handler.codec.http2.Http2Stream) throws io.netty.handler.codec.http2.Http2Exception
io.grpc.netty.NettyClientStream clientStream
io.netty.handler.codec.http2.Http2Stream stream
}
io/grpc/netty/NettyClientHandler$FrameListener.classNettyClientHandler.java
package io.grpc.netty
io.grpc.netty.NettyClientHandler$FrameListener extends io.netty.handler.codec.http2.Http2FrameAdapter {
private boolean firstSettings
final io.grpc.netty.NettyClientHandler this$0
private void (io.grpc.netty.NettyClientHandler)
public void onSettingsRead (io.netty.channel.ChannelHandlerContext, io.netty.handler.codec.http2.Http2Settings)
io.netty.channel.ChannelHandlerContext ctx
io.netty.handler.codec.http2.Http2Settings settings
public int onDataRead (io.netty.channel.ChannelHandlerContext, int, io.netty.buffer.ByteBuf, int, boolean) throws io.netty.handler.codec.http2.Http2Exception
io.netty.channel.ChannelHandlerContext ctx
int streamId
io.netty.buffer.ByteBuf data
int padding
boolean endOfStream
public void onHeadersRead (io.netty.channel.ChannelHandlerContext, int, io.netty.handler.codec.http2.Http2Headers, int, short, boolean, int, boolean) throws io.netty.handler.codec.http2.Http2Exception
io.netty.channel.ChannelHandlerContext ctx
int streamId
io.netty.handler.codec.http2.Http2Headers headers
int streamDependency
short weight
boolean exclusive
int padding
boolean endStream
public void onRstStreamRead (io.netty.channel.ChannelHandlerContext, int, long) throws io.netty.handler.codec.http2.Http2Exception
io.netty.channel.ChannelHandlerContext ctx
int streamId
long errorCode
public void onPingAckRead (io.netty.channel.ChannelHandlerContext, io.netty.buffer.ByteBuf) throws io.netty.handler.codec.http2.Http2Exception
long ackPayload
io.netty.channel.ChannelHandlerContext ctx
io.netty.buffer.ByteBuf data
io.grpc.internal.Http2Ping p
void (io.grpc.netty.NettyClientHandler, io.grpc.netty.NettyClientHandler$1)
io.grpc.netty.NettyClientHandler x0
io.grpc.netty.NettyClientHandler$1 x1
}
io/grpc/netty/NettyClientHandler.classNettyClientHandler.java
package io.grpc.netty
io.grpc.netty.NettyClientHandler extends io.grpc.netty.AbstractNettyHandler {
private static final java.util.logging.Logger logger
static final Object NOOP_MESSAGE
private static final io.grpc.Status EXHAUSTED_STREAMS_STATUS
private final io.netty.handler.codec.http2.Http2Connection$PropertyKey streamKey
private final io.grpc.netty.ClientTransportLifecycleManager lifecycleManager
private final com.google.common.base.Ticker ticker
private final java.util.Random random
private io.grpc.netty.WriteQueue clientWriteQueue
private io.grpc.internal.Http2Ping ping
static io.grpc.netty.NettyClientHandler newHandler (io.grpc.netty.ClientTransportLifecycleManager, int, int, com.google.common.base.Ticker)
io.netty.handler.codec.http2.Http2Exception e
io.grpc.netty.ClientTransportLifecycleManager lifecycleManager
int flowControlWindow
int maxHeaderListSize
com.google.common.base.Ticker ticker
io.netty.handler.codec.http2.DefaultHttp2HeadersDecoder headersDecoder
io.netty.handler.codec.http2.Http2FrameReader frameReader
io.netty.handler.codec.http2.Http2FrameWriter frameWriter
io.netty.handler.codec.http2.Http2Connection connection
static io.grpc.netty.NettyClientHandler newHandler (io.netty.handler.codec.http2.Http2Connection, io.netty.handler.codec.http2.Http2FrameReader, io.netty.handler.codec.http2.Http2FrameWriter, io.grpc.netty.ClientTransportLifecycleManager, int, com.google.common.base.Ticker)
io.netty.handler.codec.http2.Http2Connection connection
io.netty.handler.codec.http2.Http2FrameReader frameReader
io.netty.handler.codec.http2.Http2FrameWriter frameWriter
io.grpc.netty.ClientTransportLifecycleManager lifecycleManager
int flowControlWindow
com.google.common.base.Ticker ticker
io.netty.handler.codec.http2.Http2FrameLogger frameLogger
io.netty.handler.codec.http2.StreamBufferingEncoder encoder
io.netty.handler.codec.http2.Http2ConnectionDecoder decoder
io.netty.handler.codec.http2.Http2Settings settings
private void (io.netty.handler.codec.http2.Http2ConnectionDecoder, io.netty.handler.codec.http2.StreamBufferingEncoder, io.netty.handler.codec.http2.Http2Settings, io.grpc.netty.ClientTransportLifecycleManager, com.google.common.base.Ticker)
io.netty.handler.codec.http2.Http2ConnectionDecoder decoder
io.netty.handler.codec.http2.StreamBufferingEncoder encoder
io.netty.handler.codec.http2.Http2Settings settings
io.grpc.netty.ClientTransportLifecycleManager lifecycleManager
com.google.common.base.Ticker ticker
io.netty.handler.codec.http2.Http2Connection connection
public void write (io.netty.channel.ChannelHandlerContext, java.lang.Object, io.netty.channel.ChannelPromise) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
Object msg
io.netty.channel.ChannelPromise promise
void startWriteQueue (io.netty.channel.Channel)
io.netty.channel.Channel channel
io.grpc.netty.WriteQueue getWriteQueue ()
void returnProcessedBytes (io.netty.handler.codec.http2.Http2Stream, int)
io.netty.handler.codec.http2.Http2Exception e
io.netty.handler.codec.http2.Http2Stream stream
int bytes
private void onHeadersRead (int, io.netty.handler.codec.http2.Http2Headers, boolean)
int streamId
io.netty.handler.codec.http2.Http2Headers headers
boolean endStream
io.grpc.netty.NettyClientStream stream
private void onDataRead (int, io.netty.buffer.ByteBuf, boolean)
int streamId
io.netty.buffer.ByteBuf data
boolean endOfStream
io.grpc.netty.NettyClientStream stream
private void onRstStreamRead (int, long)
io.grpc.Status status
int streamId
long errorCode
io.grpc.netty.NettyClientStream stream
public void close (io.netty.channel.ChannelHandlerContext, io.netty.channel.ChannelPromise) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
io.netty.channel.ChannelPromise promise
public void channelInactive (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
protected void onConnectionError (io.netty.channel.ChannelHandlerContext, java.lang.Throwable, io.netty.handler.codec.http2.Http2Exception)
io.netty.channel.ChannelHandlerContext ctx
Throwable cause
io.netty.handler.codec.http2.Http2Exception http2Ex
protected void onStreamError (io.netty.channel.ChannelHandlerContext, java.lang.Throwable, io.netty.handler.codec.http2.Http2Exception$StreamException)
io.netty.channel.ChannelHandlerContext ctx
Throwable cause
io.netty.handler.codec.http2.Http2Exception$StreamException http2Ex
io.grpc.netty.NettyClientStream stream
protected boolean isGracefulShutdownComplete ()
private void createStream (io.grpc.netty.CreateStreamCommand, io.netty.channel.ChannelPromise) throws java.lang.Exception
io.grpc.StatusException e
io.grpc.netty.CreateStreamCommand command
io.netty.channel.ChannelPromise promise
int streamId
int streamId
io.grpc.netty.NettyClientStream stream
io.netty.handler.codec.http2.Http2Headers headers
io.netty.channel.ChannelPromise tempPromise
private void cancelStream (io.netty.channel.ChannelHandlerContext, io.grpc.netty.CancelClientStreamCommand, io.netty.channel.ChannelPromise)
io.netty.channel.ChannelHandlerContext ctx
io.grpc.netty.CancelClientStreamCommand cmd
io.netty.channel.ChannelPromise promise
io.grpc.netty.NettyClientStream stream
private void sendGrpcFrame (io.netty.channel.ChannelHandlerContext, io.grpc.netty.SendGrpcFrameCommand, io.netty.channel.ChannelPromise)
io.netty.channel.ChannelHandlerContext ctx
io.grpc.netty.SendGrpcFrameCommand cmd
io.netty.channel.ChannelPromise promise
private void sendPingFrame (io.netty.channel.ChannelHandlerContext, io.grpc.netty.SendPingCommand, io.netty.channel.ChannelPromise)
io.netty.channel.ChannelHandlerContext ctx
io.grpc.netty.SendPingCommand msg
io.netty.channel.ChannelPromise promise
io.grpc.internal.ClientTransport$PingCallback callback
java.util.concurrent.Executor executor
long data
io.netty.buffer.ByteBuf buffer
com.google.common.base.Stopwatch stopwatch
io.grpc.internal.Http2Ping finalPing
private void gracefulClose (io.netty.channel.ChannelHandlerContext, io.grpc.netty.GracefulCloseCommand, io.netty.channel.ChannelPromise) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
io.grpc.netty.GracefulCloseCommand msg
io.netty.channel.ChannelPromise promise
private void forcefulClose (io.netty.channel.ChannelHandlerContext, io.grpc.netty.ForcefulCloseCommand, io.netty.channel.ChannelPromise) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
io.grpc.netty.ForcefulCloseCommand msg
io.netty.channel.ChannelPromise promise
private void goingAway (io.grpc.Status)
io.netty.handler.codec.http2.Http2Exception e
io.grpc.Status status
io.grpc.Status goAwayStatus
int lastKnownStream
private void cancelPing (java.lang.Throwable)
Throwable t
private io.grpc.Status statusFromGoAway (long, byte[])
String msg
long errorCode
byte[] debugData
io.grpc.Status status
private io.grpc.netty.NettyClientStream clientStream (io.netty.handler.codec.http2.Http2Stream)
io.netty.handler.codec.http2.Http2Stream stream
private int incrementAndGetNextStreamId () throws io.grpc.StatusException
int nextStreamId
private io.netty.handler.codec.http2.Http2Stream requireHttp2Stream (int)
int streamId
io.netty.handler.codec.http2.Http2Stream stream
static io.grpc.Status access$100 (io.grpc.netty.NettyClientHandler, long, byte[])
io.grpc.netty.NettyClientHandler x0
long x1
byte[] x2
static void access$200 (io.grpc.netty.NettyClientHandler, io.grpc.Status)
io.grpc.netty.NettyClientHandler x0
io.grpc.Status x1
static io.grpc.netty.ClientTransportLifecycleManager access$300 (io.grpc.netty.NettyClientHandler)
io.grpc.netty.NettyClientHandler x0
static io.grpc.netty.NettyClientStream access$400 (io.grpc.netty.NettyClientHandler, io.netty.handler.codec.http2.Http2Stream)
io.grpc.netty.NettyClientHandler x0
io.netty.handler.codec.http2.Http2Stream x1
static io.netty.handler.codec.http2.Http2Connection$PropertyKey access$500 (io.grpc.netty.NettyClientHandler)
io.grpc.netty.NettyClientHandler x0
static io.grpc.internal.Http2Ping access$600 (io.grpc.netty.NettyClientHandler)
io.grpc.netty.NettyClientHandler x0
static io.grpc.internal.Http2Ping access$602 (io.grpc.netty.NettyClientHandler, io.grpc.internal.Http2Ping)
io.grpc.netty.NettyClientHandler x0
io.grpc.internal.Http2Ping x1
static void access$700 (io.grpc.netty.NettyClientHandler, int, io.netty.buffer.ByteBuf, boolean)
io.grpc.netty.NettyClientHandler x0
int x1
io.netty.buffer.ByteBuf x2
boolean x3
static void access$800 (io.grpc.netty.NettyClientHandler, int, io.netty.handler.codec.http2.Http2Headers, boolean)
io.grpc.netty.NettyClientHandler x0
int x1
io.netty.handler.codec.http2.Http2Headers x2
boolean x3
static void access$900 (io.grpc.netty.NettyClientHandler, int, long)
io.grpc.netty.NettyClientHandler x0
int x1
long x2
static java.util.logging.Logger access$1000 ()
static void ()
}
io/grpc/netty/CreateStreamCommand.classCreateStreamCommand.java
package io.grpc.netty
io.grpc.netty.CreateStreamCommand extends io.grpc.netty.WriteQueue$AbstractQueuedCommand {
private final io.netty.handler.codec.http2.Http2Headers headers
private final io.grpc.netty.NettyClientStream stream
void (io.netty.handler.codec.http2.Http2Headers, io.grpc.netty.NettyClientStream)
io.netty.handler.codec.http2.Http2Headers headers
io.grpc.netty.NettyClientStream stream
io.grpc.netty.NettyClientStream stream ()
io.netty.handler.codec.http2.Http2Headers headers ()
}
io/grpc/netty/CancelServerStreamCommand.classCancelServerStreamCommand.java
package io.grpc.netty
io.grpc.netty.CancelServerStreamCommand extends io.grpc.netty.WriteQueue$AbstractQueuedCommand {
private final io.grpc.netty.NettyServerStream$TransportState stream
private final io.grpc.Status reason
void (io.grpc.netty.NettyServerStream$TransportState, io.grpc.Status)
io.grpc.netty.NettyServerStream$TransportState stream
io.grpc.Status reason
io.grpc.netty.NettyServerStream$TransportState stream ()
io.grpc.Status reason ()
public boolean equals (java.lang.Object)
Object o
io.grpc.netty.CancelServerStreamCommand that
public int hashCode ()
public java.lang.String toString ()
}
io/grpc/netty/NettyServerStream$Sink$1.classNettyServerStream.java
package io.grpc.netty
io.grpc.netty.NettyServerStream$Sink$1 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final int val$numBytes
final io.grpc.netty.NettyServerStream$Sink this$1
void (io.grpc.netty.NettyServerStream$Sink, int)
io.grpc.netty.NettyServerStream$Sink this$1
public void operationComplete (io.netty.channel.ChannelFuture) throws java.lang.Exception
io.netty.channel.ChannelFuture future
public volatile void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
}
io/grpc/netty/NettyServerStream$Sink.classNettyServerStream.java
package io.grpc.netty
io.grpc.netty.NettyServerStream$Sink extends java.lang.Object implements io.grpc.internal.AbstractServerStream$Sink {
final io.grpc.netty.NettyServerStream this$0
private void (io.grpc.netty.NettyServerStream)
public void request (int)
int numMessages
public void writeHeaders (io.grpc.Metadata)
io.grpc.Metadata headers
public void writeFrame (io.grpc.internal.WritableBuffer, boolean)
io.grpc.internal.WritableBuffer frame
boolean flush
io.netty.buffer.ByteBuf bytebuf
int numBytes
public void writeTrailers (io.grpc.Metadata, boolean)
io.grpc.Metadata trailers
boolean headersSent
io.netty.handler.codec.http2.Http2Headers http2Trailers
public void cancel (io.grpc.Status)
io.grpc.Status status
void (io.grpc.netty.NettyServerStream, io.grpc.netty.NettyServerStream$1)
io.grpc.netty.NettyServerStream x0
io.grpc.netty.NettyServerStream$1 x1
}
io/grpc/netty/NettyServerStream$TransportState.classNettyServerStream.java
package io.grpc.netty
public io.grpc.netty.NettyServerStream$TransportState extends io.grpc.internal.AbstractServerStream$TransportState implements io.grpc.netty.StreamIdHolder {
private final io.netty.handler.codec.http2.Http2Stream http2Stream
private final io.grpc.netty.NettyServerHandler handler
public void (io.grpc.netty.NettyServerHandler, io.netty.handler.codec.http2.Http2Stream, int)
io.grpc.netty.NettyServerHandler handler
io.netty.handler.codec.http2.Http2Stream http2Stream
int maxMessageSize
public void bytesRead (int)
int processedBytes
protected void deframeFailed (java.lang.Throwable)
Throwable cause
io.grpc.Status status
void inboundDataReceived (io.netty.buffer.ByteBuf, boolean)
io.netty.buffer.ByteBuf frame
boolean endOfStream
public java.lang.Integer id ()
public volatile void complete ()
public volatile void inboundDataReceived (io.grpc.internal.ReadableBuffer, boolean)
io.grpc.internal.ReadableBuffer x0
boolean x1
public volatile void endOfStream ()
public volatile void deliveryStalled ()
static io.grpc.netty.NettyServerHandler access$100 (io.grpc.netty.NettyServerStream$TransportState)
io.grpc.netty.NettyServerStream$TransportState x0
}
io/grpc/netty/NettyServerStream$1.classNettyServerStream.java
package io.grpc.netty
io.grpc.netty.NettyServerStream$1 extends java.lang.Object {
}
io/grpc/netty/NettyServerStream.classNettyServerStream.java
package io.grpc.netty
io.grpc.netty.NettyServerStream extends io.grpc.internal.AbstractServerStream {
private static final java.util.logging.Logger log
private final io.grpc.netty.NettyServerStream$Sink sink
private final io.grpc.netty.NettyServerStream$TransportState state
private final io.netty.channel.Channel channel
private final io.grpc.netty.WriteQueue writeQueue
private final io.grpc.Attributes attributes
public void (io.netty.channel.Channel, io.grpc.netty.NettyServerStream$TransportState)
io.netty.channel.Channel channel
io.grpc.netty.NettyServerStream$TransportState state
protected io.grpc.netty.NettyServerStream$TransportState transportState ()
protected io.grpc.netty.NettyServerStream$Sink abstractServerStreamSink ()
public io.grpc.Attributes attributes ()
private static io.grpc.Attributes buildAttributes (io.netty.channel.Channel)
io.netty.channel.Channel channel
javax.net.ssl.SSLSession sslSession
public void setListener (io.grpc.internal.ServerStreamListener)
io.grpc.internal.ServerStreamListener serverStreamListener
protected volatile io.grpc.internal.AbstractServerStream$Sink abstractServerStreamSink ()
protected volatile io.grpc.internal.AbstractServerStream$TransportState transportState ()
protected volatile io.grpc.internal.AbstractStream2$TransportState transportState ()
static io.netty.channel.Channel access$200 (io.grpc.netty.NettyServerStream)
io.grpc.netty.NettyServerStream x0
static io.grpc.netty.WriteQueue access$300 (io.grpc.netty.NettyServerStream)
io.grpc.netty.NettyServerStream x0
static void access$400 (io.grpc.netty.NettyServerStream, int)
io.grpc.netty.NettyServerStream x0
int x1
static java.util.logging.Logger access$500 ()
static void ()
}
io/grpc/netty/Utils$DefaultEventLoopGroupResource.classUtils.java
package io.grpc.netty
io.grpc.netty.Utils$DefaultEventLoopGroupResource extends java.lang.Object implements io.grpc.internal.SharedResourceHolder$Resource {
private final String name
private final int numEventLoops
void (int, java.lang.String)
int numEventLoops
String name
public io.netty.channel.EventLoopGroup create ()
boolean useDaemonThreads
java.util.concurrent.ThreadFactory threadFactory
int parallelism
public void close (io.netty.channel.EventLoopGroup)
io.netty.channel.EventLoopGroup instance
public java.lang.String toString ()
public volatile void close (java.lang.Object)
public volatile java.lang.Object create ()
}
io/grpc/netty/Utils.classUtils.java
package io.grpc.netty
io.grpc.netty.Utils extends java.lang.Object {
public static final io.netty.util.AsciiString STATUS_OK
public static final io.netty.util.AsciiString HTTP_METHOD
public static final io.netty.util.AsciiString HTTPS
public static final io.netty.util.AsciiString HTTP
public static final io.netty.util.AsciiString CONTENT_TYPE_HEADER
public static final io.netty.util.AsciiString CONTENT_TYPE_GRPC
public static final io.netty.util.AsciiString TE_HEADER
public static final io.netty.util.AsciiString TE_TRAILERS
public static final io.netty.util.AsciiString USER_AGENT
public static final io.grpc.internal.SharedResourceHolder$Resource DEFAULT_BOSS_EVENT_LOOP_GROUP
public static final io.grpc.internal.SharedResourceHolder$Resource DEFAULT_WORKER_EVENT_LOOP_GROUP
public static final io.netty.util.AttributeKey SSL_SESSION_ATTR_KEY
static boolean validateHeaders
public static io.grpc.Metadata convertHeaders (io.netty.handler.codec.http2.Http2Headers)
io.netty.handler.codec.http2.Http2Headers http2Headers
private static byte[][] convertHeadersToArray (io.netty.handler.codec.http2.Http2Headers)
java.util.Map$Entry entry
io.netty.handler.codec.http2.Http2Headers http2Headers
byte[][] headerValues
int i
private static byte[] bytes (java.lang.CharSequence)
io.netty.util.AsciiString str
CharSequence seq
public static io.netty.handler.codec.http2.Http2Headers convertClientHeaders (io.grpc.Metadata, io.netty.util.AsciiString, io.netty.util.AsciiString, io.netty.util.AsciiString, io.netty.util.AsciiString)
io.grpc.Metadata headers
io.netty.util.AsciiString scheme
io.netty.util.AsciiString defaultPath
io.netty.util.AsciiString authority
io.netty.util.AsciiString userAgent
public static io.netty.handler.codec.http2.Http2Headers convertServerHeaders (io.grpc.Metadata)
io.grpc.Metadata headers
public static io.grpc.Metadata convertTrailers (io.netty.handler.codec.http2.Http2Headers)
io.netty.handler.codec.http2.Http2Headers http2Headers
public static io.netty.handler.codec.http2.Http2Headers convertTrailers (io.grpc.Metadata, boolean)
io.grpc.Metadata trailers
boolean headersSent
public static io.grpc.Status statusFromThrowable (java.lang.Throwable)
Throwable t
io.grpc.Status s
private void ()
static void ()
}
io/grpc/netty/NettyServerHandler$1.classNettyServerHandler.java
package io.grpc.netty
io.grpc.netty.NettyServerHandler$1 extends java.lang.Object implements io.netty.handler.codec.http2.Http2StreamVisitor {
final io.grpc.Status val$status
final io.grpc.netty.NettyServerHandler this$0
void (io.grpc.netty.NettyServerHandler, io.grpc.Status)
io.grpc.netty.NettyServerHandler this$0
public boolean visit (io.netty.handler.codec.http2.Http2Stream) throws io.netty.handler.codec.http2.Http2Exception
io.netty.handler.codec.http2.Http2Stream stream
io.grpc.netty.NettyServerStream$TransportState serverStream
}
io/grpc/netty/NettyServerHandler$2.classNettyServerHandler.java
package io.grpc.netty
io.grpc.netty.NettyServerHandler$2 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final io.grpc.netty.NettyServerStream$TransportState val$stream
final io.grpc.netty.NettyServerHandler this$0
void (io.grpc.netty.NettyServerHandler, io.grpc.netty.NettyServerStream$TransportState)
io.grpc.netty.NettyServerHandler this$0
public void operationComplete (io.netty.channel.ChannelFuture)
io.netty.channel.ChannelFuture future
public volatile void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
}
io/grpc/netty/NettyServerHandler$3.classNettyServerHandler.java
package io.grpc.netty
io.grpc.netty.NettyServerHandler$3 extends java.lang.Object implements io.netty.handler.codec.http2.Http2StreamVisitor {
final io.grpc.netty.ForcefulCloseCommand val$msg
final io.netty.channel.ChannelHandlerContext val$ctx
final io.grpc.netty.NettyServerHandler this$0
void (io.grpc.netty.NettyServerHandler, io.grpc.netty.ForcefulCloseCommand, io.netty.channel.ChannelHandlerContext)
io.grpc.netty.NettyServerHandler this$0
public boolean visit (io.netty.handler.codec.http2.Http2Stream) throws io.netty.handler.codec.http2.Http2Exception
io.netty.handler.codec.http2.Http2Stream stream
io.grpc.netty.NettyServerStream$TransportState serverStream
}
io/grpc/netty/NettyServerHandler$FrameListener.classNettyServerHandler.java
package io.grpc.netty
io.grpc.netty.NettyServerHandler$FrameListener extends io.netty.handler.codec.http2.Http2FrameAdapter {
final io.grpc.netty.NettyServerHandler this$0
private void (io.grpc.netty.NettyServerHandler)
public int onDataRead (io.netty.channel.ChannelHandlerContext, int, io.netty.buffer.ByteBuf, int, boolean) throws io.netty.handler.codec.http2.Http2Exception
io.netty.channel.ChannelHandlerContext ctx
int streamId
io.netty.buffer.ByteBuf data
int padding
boolean endOfStream
public void onHeadersRead (io.netty.channel.ChannelHandlerContext, int, io.netty.handler.codec.http2.Http2Headers, int, short, boolean, int, boolean) throws io.netty.handler.codec.http2.Http2Exception
io.netty.channel.ChannelHandlerContext ctx
int streamId
io.netty.handler.codec.http2.Http2Headers headers
int streamDependency
short weight
boolean exclusive
int padding
boolean endStream
public void onRstStreamRead (io.netty.channel.ChannelHandlerContext, int, long) throws io.netty.handler.codec.http2.Http2Exception
io.netty.channel.ChannelHandlerContext ctx
int streamId
long errorCode
void (io.grpc.netty.NettyServerHandler, io.grpc.netty.NettyServerHandler$1)
io.grpc.netty.NettyServerHandler x0
io.grpc.netty.NettyServerHandler$1 x1
}
io/grpc/netty/NettyServerHandler.classNettyServerHandler.java
package io.grpc.netty
io.grpc.netty.NettyServerHandler extends io.grpc.netty.AbstractNettyHandler {
private static java.util.logging.Logger logger
private final io.netty.handler.codec.http2.Http2Connection$PropertyKey streamKey
private final io.grpc.internal.ServerTransportListener transportListener
private final int maxMessageSize
private Throwable connectionError
private boolean teWarningLogged
private io.grpc.netty.WriteQueue serverWriteQueue
static io.grpc.netty.NettyServerHandler newHandler (io.grpc.internal.ServerTransportListener, int, int, int, int)
io.netty.handler.codec.http2.Http2Exception e
io.grpc.internal.ServerTransportListener transportListener
int maxStreams
int flowControlWindow
int maxHeaderListSize
int maxMessageSize
io.netty.handler.codec.http2.Http2FrameLogger frameLogger
io.netty.handler.codec.http2.DefaultHttp2HeadersDecoder headersDecoder
io.netty.handler.codec.http2.Http2FrameReader frameReader
io.netty.handler.codec.http2.Http2FrameWriter frameWriter
static io.grpc.netty.NettyServerHandler newHandler (io.netty.handler.codec.http2.Http2FrameReader, io.netty.handler.codec.http2.Http2FrameWriter, io.grpc.internal.ServerTransportListener, int, int, int)
io.netty.handler.codec.http2.Http2FrameReader frameReader
io.netty.handler.codec.http2.Http2FrameWriter frameWriter
io.grpc.internal.ServerTransportListener transportListener
int maxStreams
int flowControlWindow
int maxMessageSize
io.netty.handler.codec.http2.Http2Connection connection
io.netty.handler.codec.http2.Http2ConnectionEncoder encoder
io.netty.handler.codec.http2.Http2ConnectionDecoder decoder
io.netty.handler.codec.http2.Http2Settings settings
private void (io.grpc.internal.ServerTransportListener, io.netty.handler.codec.http2.Http2ConnectionDecoder, io.netty.handler.codec.http2.Http2ConnectionEncoder, io.netty.handler.codec.http2.Http2Settings, int)
io.grpc.internal.ServerTransportListener transportListener
io.netty.handler.codec.http2.Http2ConnectionDecoder decoder
io.netty.handler.codec.http2.Http2ConnectionEncoder encoder
io.netty.handler.codec.http2.Http2Settings settings
int maxMessageSize
java.lang.Throwable connectionError ()
public void handlerAdded (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
private void onHeadersRead (io.netty.channel.ChannelHandlerContext, int, io.netty.handler.codec.http2.Http2Headers) throws io.netty.handler.codec.http2.Http2Exception
String method
io.netty.handler.codec.http2.Http2Stream http2Stream
io.grpc.netty.NettyServerStream$TransportState state
io.grpc.netty.NettyServerStream stream
io.grpc.Metadata metadata
io.netty.handler.codec.http2.Http2Exception e
Throwable e
io.netty.channel.ChannelHandlerContext ctx
int streamId
io.netty.handler.codec.http2.Http2Headers headers
private void onDataRead (int, io.netty.buffer.ByteBuf, boolean) throws io.netty.handler.codec.http2.Http2Exception
io.grpc.netty.NettyServerStream$TransportState stream
Throwable e
int streamId
io.netty.buffer.ByteBuf data
boolean endOfStream
private void onRstStreamRead (int) throws io.netty.handler.codec.http2.Http2Exception
io.grpc.netty.NettyServerStream$TransportState stream
Throwable e
int streamId
protected void onConnectionError (io.netty.channel.ChannelHandlerContext, java.lang.Throwable, io.netty.handler.codec.http2.Http2Exception)
io.netty.channel.ChannelHandlerContext ctx
Throwable cause
io.netty.handler.codec.http2.Http2Exception http2Ex
protected void onStreamError (io.netty.channel.ChannelHandlerContext, java.lang.Throwable, io.netty.handler.codec.http2.Http2Exception$StreamException)
io.netty.channel.ChannelHandlerContext ctx
Throwable cause
io.netty.handler.codec.http2.Http2Exception$StreamException http2Ex
io.grpc.netty.NettyServerStream$TransportState serverStream
public void channelInactive (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
io.grpc.Status status
io.netty.channel.ChannelHandlerContext ctx
io.grpc.netty.WriteQueue getWriteQueue ()
public void write (io.netty.channel.ChannelHandlerContext, java.lang.Object, io.netty.channel.ChannelPromise) throws java.lang.Exception
AssertionError e
io.netty.channel.ChannelHandlerContext ctx
Object msg
io.netty.channel.ChannelPromise promise
void returnProcessedBytes (io.netty.handler.codec.http2.Http2Stream, int)
io.netty.handler.codec.http2.Http2Exception e
io.netty.handler.codec.http2.Http2Stream http2Stream
int bytes
private void closeStreamWhenDone (io.netty.channel.ChannelPromise, int) throws io.netty.handler.codec.http2.Http2Exception
io.netty.channel.ChannelPromise promise
int streamId
io.grpc.netty.NettyServerStream$TransportState stream
private void sendGrpcFrame (io.netty.channel.ChannelHandlerContext, io.grpc.netty.SendGrpcFrameCommand, io.netty.channel.ChannelPromise) throws io.netty.handler.codec.http2.Http2Exception
io.netty.channel.ChannelHandlerContext ctx
io.grpc.netty.SendGrpcFrameCommand cmd
io.netty.channel.ChannelPromise promise
private void sendResponseHeaders (io.netty.channel.ChannelHandlerContext, io.grpc.netty.SendResponseHeadersCommand, io.netty.channel.ChannelPromise) throws io.netty.handler.codec.http2.Http2Exception
io.netty.channel.ChannelHandlerContext ctx
io.grpc.netty.SendResponseHeadersCommand cmd
io.netty.channel.ChannelPromise promise
private void cancelStream (io.netty.channel.ChannelHandlerContext, io.grpc.netty.CancelServerStreamCommand, io.netty.channel.ChannelPromise)
io.netty.channel.ChannelHandlerContext ctx
io.grpc.netty.CancelServerStreamCommand cmd
io.netty.channel.ChannelPromise promise
private void forcefulClose (io.netty.channel.ChannelHandlerContext, io.grpc.netty.ForcefulCloseCommand, io.netty.channel.ChannelPromise) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
io.grpc.netty.ForcefulCloseCommand msg
io.netty.channel.ChannelPromise promise
private void verifyContentType (int, io.netty.handler.codec.http2.Http2Headers) throws io.netty.handler.codec.http2.Http2Exception
int streamId
io.netty.handler.codec.http2.Http2Headers headers
CharSequence contentType
String contentTypeString
private io.netty.handler.codec.http2.Http2Stream requireHttp2Stream (int)
int streamId
io.netty.handler.codec.http2.Http2Stream stream
private java.lang.String determineMethod (int, io.netty.handler.codec.http2.Http2Headers) throws io.netty.handler.codec.http2.Http2Exception
int streamId
io.netty.handler.codec.http2.Http2Headers headers
CharSequence path
private static void checkHeader (int, io.netty.handler.codec.http2.Http2Headers, java.lang.CharSequence, java.lang.CharSequence) throws io.netty.handler.codec.http2.Http2Exception
int streamId
io.netty.handler.codec.http2.Http2Headers headers
CharSequence header
CharSequence expectedValue
private io.grpc.netty.NettyServerStream$TransportState serverStream (io.netty.handler.codec.http2.Http2Stream)
io.netty.handler.codec.http2.Http2Stream stream
private io.netty.handler.codec.http2.Http2Exception newStreamException (int, java.lang.Throwable)
int streamId
Throwable cause
static io.grpc.netty.NettyServerStream$TransportState access$100 (io.grpc.netty.NettyServerHandler, io.netty.handler.codec.http2.Http2Stream)
io.grpc.netty.NettyServerHandler x0
io.netty.handler.codec.http2.Http2Stream x1
static void access$200 (io.grpc.netty.NettyServerHandler, int, io.netty.buffer.ByteBuf, boolean) throws io.netty.handler.codec.http2.Http2Exception
io.grpc.netty.NettyServerHandler x0
int x1
io.netty.buffer.ByteBuf x2
boolean x3
static void access$300 (io.grpc.netty.NettyServerHandler, io.netty.channel.ChannelHandlerContext, int, io.netty.handler.codec.http2.Http2Headers) throws io.netty.handler.codec.http2.Http2Exception
io.grpc.netty.NettyServerHandler x0
io.netty.channel.ChannelHandlerContext x1
int x2
io.netty.handler.codec.http2.Http2Headers x3
static void access$400 (io.grpc.netty.NettyServerHandler, int) throws io.netty.handler.codec.http2.Http2Exception
io.grpc.netty.NettyServerHandler x0
int x1
static void ()
}
io/grpc/netty/SendResponseHeadersCommand.classSendResponseHeadersCommand.java
package io.grpc.netty
io.grpc.netty.SendResponseHeadersCommand extends io.grpc.netty.WriteQueue$AbstractQueuedCommand {
private final io.grpc.netty.StreamIdHolder stream
private final io.netty.handler.codec.http2.Http2Headers headers
private final boolean endOfStream
void (io.grpc.netty.StreamIdHolder, io.netty.handler.codec.http2.Http2Headers, boolean)
io.grpc.netty.StreamIdHolder stream
io.netty.handler.codec.http2.Http2Headers headers
boolean endOfStream
io.grpc.netty.StreamIdHolder stream ()
io.netty.handler.codec.http2.Http2Headers headers ()
boolean endOfStream ()
public boolean equals (java.lang.Object)
Object that
io.grpc.netty.SendResponseHeadersCommand thatCmd
public java.lang.String toString ()
public int hashCode ()
}
io/grpc/netty/GrpcHttp2Headers$Itr.classGrpcHttp2Headers.java
package io.grpc.netty
io.grpc.netty.GrpcHttp2Headers$Itr extends java.lang.Object implements java.util.Map$Entry java.util.Iterator {
private int idx
private io.netty.util.AsciiString[] current
private io.netty.util.AsciiString key
private io.netty.util.AsciiString value
final io.grpc.netty.GrpcHttp2Headers this$0
private void (io.grpc.netty.GrpcHttp2Headers)
public boolean hasNext ()
public java.util.Map$Entry next ()
public java.lang.CharSequence getKey ()
public java.lang.CharSequence getValue ()
public java.lang.CharSequence setValue (java.lang.CharSequence)
CharSequence value
public void remove ()
public volatile java.lang.Object setValue (java.lang.Object)
public volatile java.lang.Object getValue ()
public volatile java.lang.Object getKey ()
public volatile java.lang.Object next ()
void (io.grpc.netty.GrpcHttp2Headers, io.grpc.netty.GrpcHttp2Headers$1)
io.grpc.netty.GrpcHttp2Headers x0
io.grpc.netty.GrpcHttp2Headers$1 x1
}
io/grpc/netty/GrpcHttp2Headers$1.classGrpcHttp2Headers.java
package io.grpc.netty
io.grpc.netty.GrpcHttp2Headers$1 extends java.lang.Object {
}
io/grpc/netty/GrpcHttp2Headers.classGrpcHttp2Headers.java
package io.grpc.netty
final io.grpc.netty.GrpcHttp2Headers extends io.grpc.netty.AbstractHttp2Headers {
private final io.netty.util.AsciiString[] normalHeaders
private final io.netty.util.AsciiString[] preHeaders
private static final io.netty.util.AsciiString[] EMPTY
static io.grpc.netty.GrpcHttp2Headers clientRequestHeaders (byte[][], io.netty.util.AsciiString, io.netty.util.AsciiString, io.netty.util.AsciiString, io.netty.util.AsciiString, io.netty.util.AsciiString)
byte[][] serializedMetadata
io.netty.util.AsciiString authority
io.netty.util.AsciiString path
io.netty.util.AsciiString method
io.netty.util.AsciiString scheme
io.netty.util.AsciiString userAgent
io.netty.util.AsciiString[] preHeaders
static io.grpc.netty.GrpcHttp2Headers serverResponseHeaders (byte[][])
byte[][] serializedMetadata
io.netty.util.AsciiString[] preHeaders
static io.grpc.netty.GrpcHttp2Headers serverResponseTrailers (byte[][])
byte[][] serializedMetadata
private void (io.netty.util.AsciiString[], byte[][])
int i
io.netty.util.AsciiString[] preHeaders
byte[][] serializedMetadata
public java.util.Iterator iterator ()
public int size ()
public java.lang.String toString ()
CharSequence name
CharSequence value
java.util.Map$Entry e
StringBuilder builder
String separator
static io.netty.util.AsciiString[] access$100 (io.grpc.netty.GrpcHttp2Headers)
io.grpc.netty.GrpcHttp2Headers x0
static io.netty.util.AsciiString[] access$200 (io.grpc.netty.GrpcHttp2Headers)
io.grpc.netty.GrpcHttp2Headers x0
static void ()
}
io/grpc/netty/NettyClientTransport$1.classNettyClientTransport.java
package io.grpc.netty
io.grpc.netty.NettyClientTransport$1 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final io.grpc.internal.ClientTransport$PingCallback val$callback
final java.util.concurrent.Executor val$executor
final io.grpc.netty.NettyClientTransport this$0
void (io.grpc.netty.NettyClientTransport, io.grpc.internal.ClientTransport$PingCallback, java.util.concurrent.Executor)
io.grpc.netty.NettyClientTransport this$0
public void operationComplete (io.netty.channel.ChannelFuture) throws java.lang.Exception
io.grpc.Status s
io.netty.channel.ChannelFuture future
public volatile void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
}
io/grpc/netty/NettyClientTransport$2.classNettyClientTransport.java
package io.grpc.netty
io.grpc.netty.NettyClientTransport$2 extends io.grpc.netty.NettyClientStream {
final io.grpc.netty.NettyClientTransport this$0
void (io.grpc.netty.NettyClientTransport, io.grpc.MethodDescriptor, io.grpc.Metadata, io.netty.channel.Channel, io.grpc.netty.NettyClientHandler, int, io.netty.util.AsciiString, io.netty.util.AsciiString, io.netty.util.AsciiString)
io.grpc.netty.NettyClientTransport this$0
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
io.netty.channel.Channel channel
io.grpc.netty.NettyClientHandler handler
int maxMessageSize
io.netty.util.AsciiString authority
io.netty.util.AsciiString scheme
io.netty.util.AsciiString userAgent
protected io.grpc.Status statusFromFailedFuture (io.netty.channel.ChannelFuture)
io.netty.channel.ChannelFuture f
}
io/grpc/netty/NettyClientTransport$3.classNettyClientTransport.java
package io.grpc.netty
io.grpc.netty.NettyClientTransport$3 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final io.grpc.netty.NettyClientTransport this$0
void (io.grpc.netty.NettyClientTransport)
io.grpc.netty.NettyClientTransport this$0
public void operationComplete (io.netty.channel.ChannelFuture) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
io.netty.channel.ChannelFuture future
public volatile void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
}
io/grpc/netty/NettyClientTransport$4.classNettyClientTransport.java
package io.grpc.netty
io.grpc.netty.NettyClientTransport$4 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final io.grpc.netty.NettyClientTransport this$0
void (io.grpc.netty.NettyClientTransport)
io.grpc.netty.NettyClientTransport this$0
public void operationComplete (io.netty.channel.ChannelFuture) throws java.lang.Exception
io.netty.channel.ChannelFuture future
public volatile void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
}
io/grpc/netty/NettyClientTransport$5.classNettyClientTransport.java
package io.grpc.netty
io.grpc.netty.NettyClientTransport$5 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final io.grpc.netty.NettyClientTransport this$0
void (io.grpc.netty.NettyClientTransport)
io.grpc.netty.NettyClientTransport this$0
public void operationComplete (io.netty.channel.ChannelFuture) throws java.lang.Exception
io.netty.channel.ChannelFuture future
public volatile void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
}
io/grpc/netty/NettyClientTransport.classNettyClientTransport.java
package io.grpc.netty
io.grpc.netty.NettyClientTransport extends java.lang.Object implements io.grpc.internal.ConnectionClientTransport {
private final java.net.SocketAddress address
private final Class channelType
private final io.netty.channel.EventLoopGroup group
private final io.grpc.netty.ProtocolNegotiator negotiator
private final io.netty.util.AsciiString authority
private final io.netty.util.AsciiString userAgent
private final int flowControlWindow
private final int maxMessageSize
private final int maxHeaderListSize
private io.grpc.netty.ProtocolNegotiator$Handler negotiationHandler
private io.grpc.netty.NettyClientHandler handler
private io.netty.channel.Channel channel
private io.grpc.netty.ClientTransportLifecycleManager lifecycleManager
void (java.net.SocketAddress, java.lang.Class, io.netty.channel.EventLoopGroup, io.grpc.netty.ProtocolNegotiator, int, int, int, java.lang.String, java.lang.String)
java.net.SocketAddress address
Class channelType
io.netty.channel.EventLoopGroup group
io.grpc.netty.ProtocolNegotiator negotiator
int flowControlWindow
int maxMessageSize
int maxHeaderListSize
String authority
String userAgent
public void ping (io.grpc.internal.ClientTransport$PingCallback, java.util.concurrent.Executor)
io.grpc.internal.ClientTransport$PingCallback callback
java.util.concurrent.Executor executor
io.netty.channel.ChannelFutureListener failureListener
public io.grpc.internal.ClientStream newStream (io.grpc.MethodDescriptor, io.grpc.Metadata, io.grpc.CallOptions)
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
io.grpc.CallOptions callOptions
public io.grpc.internal.ClientStream newStream (io.grpc.MethodDescriptor, io.grpc.Metadata)
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
public java.lang.Runnable start (io.grpc.internal.ManagedClientTransport$Listener)
io.grpc.internal.ManagedClientTransport$Listener transportListener
io.netty.bootstrap.Bootstrap b
public void shutdown ()
io.grpc.Status status
public void shutdownNow (io.grpc.Status)
io.grpc.Status reason
public java.lang.String toString ()
public java.lang.String getLogId ()
public io.grpc.Attributes getAttrs ()
private io.grpc.Status statusFromFailedFuture (io.netty.channel.ChannelFuture)
io.grpc.Status shutdownStatus
io.netty.channel.ChannelFuture f
Throwable t
private io.grpc.netty.NettyClientHandler newHandler ()
static io.grpc.Status access$000 (io.grpc.netty.NettyClientTransport, io.netty.channel.ChannelFuture)
io.grpc.netty.NettyClientTransport x0
io.netty.channel.ChannelFuture x1
static io.grpc.netty.NettyClientHandler access$100 (io.grpc.netty.NettyClientTransport)
io.grpc.netty.NettyClientTransport x0
static io.grpc.netty.ClientTransportLifecycleManager access$200 (io.grpc.netty.NettyClientTransport)
io.grpc.netty.NettyClientTransport x0
}
io/grpc/netty/NettyReadableBuffer.classNettyReadableBuffer.java
package io.grpc.netty
io.grpc.netty.NettyReadableBuffer extends io.grpc.internal.AbstractReadableBuffer {
private final io.netty.buffer.ByteBuf buffer
private boolean closed
void (io.netty.buffer.ByteBuf)
io.netty.buffer.ByteBuf buffer
io.netty.buffer.ByteBuf buffer ()
public int readableBytes ()
public void skipBytes (int)
int length
public int readUnsignedByte ()
public void readBytes (byte[], int, int)
byte[] dest
int index
int length
public void readBytes (java.nio.ByteBuffer)
java.nio.ByteBuffer dest
public void readBytes (java.io.OutputStream, int)
java.io.IOException e
java.io.OutputStream dest
int length
public io.grpc.netty.NettyReadableBuffer readBytes (int)
int length
public boolean hasArray ()
public byte[] array ()
public int arrayOffset ()
public void close ()
public volatile io.grpc.internal.ReadableBuffer readBytes (int)
}
io/grpc/netty/NettyServerTransport$1.classNettyServerTransport.java
package io.grpc.netty
io.grpc.netty.NettyServerTransport$1 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final io.grpc.netty.NettyServerHandler val$grpcHandler
final io.grpc.netty.NettyServerTransport this$0
void (io.grpc.netty.NettyServerTransport, io.grpc.netty.NettyServerHandler)
io.grpc.netty.NettyServerTransport this$0
public void operationComplete (io.netty.channel.ChannelFuture) throws java.lang.Exception
io.netty.channel.ChannelFuture future
public volatile void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
}
io/grpc/netty/NettyServerTransport.classNettyServerTransport.java
package io.grpc.netty
io.grpc.netty.NettyServerTransport extends java.lang.Object implements io.grpc.internal.ServerTransport {
private static final java.util.logging.Logger log
private final io.netty.channel.Channel channel
private final io.grpc.netty.ProtocolNegotiator protocolNegotiator
private final int maxStreams
private io.grpc.internal.ServerTransportListener listener
private boolean terminated
private final int flowControlWindow
private final int maxMessageSize
private final int maxHeaderListSize
void (io.netty.channel.Channel, io.grpc.netty.ProtocolNegotiator, int, int, int, int)
io.netty.channel.Channel channel
io.grpc.netty.ProtocolNegotiator protocolNegotiator
int maxStreams
int flowControlWindow
int maxMessageSize
int maxHeaderListSize
public void start (io.grpc.internal.ServerTransportListener)
io.grpc.internal.ServerTransportListener listener
io.grpc.netty.NettyServerHandler grpcHandler
io.netty.channel.ChannelHandler negotiationHandler
public void shutdown ()
public void shutdownNow (io.grpc.Status)
io.grpc.Status reason
io.netty.channel.Channel channel ()
private void notifyTerminated (java.lang.Throwable)
Throwable t
private io.grpc.netty.NettyServerHandler createHandler (io.grpc.internal.ServerTransportListener)
io.grpc.internal.ServerTransportListener transportListener
static void access$000 (io.grpc.netty.NettyServerTransport, java.lang.Throwable)
io.grpc.netty.NettyServerTransport x0
Throwable x1
static void ()
}
io/grpc/netty/ProtocolNegotiators$1$1PlaintextHandler.classProtocolNegotiators.java
package io.grpc.netty
io.grpc.netty.ProtocolNegotiators$1$1PlaintextHandler extends io.netty.channel.ChannelHandlerAdapter implements io.grpc.netty.ProtocolNegotiator$Handler {
final io.netty.handler.codec.http2.Http2ConnectionHandler val$handler
final io.grpc.netty.ProtocolNegotiators$1 this$0
void (io.grpc.netty.ProtocolNegotiators$1, io.netty.handler.codec.http2.Http2ConnectionHandler)
io.grpc.netty.ProtocolNegotiators$1 this$0
public void handlerAdded (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
public io.netty.util.AsciiString scheme ()
}
io/grpc/netty/ProtocolNegotiators$1.classProtocolNegotiators.java
package io.grpc.netty
final io.grpc.netty.ProtocolNegotiators$1 extends java.lang.Object implements io.grpc.netty.ProtocolNegotiator {
void ()
public io.grpc.netty.ProtocolNegotiator$Handler newHandler (io.netty.handler.codec.http2.Http2ConnectionHandler)
io.netty.handler.codec.http2.Http2ConnectionHandler handler
}
io/grpc/netty/ProtocolNegotiators$2.classProtocolNegotiators.java
package io.grpc.netty
final io.grpc.netty.ProtocolNegotiators$2 extends java.lang.Object implements io.grpc.netty.ProtocolNegotiator {
final io.netty.handler.ssl.SslContext val$sslContext
void (io.netty.handler.ssl.SslContext)
public io.grpc.netty.ProtocolNegotiator$Handler newHandler (io.netty.handler.codec.http2.Http2ConnectionHandler)
io.netty.handler.codec.http2.Http2ConnectionHandler handler
}
io/grpc/netty/ProtocolNegotiators$ServerTlsHandler.classProtocolNegotiators.java
package io.grpc.netty
final io.grpc.netty.ProtocolNegotiators$ServerTlsHandler extends io.netty.channel.ChannelInboundHandlerAdapter implements io.grpc.netty.ProtocolNegotiator$Handler {
private final io.netty.channel.ChannelHandler grpcHandler
private final io.netty.handler.ssl.SslContext sslContext
void (io.netty.handler.ssl.SslContext, io.netty.channel.ChannelHandler)
io.netty.handler.ssl.SslContext sslContext
io.netty.channel.ChannelHandler grpcHandler
public void handlerAdded (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
javax.net.ssl.SSLEngine sslEngine
public void exceptionCaught (io.netty.channel.ChannelHandlerContext, java.lang.Throwable) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
Throwable cause
public void userEventTriggered (io.netty.channel.ChannelHandlerContext, java.lang.Object) throws java.lang.Exception
io.netty.util.Attribute sslSessionAttr
io.netty.handler.ssl.SslHandshakeCompletionEvent handshakeEvent
io.netty.channel.ChannelHandlerContext ctx
Object evt
private io.netty.handler.ssl.SslHandler sslHandler (io.netty.channel.ChannelPipeline)
io.netty.channel.ChannelPipeline pipeline
private void fail (io.netty.channel.ChannelHandlerContext, java.lang.Throwable)
io.netty.channel.ChannelHandlerContext ctx
Throwable exception
public io.netty.util.AsciiString scheme ()
}
io/grpc/netty/ProtocolNegotiators$1ProxyNegotiator.classProtocolNegotiators.java
package io.grpc.netty
io.grpc.netty.ProtocolNegotiators$1ProxyNegotiator extends java.lang.Object implements io.grpc.netty.ProtocolNegotiator {
final String val$proxyUsername
final String val$proxyPassword
final java.net.SocketAddress val$proxyAddress
final io.grpc.netty.ProtocolNegotiator val$negotiator
void (java.lang.String, java.lang.String, java.net.SocketAddress, io.grpc.netty.ProtocolNegotiator)
public io.grpc.netty.ProtocolNegotiator$Handler newHandler (io.netty.handler.codec.http2.Http2ConnectionHandler)
io.netty.handler.proxy.HttpProxyHandler proxyHandler
io.netty.handler.codec.http2.Http2ConnectionHandler http2Handler
io.netty.handler.proxy.HttpProxyHandler proxyHandler
}
io/grpc/netty/ProtocolNegotiators$BufferUntilProxyTunnelledHandler.classProtocolNegotiators.java
package io.grpc.netty
final io.grpc.netty.ProtocolNegotiators$BufferUntilProxyTunnelledHandler extends io.grpc.netty.ProtocolNegotiators$AbstractBufferingHandler implements io.grpc.netty.ProtocolNegotiator$Handler {
private final io.grpc.netty.ProtocolNegotiator$Handler originalHandler
public void (io.netty.handler.proxy.ProxyHandler, io.grpc.netty.ProtocolNegotiator$Handler)
io.netty.handler.proxy.ProxyHandler proxyHandler
io.grpc.netty.ProtocolNegotiator$Handler handler
public io.netty.util.AsciiString scheme ()
public void userEventTriggered (io.netty.channel.ChannelHandlerContext, java.lang.Object) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
Object evt
public void channelInactive (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
public void close (io.netty.channel.ChannelHandlerContext, io.netty.channel.ChannelPromise) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
io.netty.channel.ChannelPromise future
}
io/grpc/netty/ProtocolNegotiators$TlsNegotiator$1.classProtocolNegotiators.java
package io.grpc.netty
io.grpc.netty.ProtocolNegotiators$TlsNegotiator$1 extends io.netty.channel.ChannelHandlerAdapter {
final io.grpc.netty.ProtocolNegotiators$TlsNegotiator this$0
void (io.grpc.netty.ProtocolNegotiators$TlsNegotiator)
io.grpc.netty.ProtocolNegotiators$TlsNegotiator this$0
public void handlerAdded (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
javax.net.ssl.SSLEngine sslEngine
javax.net.ssl.SSLParameters sslParams
}
io/grpc/netty/ProtocolNegotiators$TlsNegotiator.classProtocolNegotiators.java
package io.grpc.netty
final io.grpc.netty.ProtocolNegotiators$TlsNegotiator extends java.lang.Object implements io.grpc.netty.ProtocolNegotiator {
private final io.netty.handler.ssl.SslContext sslContext
private final String host
private final int port
void (io.netty.handler.ssl.SslContext, java.lang.String, int)
io.netty.handler.ssl.SslContext sslContext
String host
int port
java.lang.String getHost ()
int getPort ()
public io.grpc.netty.ProtocolNegotiator$Handler newHandler (io.netty.handler.codec.http2.Http2ConnectionHandler)
io.netty.handler.codec.http2.Http2ConnectionHandler handler
io.netty.channel.ChannelHandler sslBootstrap
static java.lang.String access$100 (io.grpc.netty.ProtocolNegotiators$TlsNegotiator)
io.grpc.netty.ProtocolNegotiators$TlsNegotiator x0
static int access$200 (io.grpc.netty.ProtocolNegotiators$TlsNegotiator)
io.grpc.netty.ProtocolNegotiators$TlsNegotiator x0
static io.netty.handler.ssl.SslContext access$300 (io.grpc.netty.ProtocolNegotiators$TlsNegotiator)
io.grpc.netty.ProtocolNegotiators$TlsNegotiator x0
}
io/grpc/netty/ProtocolNegotiators$PlaintextUpgradeNegotiator.classProtocolNegotiators.java
package io.grpc.netty
final io.grpc.netty.ProtocolNegotiators$PlaintextUpgradeNegotiator extends java.lang.Object implements io.grpc.netty.ProtocolNegotiator {
void ()
public io.grpc.netty.ProtocolNegotiator$Handler newHandler (io.netty.handler.codec.http2.Http2ConnectionHandler)
io.netty.handler.codec.http2.Http2ConnectionHandler handler
io.netty.handler.codec.http2.Http2ClientUpgradeCodec upgradeCodec
io.netty.handler.codec.http.HttpClientCodec httpClientCodec
io.netty.handler.codec.http.HttpClientUpgradeHandler upgrader
}
io/grpc/netty/ProtocolNegotiators$PlaintextNegotiator.classProtocolNegotiators.java
package io.grpc.netty
final io.grpc.netty.ProtocolNegotiators$PlaintextNegotiator extends java.lang.Object implements io.grpc.netty.ProtocolNegotiator {
void ()
public io.grpc.netty.ProtocolNegotiator$Handler newHandler (io.netty.handler.codec.http2.Http2ConnectionHandler)
io.netty.handler.codec.http2.Http2ConnectionHandler handler
}
io/grpc/netty/ProtocolNegotiators$AbstractBufferingHandler$ChannelWrite.classProtocolNegotiators.java
package io.grpc.netty
io.grpc.netty.ProtocolNegotiators$AbstractBufferingHandler$ChannelWrite extends java.lang.Object {
Object msg
io.netty.channel.ChannelPromise promise
void (java.lang.Object, io.netty.channel.ChannelPromise)
Object msg
io.netty.channel.ChannelPromise promise
}
io/grpc/netty/ProtocolNegotiators$AbstractBufferingHandler.classProtocolNegotiators.java
package io.grpc.netty
public abstract io.grpc.netty.ProtocolNegotiators$AbstractBufferingHandler extends io.netty.channel.ChannelDuplexHandler {
private io.netty.channel.ChannelHandler[] handlers
private java.util.Queue bufferedWrites
private boolean writing
private boolean flushRequested
private Throwable failCause
static final boolean $assertionsDisabled
protected transient void (io.netty.channel.ChannelHandler[])
io.netty.channel.ChannelHandler[] handlers
public void channelRegistered (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
io.netty.channel.ChannelHandler handler
io.netty.channel.ChannelHandler handler0
io.netty.channel.ChannelHandlerContext handler0Ctx
io.netty.channel.ChannelHandlerContext ctx
public void exceptionCaught (io.netty.channel.ChannelHandlerContext, java.lang.Throwable) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
Throwable cause
public void channelInactive (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
public void write (io.netty.channel.ChannelHandlerContext, java.lang.Object, io.netty.channel.ChannelPromise) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
Object msg
io.netty.channel.ChannelPromise promise
public void flush (io.netty.channel.ChannelHandlerContext)
io.netty.channel.ChannelHandlerContext ctx
public void close (io.netty.channel.ChannelHandlerContext, io.netty.channel.ChannelPromise) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
io.netty.channel.ChannelPromise future
protected final void fail (io.netty.channel.ChannelHandlerContext, java.lang.Throwable)
io.grpc.netty.ProtocolNegotiators$AbstractBufferingHandler$ChannelWrite write
io.netty.channel.ChannelHandlerContext ctx
Throwable cause
protected final void writeBufferedAndRemove (io.netty.channel.ChannelHandlerContext)
io.grpc.netty.ProtocolNegotiators$AbstractBufferingHandler$ChannelWrite write
io.netty.channel.ChannelHandlerContext ctx
static void ()
}
io/grpc/netty/ProtocolNegotiators$BufferUntilTlsNegotiatedHandler.classProtocolNegotiators.java
package io.grpc.netty
io.grpc.netty.ProtocolNegotiators$BufferUntilTlsNegotiatedHandler extends io.grpc.netty.ProtocolNegotiators$AbstractBufferingHandler implements io.grpc.netty.ProtocolNegotiator$Handler {
transient void (io.netty.channel.ChannelHandler[])
io.netty.channel.ChannelHandler[] handlers
public io.netty.util.AsciiString scheme ()
public void userEventTriggered (io.netty.channel.ChannelHandlerContext, java.lang.Object) throws java.lang.Exception
Exception ex
io.netty.handler.ssl.SslHandler handler
io.netty.handler.ssl.SslHandshakeCompletionEvent handshakeEvent
io.netty.channel.ChannelHandlerContext ctx
Object evt
}
io/grpc/netty/ProtocolNegotiators$BufferUntilChannelActiveHandler.classProtocolNegotiators.java
package io.grpc.netty
io.grpc.netty.ProtocolNegotiators$BufferUntilChannelActiveHandler extends io.grpc.netty.ProtocolNegotiators$AbstractBufferingHandler implements io.grpc.netty.ProtocolNegotiator$Handler {
transient void (io.netty.channel.ChannelHandler[])
io.netty.channel.ChannelHandler[] handlers
public io.netty.util.AsciiString scheme ()
public void handlerAdded (io.netty.channel.ChannelHandlerContext)
io.netty.channel.ChannelHandlerContext ctx
public void channelActive (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
}
io/grpc/netty/ProtocolNegotiators$BufferingHttp2UpgradeHandler.classProtocolNegotiators.java
package io.grpc.netty
io.grpc.netty.ProtocolNegotiators$BufferingHttp2UpgradeHandler extends io.grpc.netty.ProtocolNegotiators$AbstractBufferingHandler implements io.grpc.netty.ProtocolNegotiator$Handler {
transient void (io.netty.channel.ChannelHandler[])
io.netty.channel.ChannelHandler[] handlers
public io.netty.util.AsciiString scheme ()
public void channelActive (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
io.netty.handler.codec.http.DefaultHttpRequest upgradeTrigger
public void userEventTriggered (io.netty.channel.ChannelHandlerContext, java.lang.Object) throws java.lang.Exception
io.netty.channel.ChannelHandlerContext ctx
Object evt
}
io/grpc/netty/ProtocolNegotiators.classProtocolNegotiators.java
package io.grpc.netty
public final io.grpc.netty.ProtocolNegotiators extends java.lang.Object {
private static final java.util.logging.Logger log
private void ()
public static io.grpc.netty.ProtocolNegotiator serverPlaintext ()
public static io.grpc.netty.ProtocolNegotiator serverTls (io.netty.handler.ssl.SslContext)
io.netty.handler.ssl.SslContext sslContext
public static io.grpc.netty.ProtocolNegotiator httpProxy (java.net.SocketAddress, java.lang.String, java.lang.String, io.grpc.netty.ProtocolNegotiator)
java.net.SocketAddress proxyAddress
String proxyUsername
String proxyPassword
io.grpc.netty.ProtocolNegotiator negotiator
public static io.grpc.netty.ProtocolNegotiator tls (io.netty.handler.ssl.SslContext, java.lang.String)
String host
int port
io.netty.handler.ssl.SslContext sslContext
String authority
java.net.URI uri
String host
int port
public static io.grpc.netty.ProtocolNegotiator plaintextUpgrade ()
public static io.grpc.netty.ProtocolNegotiator plaintext ()
private static java.lang.RuntimeException unavailableException (java.lang.String)
String msg
static void logSslEngineDetails (java.util.logging.Level, io.netty.channel.ChannelHandlerContext, java.lang.String, java.lang.Throwable)
java.util.logging.Level level
io.netty.channel.ChannelHandlerContext ctx
String msg
Throwable t
io.netty.handler.ssl.SslHandler sslHandler
javax.net.ssl.SSLEngine engine
StringBuilder builder
static java.lang.RuntimeException access$000 (java.lang.String)
String x0
static void ()
}
io/grpc/netty/RequestMessagesCommand.classRequestMessagesCommand.java
package io.grpc.netty
io.grpc.netty.RequestMessagesCommand extends io.grpc.netty.WriteQueue$AbstractQueuedCommand {
private final int numMessages
private final io.grpc.internal.Stream stream
private final io.grpc.internal.AbstractStream2$TransportState state
public void (io.grpc.internal.Stream, int)
io.grpc.internal.Stream stream
int numMessages
public void (io.grpc.internal.AbstractStream2$TransportState, int)
io.grpc.internal.AbstractStream2$TransportState state
int numMessages
void requestMessages ()
}
META-INF/services/
META-INF/services/io.grpc.ManagedChannelProvider
META-INF/services/io.grpc.ServerProvider