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 synthetic io.netty.handler.codec.Headers clear ()
public volatile synthetic boolean remove (java.lang.Object)
public volatile synthetic io.netty.handler.codec.Headers setAll (io.netty.handler.codec.Headers)
public volatile synthetic io.netty.handler.codec.Headers set (io.netty.handler.codec.Headers)
public volatile synthetic io.netty.handler.codec.Headers setTimeMillis (java.lang.Object, long)
public volatile synthetic io.netty.handler.codec.Headers setDouble (java.lang.Object, double)
public volatile synthetic io.netty.handler.codec.Headers setFloat (java.lang.Object, float)
public volatile synthetic io.netty.handler.codec.Headers setLong (java.lang.Object, long)
public volatile synthetic io.netty.handler.codec.Headers setInt (java.lang.Object, int)
public volatile synthetic io.netty.handler.codec.Headers setShort (java.lang.Object, short)
public volatile synthetic io.netty.handler.codec.Headers setChar (java.lang.Object, char)
public volatile synthetic io.netty.handler.codec.Headers setByte (java.lang.Object, byte)
public volatile synthetic io.netty.handler.codec.Headers setBoolean (java.lang.Object, boolean)
public volatile synthetic io.netty.handler.codec.Headers setObject (java.lang.Object, java.lang.Object[])
public volatile synthetic io.netty.handler.codec.Headers setObject (java.lang.Object, java.lang.Iterable)
public volatile synthetic io.netty.handler.codec.Headers setObject (java.lang.Object, java.lang.Object)
public volatile synthetic io.netty.handler.codec.Headers set (java.lang.Object, java.lang.Object[])
public volatile synthetic io.netty.handler.codec.Headers set (java.lang.Object, java.lang.Iterable)
public volatile synthetic io.netty.handler.codec.Headers set (java.lang.Object, java.lang.Object)
public volatile synthetic io.netty.handler.codec.Headers add (io.netty.handler.codec.Headers)
public volatile synthetic io.netty.handler.codec.Headers addTimeMillis (java.lang.Object, long)
public volatile synthetic io.netty.handler.codec.Headers addDouble (java.lang.Object, double)
public volatile synthetic io.netty.handler.codec.Headers addFloat (java.lang.Object, float)
public volatile synthetic io.netty.handler.codec.Headers addLong (java.lang.Object, long)
public volatile synthetic io.netty.handler.codec.Headers addInt (java.lang.Object, int)
public volatile synthetic io.netty.handler.codec.Headers addShort (java.lang.Object, short)
public volatile synthetic io.netty.handler.codec.Headers addChar (java.lang.Object, char)
public volatile synthetic io.netty.handler.codec.Headers addByte (java.lang.Object, byte)
public volatile synthetic io.netty.handler.codec.Headers addBoolean (java.lang.Object, boolean)
public volatile synthetic io.netty.handler.codec.Headers addObject (java.lang.Object, java.lang.Object[])
public volatile synthetic io.netty.handler.codec.Headers addObject (java.lang.Object, java.lang.Iterable)
public volatile synthetic io.netty.handler.codec.Headers addObject (java.lang.Object, java.lang.Object)
public volatile synthetic io.netty.handler.codec.Headers add (java.lang.Object, java.lang.Object[])
public volatile synthetic io.netty.handler.codec.Headers add (java.lang.Object, java.lang.Iterable)
public volatile synthetic io.netty.handler.codec.Headers add (java.lang.Object, java.lang.Object)
public volatile synthetic boolean containsTimeMillis (java.lang.Object, long)
public volatile synthetic boolean containsDouble (java.lang.Object, double)
public volatile synthetic boolean containsFloat (java.lang.Object, float)
public volatile synthetic boolean containsLong (java.lang.Object, long)
public volatile synthetic boolean containsInt (java.lang.Object, int)
public volatile synthetic boolean containsShort (java.lang.Object, short)
public volatile synthetic boolean containsChar (java.lang.Object, char)
public volatile synthetic boolean containsByte (java.lang.Object, byte)
public volatile synthetic boolean containsBoolean (java.lang.Object, boolean)
public volatile synthetic boolean containsObject (java.lang.Object, java.lang.Object)
public volatile synthetic boolean contains (java.lang.Object, java.lang.Object)
public volatile synthetic boolean contains (java.lang.Object)
public volatile synthetic long getTimeMillisAndRemove (java.lang.Object, long)
public volatile synthetic java.lang.Long getTimeMillisAndRemove (java.lang.Object)
public volatile synthetic double getDoubleAndRemove (java.lang.Object, double)
public volatile synthetic java.lang.Double getDoubleAndRemove (java.lang.Object)
public volatile synthetic float getFloatAndRemove (java.lang.Object, float)
public volatile synthetic java.lang.Float getFloatAndRemove (java.lang.Object)
public volatile synthetic long getLongAndRemove (java.lang.Object, long)
public volatile synthetic java.lang.Long getLongAndRemove (java.lang.Object)
public volatile synthetic int getIntAndRemove (java.lang.Object, int)
public volatile synthetic java.lang.Integer getIntAndRemove (java.lang.Object)
public volatile synthetic short getShortAndRemove (java.lang.Object, short)
public volatile synthetic java.lang.Short getShortAndRemove (java.lang.Object)
public volatile synthetic char getCharAndRemove (java.lang.Object, char)
public volatile synthetic java.lang.Character getCharAndRemove (java.lang.Object)
public volatile synthetic byte getByteAndRemove (java.lang.Object, byte)
public volatile synthetic java.lang.Byte getByteAndRemove (java.lang.Object)
public volatile synthetic boolean getBooleanAndRemove (java.lang.Object, boolean)
public volatile synthetic java.lang.Boolean getBooleanAndRemove (java.lang.Object)
public volatile synthetic long getTimeMillis (java.lang.Object, long)
public volatile synthetic java.lang.Long getTimeMillis (java.lang.Object)
public volatile synthetic double getDouble (java.lang.Object, double)
public volatile synthetic java.lang.Double getDouble (java.lang.Object)
public volatile synthetic float getFloat (java.lang.Object, float)
public volatile synthetic java.lang.Float getFloat (java.lang.Object)
public volatile synthetic long getLong (java.lang.Object, long)
public volatile synthetic java.lang.Long getLong (java.lang.Object)
public volatile synthetic int getInt (java.lang.Object, int)
public volatile synthetic java.lang.Integer getInt (java.lang.Object)
public volatile synthetic short getShort (java.lang.Object, short)
public volatile synthetic java.lang.Short getShort (java.lang.Object)
public volatile synthetic char getChar (java.lang.Object, char)
public volatile synthetic java.lang.Character getChar (java.lang.Object)
public volatile synthetic byte getByte (java.lang.Object, byte)
public volatile synthetic java.lang.Byte getByte (java.lang.Object)
public volatile synthetic boolean getBoolean (java.lang.Object, boolean)
public volatile synthetic java.lang.Boolean getBoolean (java.lang.Object)
public volatile synthetic java.util.List getAllAndRemove (java.lang.Object)
public volatile synthetic java.util.List getAll (java.lang.Object)
public volatile synthetic java.lang.Object getAndRemove (java.lang.Object, java.lang.Object)
public volatile synthetic java.lang.Object getAndRemove (java.lang.Object)
public volatile synthetic java.lang.Object get (java.lang.Object, java.lang.Object)
public volatile synthetic 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 synthetic 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 synthetic 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
synthetic io.grpc.netty.GrpcSslContexts$1 extends java.lang.Object {
static final synthetic 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 enum io.grpc.netty.NegotiationType extends java.lang.Enum {
public static final enum io.grpc.netty.NegotiationType TLS
public static final enum io.grpc.netty.NegotiationType PLAINTEXT_UPGRADE
public static final enum io.grpc.netty.NegotiationType PLAINTEXT
private static final synthetic 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 synthetic io.grpc.ManagedChannelBuilder builderForTarget (java.lang.String)
public volatile synthetic 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 ()
synthetic 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
synthetic io.grpc.netty.NettyChannelBuilder$1 extends java.lang.Object {
static final synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic io.netty.util.ReferenceCounted access$000 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic io.grpc.netty.ProtocolNegotiator access$100 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic int access$200 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic int access$300 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic int access$400 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic int access$500 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic io.netty.channel.Channel access$600 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic io.grpc.internal.ServerListener access$700 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic java.util.logging.Logger access$800 ()
static synthetic boolean access$900 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic io.netty.channel.EventLoopGroup access$1000 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic 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 synthetic boolean access$1100 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic io.netty.channel.EventLoopGroup access$1200 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic 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 synthetic 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 synthetic io.grpc.internal.InternalServer buildTransportServer ()
public volatile synthetic 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 synthetic io.netty.buffer.ByteBufHolder touch (java.lang.Object)
public volatile synthetic io.netty.buffer.ByteBufHolder touch ()
public volatile synthetic io.netty.buffer.ByteBufHolder retain (int)
public volatile synthetic io.netty.buffer.ByteBufHolder retain ()
public volatile synthetic io.netty.util.ReferenceCounted touch (java.lang.Object)
public volatile synthetic io.netty.util.ReferenceCounted touch ()
public volatile synthetic io.netty.util.ReferenceCounted retain (int)
public volatile synthetic 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 synthetic 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 synthetic 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 synthetic int val$numBytes
final synthetic 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 synthetic 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 synthetic java.lang.Object id ()
static synthetic 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 synthetic 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 synthetic 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 synthetic int val$streamId
final synthetic io.grpc.netty.NettyClientStream val$stream
final synthetic io.netty.channel.ChannelPromise val$promise
final synthetic 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 synthetic 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 synthetic io.grpc.internal.Http2Ping val$finalPing
final synthetic 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 synthetic 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 synthetic io.grpc.netty.ForcefulCloseCommand val$msg
final synthetic io.netty.channel.ChannelHandlerContext val$ctx
final synthetic 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 synthetic int val$lastKnownStream
final synthetic io.grpc.Status val$goAwayStatus
final synthetic 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 synthetic 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
synthetic 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 synthetic io.grpc.Status access$100 (io.grpc.netty.NettyClientHandler, long, byte[])
io.grpc.netty.NettyClientHandler x0
long x1
byte[] x2
static synthetic void access$200 (io.grpc.netty.NettyClientHandler, io.grpc.Status)
io.grpc.netty.NettyClientHandler x0
io.grpc.Status x1
static synthetic io.grpc.netty.ClientTransportLifecycleManager access$300 (io.grpc.netty.NettyClientHandler)
io.grpc.netty.NettyClientHandler x0
static synthetic 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 synthetic io.netty.handler.codec.http2.Http2Connection$PropertyKey access$500 (io.grpc.netty.NettyClientHandler)
io.grpc.netty.NettyClientHandler x0
static synthetic io.grpc.internal.Http2Ping access$600 (io.grpc.netty.NettyClientHandler)
io.grpc.netty.NettyClientHandler x0
static synthetic 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 synthetic 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 synthetic 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 synthetic void access$900 (io.grpc.netty.NettyClientHandler, int, long)
io.grpc.netty.NettyClientHandler x0
int x1
long x2
static synthetic 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 synthetic int val$numBytes
final synthetic 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 synthetic 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 synthetic 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
synthetic 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 synthetic void complete ()
public volatile synthetic void inboundDataReceived (io.grpc.internal.ReadableBuffer, boolean)
io.grpc.internal.ReadableBuffer x0
boolean x1
public volatile synthetic void endOfStream ()
public volatile synthetic void deliveryStalled ()
static synthetic 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
synthetic 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 synthetic io.grpc.internal.AbstractServerStream$Sink abstractServerStreamSink ()
protected volatile synthetic io.grpc.internal.AbstractServerStream$TransportState transportState ()
protected volatile synthetic io.grpc.internal.AbstractStream2$TransportState transportState ()
static synthetic io.netty.channel.Channel access$200 (io.grpc.netty.NettyServerStream)
io.grpc.netty.NettyServerStream x0
static synthetic io.grpc.netty.WriteQueue access$300 (io.grpc.netty.NettyServerStream)
io.grpc.netty.NettyServerStream x0
static synthetic void access$400 (io.grpc.netty.NettyServerStream, int)
io.grpc.netty.NettyServerStream x0
int x1
static synthetic 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 synthetic void close (java.lang.Object)
public volatile synthetic 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 synthetic io.grpc.Status val$status
final synthetic 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 synthetic io.grpc.netty.NettyServerStream$TransportState val$stream
final synthetic 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 synthetic 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 synthetic io.grpc.netty.ForcefulCloseCommand val$msg
final synthetic io.netty.channel.ChannelHandlerContext val$ctx
final synthetic 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 synthetic 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
synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic java.lang.Object setValue (java.lang.Object)
public volatile synthetic java.lang.Object getValue ()
public volatile synthetic java.lang.Object getKey ()
public volatile synthetic java.lang.Object next ()
synthetic 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
synthetic 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 synthetic io.netty.util.AsciiString[] access$100 (io.grpc.netty.GrpcHttp2Headers)
io.grpc.netty.GrpcHttp2Headers x0
static synthetic 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 synthetic io.grpc.internal.ClientTransport$PingCallback val$callback
final synthetic java.util.concurrent.Executor val$executor
final synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic 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 synthetic io.grpc.Status access$000 (io.grpc.netty.NettyClientTransport, io.netty.channel.ChannelFuture)
io.grpc.netty.NettyClientTransport x0
io.netty.channel.ChannelFuture x1
static synthetic io.grpc.netty.NettyClientHandler access$100 (io.grpc.netty.NettyClientTransport)
io.grpc.netty.NettyClientTransport x0
static synthetic 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 synthetic 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 synthetic io.grpc.netty.NettyServerHandler val$grpcHandler
final synthetic 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 synthetic 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 synthetic 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 synthetic io.netty.handler.codec.http2.Http2ConnectionHandler val$handler
final synthetic 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 synthetic 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 synthetic String val$proxyUsername
final synthetic String val$proxyPassword
final synthetic java.net.SocketAddress val$proxyAddress
final synthetic 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 synthetic 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 synthetic java.lang.String access$100 (io.grpc.netty.ProtocolNegotiators$TlsNegotiator)
io.grpc.netty.ProtocolNegotiators$TlsNegotiator x0
static synthetic int access$200 (io.grpc.netty.ProtocolNegotiators$TlsNegotiator)
io.grpc.netty.ProtocolNegotiators$TlsNegotiator x0
static synthetic 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 synthetic 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 synthetic 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