META-INF/
META-INF/MANIFEST.MF
io/
io/grpc/
io/grpc/netty/
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
String message
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 java.lang.Object {
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 {
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 io.netty.util.AsciiString authority
private final io.netty.util.AsciiString scheme
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.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
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
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
}
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 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.grpc.netty.ClientTransportLifecycleManager lifecycleManager
int flowControlWindow
int maxHeaderListSize
com.google.common.base.Ticker ticker
io.netty.handler.codec.http2.Http2HeadersDecoder 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) throws io.netty.handler.codec.http2.Http2Exception
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) throws io.netty.handler.codec.http2.Http2Exception
int streamId
io.netty.buffer.ByteBuf data
boolean endOfStream
io.grpc.netty.NettyClientStream stream
private void onRstStreamRead (int, long) throws io.netty.handler.codec.http2.Http2Exception
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 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.NettyClientStream access$300 (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.grpc.netty.ClientTransportLifecycleManager access$400 (io.grpc.netty.NettyClientHandler)
io.grpc.netty.NettyClientHandler x0
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) throws io.netty.handler.codec.http2.Http2Exception
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) throws io.netty.handler.codec.http2.Http2Exception
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) throws io.netty.handler.codec.http2.Http2Exception
io.grpc.netty.NettyClientHandler x0
int x1
long x2
static synthetic java.util.logging.Logger access$1000 ()
static void ()
}
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$QueuedCommand.classWriteQueue.java
package io.grpc.netty
final io.grpc.netty.WriteQueue$QueuedCommand extends java.lang.Object implements java.lang.Runnable {
private final Object command
private final io.netty.channel.ChannelPromise promise
final synthetic io.grpc.netty.WriteQueue this$0
private void (io.grpc.netty.WriteQueue, java.lang.Object, io.netty.channel.ChannelPromise)
Object command
io.netty.channel.ChannelPromise promise
public void run ()
synthetic void (io.grpc.netty.WriteQueue, java.lang.Object, io.netty.channel.ChannelPromise, io.grpc.netty.WriteQueue$1)
io.grpc.netty.WriteQueue x0
Object x1
io.netty.channel.ChannelPromise x2
io.grpc.netty.WriteQueue$1 x3
}
io/grpc/netty/WriteQueue.classWriteQueue.java
package io.grpc.netty
io.grpc.netty.WriteQueue extends java.lang.Object {
private 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 (java.lang.Object, boolean)
Object command
boolean flush
io.netty.channel.ChannelFuture enqueue (java.lang.Object, io.netty.channel.ChannelPromise, boolean)
Object command
io.netty.channel.ChannelPromise promise
boolean flush
private void flush ()
boolean flushed
static synthetic void access$000 (io.grpc.netty.WriteQueue)
io.grpc.netty.WriteQueue x0
static synthetic io.netty.channel.Channel access$200 (io.grpc.netty.WriteQueue)
io.grpc.netty.WriteQueue x0
}
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 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 notifyTerminated (io.grpc.Status)
io.grpc.Status s
public io.grpc.Status getShutdownStatus ()
public java.lang.Throwable getShutdownThrowable ()
}
io/grpc/netty/CreateStreamCommand.classCreateStreamCommand.java
package io.grpc.netty
io.grpc.netty.CreateStreamCommand extends java.lang.Object {
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/SendGrpcFrameCommand.classSendGrpcFrameCommand.java
package io.grpc.netty
io.grpc.netty.SendGrpcFrameCommand extends io.netty.buffer.DefaultByteBufHolder {
private final io.grpc.internal.AbstractStream stream
private final boolean endStream
void (io.grpc.internal.AbstractStream, io.netty.buffer.ByteBuf, boolean)
io.grpc.internal.AbstractStream 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 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/SendPingCommand.classSendPingCommand.java
package io.grpc.netty
io.grpc.netty.SendPingCommand extends java.lang.Object {
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/GracefulCloseCommand.classGracefulCloseCommand.java
package io.grpc.netty
io.grpc.netty.GracefulCloseCommand extends java.lang.Object {
private final io.grpc.Status status
public void (io.grpc.Status)
io.grpc.Status status
public io.grpc.Status getStatus ()
}
io/grpc/netty/CancelServerStreamCommand.classCancelServerStreamCommand.java
package io.grpc.netty
io.grpc.netty.CancelServerStreamCommand extends java.lang.Object {
private final io.grpc.netty.NettyServerStream stream
private final io.grpc.Status reason
void (io.grpc.netty.NettyServerStream, io.grpc.Status)
io.grpc.netty.NettyServerStream stream
io.grpc.Status reason
io.grpc.netty.NettyServerStream 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$1.classNettyServerStream.java
package io.grpc.netty
io.grpc.netty.NettyServerStream$1 extends java.lang.Object implements io.netty.channel.ChannelFutureListener {
final synthetic int val$numBytes
final synthetic io.grpc.netty.NettyServerStream this$0
void (io.grpc.netty.NettyServerStream, int)
io.grpc.netty.NettyServerStream 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/NettyServerStream.classNettyServerStream.java
package io.grpc.netty
io.grpc.netty.NettyServerStream extends io.grpc.internal.AbstractServerStream {
private final io.netty.channel.Channel channel
private final io.grpc.netty.NettyServerHandler handler
private final io.netty.handler.codec.http2.Http2Stream http2Stream
private final io.grpc.netty.WriteQueue writeQueue
void (io.netty.channel.Channel, io.netty.handler.codec.http2.Http2Stream, io.grpc.netty.NettyServerHandler, int)
io.netty.channel.Channel channel
io.netty.handler.codec.http2.Http2Stream http2Stream
io.grpc.netty.NettyServerHandler handler
int maxMessageSize
public java.lang.Integer id ()
protected void inboundHeadersReceived (io.grpc.Metadata)
io.grpc.Metadata headers
void inboundDataReceived (io.netty.buffer.ByteBuf, boolean)
io.netty.buffer.ByteBuf frame
boolean endOfStream
public void request (int)
int numMessages
protected void inboundDeliveryPaused ()
protected void internalSendHeaders (io.grpc.Metadata)
io.grpc.Metadata headers
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 sendTrailers (io.grpc.Metadata, boolean)
io.grpc.Metadata trailers
boolean headersSent
io.netty.handler.codec.http2.Http2Headers http2Trailers
protected void returnProcessedBytes (int)
int processedBytes
protected void sendStreamAbortToClient (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
public void cancel (io.grpc.Status)
io.grpc.Status status
public volatile synthetic java.lang.Object id ()
static synthetic void access$000 (io.grpc.netty.NettyServerStream, int)
io.grpc.netty.NettyServerStream x0
int x1
}
io/grpc/netty/Utils$DefaultEventLoopGroupResource$1.classUtils.java
package io.grpc.netty
io.grpc.netty.Utils$DefaultEventLoopGroupResource$1 extends java.lang.Object implements io.netty.util.concurrent.GenericFutureListener {
final synthetic java.util.concurrent.ExecutorService val$executor
final synthetic io.grpc.netty.Utils$DefaultEventLoopGroupResource this$0
void (io.grpc.netty.Utils$DefaultEventLoopGroupResource, java.util.concurrent.ExecutorService)
io.grpc.netty.Utils$DefaultEventLoopGroupResource this$0
public void operationComplete (io.netty.util.concurrent.Future) throws java.lang.Exception
io.netty.util.concurrent.Future future
}
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 ()
java.util.concurrent.ThreadFactory threadFactory
int parallelism
java.util.concurrent.ExecutorService executor
io.netty.channel.nio.NioEventLoopGroup nioEventLoopGroup
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 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)
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.grpc.Metadata headers
io.netty.util.AsciiString scheme
io.netty.util.AsciiString defaultPath
io.netty.util.AsciiString authority
io.netty.handler.codec.http2.Http2Headers http2Headers
String userAgent
public static io.netty.handler.codec.http2.Http2Headers convertServerHeaders (io.grpc.Metadata)
io.grpc.Metadata headers
io.netty.handler.codec.http2.Http2Headers http2Headers
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
io.netty.handler.codec.http2.Http2Headers http2Trailers
private static io.netty.handler.codec.http2.Http2Headers convertMetadata (io.grpc.Metadata)
io.netty.util.AsciiString name
io.netty.util.AsciiString value
int i
io.grpc.Metadata headers
io.netty.handler.codec.http2.Http2Headers http2Headers
byte[][] serializedHeaders
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.netty.NettyServerHandler this$0
void (io.grpc.netty.NettyServerHandler)
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 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 val$stream
final synthetic io.grpc.netty.NettyServerHandler this$0
void (io.grpc.netty.NettyServerHandler, io.grpc.netty.NettyServerStream)
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$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 static final io.grpc.Status GOAWAY_STATUS
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.grpc.internal.ServerTransportListener transportListener
int maxStreams
int flowControlWindow
int maxHeaderListSize
int maxMessageSize
io.netty.handler.codec.http2.Http2FrameLogger frameLogger
io.netty.handler.codec.http2.Http2HeadersDecoder 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 stream
io.grpc.Metadata metadata
io.grpc.internal.ServerStreamListener listener
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 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 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 serverStream
public void channelInactive (io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
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 io.netty.handler.codec.http2.Http2Exception
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 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 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 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 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 io.grpc.Status access$200 ()
static synthetic void access$300 (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$400 (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$500 (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 java.lang.Object {
private final int streamId
private final io.netty.handler.codec.http2.Http2Headers headers
private final boolean endOfStream
void (int, io.netty.handler.codec.http2.Http2Headers, boolean)
int streamId
io.netty.handler.codec.http2.Http2Headers headers
boolean endOfStream
int streamId ()
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/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 java.util.Set HTTP2_VERSIONS
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 ()
}
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/NettyChannelBuilder$NettyTransportFactory.classNettyChannelBuilder.java
package io.grpc.netty
public final io.grpc.netty.NettyChannelBuilder$NettyTransportFactory extends io.grpc.internal.AbstractReferenceCounted 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 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.ManagedClientTransport newClientTransport (java.net.SocketAddress, java.lang.String)
java.net.SocketAddress serverAddress
String authority
io.grpc.netty.ProtocolNegotiator negotiator
public io.grpc.internal.ManagedClientTransport newClientTransport (java.net.SocketAddress, java.lang.String, io.grpc.netty.ProtocolNegotiator)
java.net.SocketAddress serverAddress
String authority
io.grpc.netty.ProtocolNegotiator negotiator
protected void deallocate ()
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/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/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/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/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.Server {
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 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.grpc.internal.ServerListener access$600 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic java.util.logging.Logger access$700 ()
static synthetic boolean access$800 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic io.netty.channel.EventLoopGroup access$900 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic io.netty.channel.EventLoopGroup access$902 (io.grpc.netty.NettyServer, io.netty.channel.EventLoopGroup)
io.grpc.netty.NettyServer x0
io.netty.channel.EventLoopGroup x1
static synthetic boolean access$1000 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic io.netty.channel.EventLoopGroup access$1100 (io.grpc.netty.NettyServer)
io.grpc.netty.NettyServer x0
static synthetic io.netty.channel.EventLoopGroup access$1102 (io.grpc.netty.NettyServer, io.netty.channel.EventLoopGroup)
io.grpc.netty.NettyServer x0
io.netty.channel.EventLoopGroup x1
static void ()
}
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 forRegistryAndPort (io.grpc.HandlerRegistry, int)
io.grpc.HandlerRegistry registry
int port
public static io.grpc.netty.NettyServerBuilder forAddress (java.net.SocketAddress)
java.net.SocketAddress address
private void (int)
int port
private void (io.grpc.HandlerRegistry, int)
io.grpc.HandlerRegistry registry
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.Server buildTransportServer ()
public volatile synthetic io.grpc.ServerBuilder useTransportSecurity (java.io.File, java.io.File)
}
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/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 ()
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/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 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/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.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$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$000 (io.grpc.netty.ProtocolNegotiators$TlsNegotiator)
io.grpc.netty.ProtocolNegotiators$TlsNegotiator x0
static synthetic int access$100 (io.grpc.netty.ProtocolNegotiators$TlsNegotiator)
io.grpc.netty.ProtocolNegotiators$TlsNegotiator x0
static synthetic io.netty.handler.ssl.SslContext access$200 (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.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 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$300 (java.lang.String)
String x0
static void ()
}
io/grpc/netty/RequestMessagesCommand.classRequestMessagesCommand.java
package io.grpc.netty
io.grpc.netty.RequestMessagesCommand extends java.lang.Object {
private final int numMessages
private final io.grpc.internal.AbstractStream stream
public void (io.grpc.internal.AbstractStream, int)
io.grpc.internal.AbstractStream stream
int numMessages
void requestMessages ()
}
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.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
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.ManagedClientTransport {
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 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.net.SocketAddress address
Class channelType
io.netty.channel.EventLoopGroup group
io.grpc.netty.ProtocolNegotiator negotiator
int flowControlWindow
int maxMessageSize
int maxHeaderListSize
String authority
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.MethodDescriptor method
io.grpc.Metadata headers
public void 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 java.lang.String toString ()
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.netty.channel.Channel access$200 (io.grpc.netty.NettyClientTransport)
io.grpc.netty.NettyClientTransport x0
static synthetic io.grpc.netty.ClientTransportLifecycleManager access$300 (io.grpc.netty.NettyClientTransport)
io.grpc.netty.NettyClientTransport x0
}
META-INF/services/
META-INF/services/io.grpc.ManagedChannelProvider
META-INF/services/io.grpc.ServerProvider