META-INF/
META-INF/MANIFEST.MF
io/
io/grpc/
io/grpc/internal/
io/grpc/internal/package-info.classpackage-info.java
package io.grpc.internal
abstract io.grpc.internal.package-info extends java.lang.Object {
}
io/grpc/internal/InternalServer.classInternalServer.java
package io.grpc.internal
public abstract io.grpc.internal.InternalServer extends java.lang.Object {
public abstract void start (io.grpc.internal.ServerListener) throws java.io.IOException
public abstract void shutdown ()
public abstract int getPort ()
}
io/grpc/internal/ServerListener.classServerListener.java
package io.grpc.internal
public abstract io.grpc.internal.ServerListener extends java.lang.Object {
public abstract io.grpc.internal.ServerTransportListener transportCreated (io.grpc.internal.ServerTransport)
public abstract void serverShutdown ()
}
io/grpc/internal/ServerTransport.classServerTransport.java
package io.grpc.internal
public abstract io.grpc.internal.ServerTransport extends java.lang.Object {
public abstract void shutdown ()
public abstract void shutdownNow (io.grpc.Status)
}
io/grpc/internal/ConnectionClientTransport.classConnectionClientTransport.java
package io.grpc.internal
public abstract io.grpc.internal.ConnectionClientTransport extends java.lang.Object implements io.grpc.internal.ManagedClientTransport {
public abstract io.grpc.Attributes getAttrs ()
}
io/grpc/internal/ManagedClientTransport$Listener.classManagedClientTransport.java
package io.grpc.internal
public abstract io.grpc.internal.ManagedClientTransport$Listener extends java.lang.Object {
public abstract void transportShutdown (io.grpc.Status)
public abstract void transportTerminated ()
public abstract void transportReady ()
public abstract void transportInUse (boolean)
}
io/grpc/internal/ManagedClientTransport.classManagedClientTransport.java
package io.grpc.internal
public abstract io.grpc.internal.ManagedClientTransport extends java.lang.Object implements io.grpc.internal.ClientTransport io.grpc.internal.WithLogId {
public abstract java.lang.Runnable start (io.grpc.internal.ManagedClientTransport$Listener)
public abstract void shutdown ()
public abstract void shutdownNow (io.grpc.Status)
}
io/grpc/internal/ClientTransport$PingCallback.classClientTransport.java
package io.grpc.internal
public abstract io.grpc.internal.ClientTransport$PingCallback extends java.lang.Object {
public abstract void onSuccess (long)
public abstract void onFailure (java.lang.Throwable)
}
io/grpc/internal/ClientTransport.classClientTransport.java
package io.grpc.internal
public abstract io.grpc.internal.ClientTransport extends java.lang.Object {
public abstract io.grpc.internal.ClientStream newStream (io.grpc.MethodDescriptor, io.grpc.Metadata, io.grpc.CallOptions)
public abstract io.grpc.internal.ClientStream newStream (io.grpc.MethodDescriptor, io.grpc.Metadata)
public abstract void ping (io.grpc.internal.ClientTransport$PingCallback, java.util.concurrent.Executor)
}
io/grpc/internal/WithLogId.classWithLogId.java
package io.grpc.internal
public abstract io.grpc.internal.WithLogId extends java.lang.Object {
public abstract java.lang.String getLogId ()
}
io/grpc/internal/ServerTransportListener.classServerTransportListener.java
package io.grpc.internal
public abstract io.grpc.internal.ServerTransportListener extends java.lang.Object {
public abstract void streamCreated (io.grpc.internal.ServerStream, java.lang.String, io.grpc.Metadata)
public abstract void transportTerminated ()
}
io/grpc/internal/ClientStream.classClientStream.java
package io.grpc.internal
public abstract io.grpc.internal.ClientStream extends java.lang.Object implements io.grpc.internal.Stream {
public abstract void cancel (io.grpc.Status)
public abstract void halfClose ()
public abstract void setAuthority (java.lang.String)
public abstract void start (io.grpc.internal.ClientStreamListener)
}
io/grpc/internal/Stream.classStream.java
package io.grpc.internal
public abstract io.grpc.internal.Stream extends java.lang.Object {
public abstract void request (int)
public abstract void writeMessage (java.io.InputStream)
public abstract void flush ()
public abstract boolean isReady ()
public abstract void setCompressor (io.grpc.Compressor)
public abstract void setDecompressor (io.grpc.Decompressor)
public abstract void setMessageCompression (boolean)
}
io/grpc/internal/ServerStream.classServerStream.java
package io.grpc.internal
public abstract io.grpc.internal.ServerStream extends java.lang.Object implements io.grpc.internal.Stream {
public abstract void writeHeaders (io.grpc.Metadata)
public abstract void close (io.grpc.Status, io.grpc.Metadata)
public abstract void cancel (io.grpc.Status)
public abstract io.grpc.Attributes attributes ()
public abstract void setListener (io.grpc.internal.ServerStreamListener)
}
io/grpc/internal/ClientStreamListener.classClientStreamListener.java
package io.grpc.internal
public abstract io.grpc.internal.ClientStreamListener extends java.lang.Object implements io.grpc.internal.StreamListener {
public abstract void headersRead (io.grpc.Metadata)
public abstract void closed (io.grpc.Status, io.grpc.Metadata)
}
io/grpc/internal/StreamListener.classStreamListener.java
package io.grpc.internal
public abstract io.grpc.internal.StreamListener extends java.lang.Object {
public abstract void messageRead (java.io.InputStream)
public abstract void onReady ()
}
io/grpc/internal/ServerStreamListener.classServerStreamListener.java
package io.grpc.internal
public abstract io.grpc.internal.ServerStreamListener extends java.lang.Object implements io.grpc.internal.StreamListener {
public abstract void halfClosed ()
public abstract void closed (io.grpc.Status)
}
io/grpc/internal/AbstractManagedChannelImplBuilder$AuthorityOverridingTransportFactory.classAbstractManagedChannelImplBuilder.java
package io.grpc.internal
io.grpc.internal.AbstractManagedChannelImplBuilder$AuthorityOverridingTransportFactory extends java.lang.Object implements io.grpc.internal.ClientTransportFactory {
final io.grpc.internal.ClientTransportFactory factory
final String authorityOverride
void (io.grpc.internal.ClientTransportFactory, java.lang.String)
io.grpc.internal.ClientTransportFactory factory
String authorityOverride
public io.grpc.internal.ConnectionClientTransport newClientTransport (java.net.SocketAddress, java.lang.String, java.lang.String)
java.net.SocketAddress serverAddress
String authority
String userAgent
public void close ()
}
io/grpc/internal/AbstractManagedChannelImplBuilder$DirectAddressNameResolverFactory$1.classAbstractManagedChannelImplBuilder.java
package io.grpc.internal
io.grpc.internal.AbstractManagedChannelImplBuilder$DirectAddressNameResolverFactory$1 extends io.grpc.NameResolver {
final io.grpc.internal.AbstractManagedChannelImplBuilder$DirectAddressNameResolverFactory this$0
void (io.grpc.internal.AbstractManagedChannelImplBuilder$DirectAddressNameResolverFactory)
io.grpc.internal.AbstractManagedChannelImplBuilder$DirectAddressNameResolverFactory this$0
public java.lang.String getServiceAuthority ()
public void start (io.grpc.NameResolver$Listener)
io.grpc.NameResolver$Listener listener
public void shutdown ()
}
io/grpc/internal/AbstractManagedChannelImplBuilder$DirectAddressNameResolverFactory.classAbstractManagedChannelImplBuilder.java
package io.grpc.internal
io.grpc.internal.AbstractManagedChannelImplBuilder$DirectAddressNameResolverFactory extends io.grpc.NameResolver$Factory {
final java.net.SocketAddress address
final String authority
void (java.net.SocketAddress, java.lang.String)
java.net.SocketAddress address
String authority
public io.grpc.NameResolver newNameResolver (java.net.URI, io.grpc.Attributes)
java.net.URI notUsedUri
io.grpc.Attributes params
public java.lang.String getDefaultScheme ()
}
io/grpc/internal/AbstractManagedChannelImplBuilder.classAbstractManagedChannelImplBuilder.java
package io.grpc.internal
public abstract io.grpc.internal.AbstractManagedChannelImplBuilder extends io.grpc.ManagedChannelBuilder {
private static final String DIRECT_ADDRESS_SCHEME
static final long IDLE_MODE_MAX_TIMEOUT_DAYS
static final long IDLE_MODE_MIN_TIMEOUT_MILLIS
private java.util.concurrent.Executor executor
private final java.util.List interceptors
private final String target
private final java.net.SocketAddress directServerAddress
private String userAgent
private String authorityOverride
private io.grpc.NameResolver$Factory nameResolverFactory
private io.grpc.LoadBalancer$Factory loadBalancerFactory
private io.grpc.DecompressorRegistry decompressorRegistry
private io.grpc.CompressorRegistry compressorRegistry
private long idleTimeoutMillis
protected void (java.lang.String)
String target
static java.lang.String makeTargetStringForDirectAddress (java.net.SocketAddress)
java.net.URISyntaxException e
java.net.SocketAddress address
protected void (java.net.SocketAddress, java.lang.String)
java.net.SocketAddress directServerAddress
String authority
public final io.grpc.internal.AbstractManagedChannelImplBuilder directExecutor ()
public final io.grpc.internal.AbstractManagedChannelImplBuilder executor (java.util.concurrent.Executor)
java.util.concurrent.Executor executor
public final io.grpc.internal.AbstractManagedChannelImplBuilder intercept (java.util.List)
java.util.List interceptors
public final transient io.grpc.internal.AbstractManagedChannelImplBuilder intercept (io.grpc.ClientInterceptor[])
io.grpc.ClientInterceptor[] interceptors
public final io.grpc.internal.AbstractManagedChannelImplBuilder nameResolverFactory (io.grpc.NameResolver$Factory)
io.grpc.NameResolver$Factory resolverFactory
public final io.grpc.internal.AbstractManagedChannelImplBuilder loadBalancerFactory (io.grpc.LoadBalancer$Factory)
io.grpc.LoadBalancer$Factory loadBalancerFactory
public final io.grpc.internal.AbstractManagedChannelImplBuilder decompressorRegistry (io.grpc.DecompressorRegistry)
io.grpc.DecompressorRegistry registry
public final io.grpc.internal.AbstractManagedChannelImplBuilder compressorRegistry (io.grpc.CompressorRegistry)
io.grpc.CompressorRegistry registry
private io.grpc.internal.AbstractManagedChannelImplBuilder thisT ()
io.grpc.internal.AbstractManagedChannelImplBuilder thisT
public final io.grpc.internal.AbstractManagedChannelImplBuilder userAgent (java.lang.String)
String userAgent
public final io.grpc.internal.AbstractManagedChannelImplBuilder overrideAuthority (java.lang.String)
String authority
public final io.grpc.internal.AbstractManagedChannelImplBuilder idleTimeout (long, java.util.concurrent.TimeUnit)
long value
java.util.concurrent.TimeUnit unit
final long getIdleTimeoutMillis ()
protected java.lang.String checkAuthority (java.lang.String)
String authority
public io.grpc.internal.ManagedChannelImpl build ()
io.grpc.internal.ClientTransportFactory transportFactory
io.grpc.NameResolver$Factory nameResolverFactory
protected abstract io.grpc.internal.ClientTransportFactory buildTransportFactory ()
protected io.grpc.Attributes getNameResolverParams ()
public volatile io.grpc.ManagedChannel build ()
public volatile io.grpc.ManagedChannelBuilder idleTimeout (long, java.util.concurrent.TimeUnit)
public volatile io.grpc.ManagedChannelBuilder compressorRegistry (io.grpc.CompressorRegistry)
public volatile io.grpc.ManagedChannelBuilder decompressorRegistry (io.grpc.DecompressorRegistry)
public volatile io.grpc.ManagedChannelBuilder loadBalancerFactory (io.grpc.LoadBalancer$Factory)
public volatile io.grpc.ManagedChannelBuilder nameResolverFactory (io.grpc.NameResolver$Factory)
public volatile io.grpc.ManagedChannelBuilder overrideAuthority (java.lang.String)
public volatile io.grpc.ManagedChannelBuilder userAgent (java.lang.String)
public volatile io.grpc.ManagedChannelBuilder intercept (io.grpc.ClientInterceptor[])
public volatile io.grpc.ManagedChannelBuilder intercept (java.util.List)
public volatile io.grpc.ManagedChannelBuilder executor (java.util.concurrent.Executor)
public volatile io.grpc.ManagedChannelBuilder directExecutor ()
static void ()
}
io/grpc/internal/ClientTransportFactory.classClientTransportFactory.java
package io.grpc.internal
public abstract io.grpc.internal.ClientTransportFactory extends java.lang.Object implements java.io.Closeable {
public abstract io.grpc.internal.ConnectionClientTransport newClientTransport (java.net.SocketAddress, java.lang.String, java.lang.String)
public abstract void close ()
}
io/grpc/internal/SharedResourceHolder$1.classSharedResourceHolder.java
package io.grpc.internal
final io.grpc.internal.SharedResourceHolder$1 extends java.lang.Object implements io.grpc.internal.SharedResourceHolder$ScheduledExecutorFactory {
void ()
public java.util.concurrent.ScheduledExecutorService createScheduledExecutor ()
}
io/grpc/internal/SharedResourceHolder$2.classSharedResourceHolder.java
package io.grpc.internal
io.grpc.internal.SharedResourceHolder$2 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.SharedResourceHolder$Instance val$cached
final io.grpc.internal.SharedResourceHolder$Resource val$resource
final Object val$instance
final io.grpc.internal.SharedResourceHolder this$0
void (io.grpc.internal.SharedResourceHolder, io.grpc.internal.SharedResourceHolder$Instance, io.grpc.internal.SharedResourceHolder$Resource, java.lang.Object)
io.grpc.internal.SharedResourceHolder this$0
public void run ()
}
io/grpc/internal/SharedResourceHolder$Resource.classSharedResourceHolder.java
package io.grpc.internal
public abstract io.grpc.internal.SharedResourceHolder$Resource extends java.lang.Object {
public abstract java.lang.Object create ()
public abstract void close (java.lang.Object)
}
io/grpc/internal/SharedResourceHolder$ScheduledExecutorFactory.classSharedResourceHolder.java
package io.grpc.internal
abstract io.grpc.internal.SharedResourceHolder$ScheduledExecutorFactory extends java.lang.Object {
public abstract java.util.concurrent.ScheduledExecutorService createScheduledExecutor ()
}
io/grpc/internal/SharedResourceHolder$Instance.classSharedResourceHolder.java
package io.grpc.internal
io.grpc.internal.SharedResourceHolder$Instance extends java.lang.Object {
final Object payload
int refcount
java.util.concurrent.ScheduledFuture destroyTask
void (java.lang.Object)
Object payload
}
io/grpc/internal/SharedResourceHolder.classSharedResourceHolder.java
package io.grpc.internal
public final io.grpc.internal.SharedResourceHolder extends java.lang.Object {
static final long DESTROY_DELAY_SECONDS
private static final io.grpc.internal.SharedResourceHolder holder
private final java.util.IdentityHashMap instances
private final io.grpc.internal.SharedResourceHolder$ScheduledExecutorFactory destroyerFactory
private java.util.concurrent.ScheduledExecutorService destroyer
void (io.grpc.internal.SharedResourceHolder$ScheduledExecutorFactory)
io.grpc.internal.SharedResourceHolder$ScheduledExecutorFactory destroyerFactory
public static java.lang.Object get (io.grpc.internal.SharedResourceHolder$Resource)
io.grpc.internal.SharedResourceHolder$Resource resource
public static java.lang.Object release (io.grpc.internal.SharedResourceHolder$Resource, java.lang.Object)
io.grpc.internal.SharedResourceHolder$Resource resource
Object instance
synchronized java.lang.Object getInternal (io.grpc.internal.SharedResourceHolder$Resource)
io.grpc.internal.SharedResourceHolder$Resource resource
io.grpc.internal.SharedResourceHolder$Instance instance
synchronized java.lang.Object releaseInternal (io.grpc.internal.SharedResourceHolder$Resource, java.lang.Object)
io.grpc.internal.SharedResourceHolder$Resource resource
Object instance
io.grpc.internal.SharedResourceHolder$Instance cached
static java.util.IdentityHashMap access$000 (io.grpc.internal.SharedResourceHolder)
io.grpc.internal.SharedResourceHolder x0
static java.util.concurrent.ScheduledExecutorService access$100 (io.grpc.internal.SharedResourceHolder)
io.grpc.internal.SharedResourceHolder x0
static java.util.concurrent.ScheduledExecutorService access$102 (io.grpc.internal.SharedResourceHolder, java.util.concurrent.ScheduledExecutorService)
io.grpc.internal.SharedResourceHolder x0
java.util.concurrent.ScheduledExecutorService x1
static void ()
}
io/grpc/internal/GrpcUtil$Http2Error.classGrpcUtil.java
package io.grpc.internal
public final io.grpc.internal.GrpcUtil$Http2Error extends java.lang.Enum {
public static final io.grpc.internal.GrpcUtil$Http2Error NO_ERROR
public static final io.grpc.internal.GrpcUtil$Http2Error PROTOCOL_ERROR
public static final io.grpc.internal.GrpcUtil$Http2Error INTERNAL_ERROR
public static final io.grpc.internal.GrpcUtil$Http2Error FLOW_CONTROL_ERROR
public static final io.grpc.internal.GrpcUtil$Http2Error SETTINGS_TIMEOUT
public static final io.grpc.internal.GrpcUtil$Http2Error STREAM_CLOSED
public static final io.grpc.internal.GrpcUtil$Http2Error FRAME_SIZE_ERROR
public static final io.grpc.internal.GrpcUtil$Http2Error REFUSED_STREAM
public static final io.grpc.internal.GrpcUtil$Http2Error CANCEL
public static final io.grpc.internal.GrpcUtil$Http2Error COMPRESSION_ERROR
public static final io.grpc.internal.GrpcUtil$Http2Error CONNECT_ERROR
public static final io.grpc.internal.GrpcUtil$Http2Error ENHANCE_YOUR_CALM
public static final io.grpc.internal.GrpcUtil$Http2Error INADEQUATE_SECURITY
public static final io.grpc.internal.GrpcUtil$Http2Error HTTP_1_1_REQUIRED
private static final io.grpc.internal.GrpcUtil$Http2Error[] codeMap
private final int code
private final io.grpc.Status status
private static final io.grpc.internal.GrpcUtil$Http2Error[] $VALUES
public static io.grpc.internal.GrpcUtil$Http2Error[] values ()
public static io.grpc.internal.GrpcUtil$Http2Error valueOf (java.lang.String)
String name
private static io.grpc.internal.GrpcUtil$Http2Error[] buildHttp2CodeMap ()
int index
io.grpc.internal.GrpcUtil$Http2Error error
io.grpc.internal.GrpcUtil$Http2Error[] errors
int size
io.grpc.internal.GrpcUtil$Http2Error[] http2CodeMap
private void (java.lang.String, int, int, io.grpc.Status)
int code
io.grpc.Status status
public long code ()
public io.grpc.Status status ()
public static io.grpc.internal.GrpcUtil$Http2Error forCode (long)
long code
public static io.grpc.Status statusForCode (long)
io.grpc.Status$Code statusCode
long code
io.grpc.internal.GrpcUtil$Http2Error error
static void ()
}
io/grpc/internal/GrpcUtil$1.classGrpcUtil.java
package io.grpc.internal
final io.grpc.internal.GrpcUtil$1 extends java.lang.Object implements io.grpc.internal.SharedResourceHolder$Resource {
private static final String name
void ()
public java.util.concurrent.ExecutorService create ()
public void close (java.util.concurrent.ExecutorService)
java.util.concurrent.ExecutorService instance
public java.lang.String toString ()
public volatile void close (java.lang.Object)
public volatile java.lang.Object create ()
}
io/grpc/internal/GrpcUtil$2.classGrpcUtil.java
package io.grpc.internal
final io.grpc.internal.GrpcUtil$2 extends java.lang.Object implements io.grpc.internal.SharedResourceHolder$Resource {
void ()
public java.util.concurrent.ScheduledExecutorService create ()
java.lang.reflect.Method method
RuntimeException e
Exception e
java.util.concurrent.ScheduledExecutorService service
public void close (java.util.concurrent.ScheduledExecutorService)
java.util.concurrent.ScheduledExecutorService instance
public volatile void close (java.lang.Object)
public volatile java.lang.Object create ()
}
io/grpc/internal/GrpcUtil$3.classGrpcUtil.java
package io.grpc.internal
final io.grpc.internal.GrpcUtil$3 extends java.lang.Object implements com.google.common.base.Supplier {
void ()
public com.google.common.base.Stopwatch get ()
public volatile java.lang.Object get ()
}
io/grpc/internal/GrpcUtil$TimeoutMarshaller.classGrpcUtil.java
package io.grpc.internal
io.grpc.internal.GrpcUtil$TimeoutMarshaller extends java.lang.Object implements io.grpc.Metadata$AsciiMarshaller {
private static final com.google.common.collect.ImmutableMap UNITS
void ()
public java.lang.String toAsciiString (java.lang.Long)
long timeout
java.util.Map$Entry unit
Long timeoutNanos
int cutoff
public java.lang.Long parseAsciiString (java.lang.String)
String serialized
String valuePart
char unit
java.util.concurrent.TimeUnit timeUnit
public volatile java.lang.Object parseAsciiString (java.lang.String)
public volatile java.lang.String toAsciiString (java.lang.Object)
static void ()
}
io/grpc/internal/GrpcUtil.classGrpcUtil.java
package io.grpc.internal
public final io.grpc.internal.GrpcUtil extends java.lang.Object {
public static final boolean IS_RESTRICTED_APPENGINE
public static final io.grpc.Metadata$Key TIMEOUT_KEY
public static final io.grpc.Metadata$Key MESSAGE_ENCODING_KEY
public static final io.grpc.Metadata$Key MESSAGE_ACCEPT_ENCODING_KEY
public static final io.grpc.Metadata$Key CONTENT_TYPE_KEY
public static final io.grpc.Metadata$Key USER_AGENT_KEY
public static final int DEFAULT_PORT_PLAINTEXT
public static final int DEFAULT_PORT_SSL
public static final String CONTENT_TYPE_GRPC
public static final String HTTP_METHOD
public static final String TE_TRAILERS
public static final String TIMEOUT
public static final String MESSAGE_ENCODING
public static final String MESSAGE_ACCEPT_ENCODING
public static final int DEFAULT_MAX_MESSAGE_SIZE
public static final int DEFAULT_MAX_HEADER_LIST_SIZE
public static final com.google.common.base.Splitter ACCEPT_ENCODING_SPLITER
private static final String IMPLEMENTATION_VERION
public static final long DEFAULT_KEEPALIVE_DELAY_NANOS
public static final long DEFAULT_KEEPALIVE_TIMEOUT_NANOS
public static final io.grpc.internal.SharedResourceHolder$Resource SHARED_CHANNEL_EXECUTOR
public static final io.grpc.internal.SharedResourceHolder$Resource TIMER_SERVICE
static final com.google.common.base.Supplier STOPWATCH_SUPPLIER
public static io.grpc.Status httpStatusToGrpcStatus (int)
int httpStatusCode
public static boolean isGrpcContentType (java.lang.String)
String contentType
char nextChar
public static java.lang.String getGrpcUserAgent (java.lang.String, java.lang.String)
String transportName
String applicationUserAgent
StringBuilder builder
public static java.net.URI authorityToUri (java.lang.String)
java.net.URISyntaxException ex
String authority
java.net.URI uri
java.net.URI uri
public static java.lang.String checkAuthority (java.lang.String)
String authority
java.net.URI uri
public static java.lang.String authorityFromHostAndPort (java.lang.String, int)
java.net.URISyntaxException ex
String host
int port
public static java.util.concurrent.ThreadFactory getThreadFactory (java.lang.String, boolean)
String nameFormat
boolean daemon
java.util.concurrent.ThreadFactory threadFactory
public static java.lang.String getLogId (io.grpc.internal.WithLogId)
io.grpc.internal.WithLogId subject
private void ()
private static java.lang.String getImplementationVersion ()
String version
static void ()
}
io/grpc/internal/ClientCallImpl$ClientTransportProvider.classClientCallImpl.java
package io.grpc.internal
abstract io.grpc.internal.ClientCallImpl$ClientTransportProvider extends java.lang.Object {
public abstract io.grpc.internal.ClientTransport get (io.grpc.CallOptions)
}
io/grpc/internal/ClientCallImpl$1ClosedByContext.classClientCallImpl.java
package io.grpc.internal
io.grpc.internal.ClientCallImpl$1ClosedByContext extends io.grpc.internal.ContextRunnable {
final io.grpc.ClientCall$Listener val$observer
final io.grpc.internal.ClientCallImpl this$0
void (io.grpc.internal.ClientCallImpl, io.grpc.ClientCall$Listener)
io.grpc.internal.ClientCallImpl this$0
public void runInContext ()
}
io/grpc/internal/ClientCallImpl$1ClosedByNotFoundCompressor.classClientCallImpl.java
package io.grpc.internal
io.grpc.internal.ClientCallImpl$1ClosedByNotFoundCompressor extends io.grpc.internal.ContextRunnable {
final io.grpc.ClientCall$Listener val$observer
final String val$compressorName
final io.grpc.internal.ClientCallImpl this$0
void (io.grpc.internal.ClientCallImpl, io.grpc.ClientCall$Listener, java.lang.String)
io.grpc.internal.ClientCallImpl this$0
public void runInContext ()
}
io/grpc/internal/ClientCallImpl$DeadlineTimer.classClientCallImpl.java
package io.grpc.internal
io.grpc.internal.ClientCallImpl$DeadlineTimer extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.ClientCallImpl this$0
private void (io.grpc.internal.ClientCallImpl)
public void run ()
void (io.grpc.internal.ClientCallImpl, io.grpc.internal.ClientCallImpl$1)
io.grpc.internal.ClientCallImpl x0
io.grpc.internal.ClientCallImpl$1 x1
}
io/grpc/internal/ClientCallImpl$ClientStreamListenerImpl$1HeadersRead.classClientCallImpl.java
package io.grpc.internal
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1HeadersRead extends io.grpc.internal.ContextRunnable {
final io.grpc.Metadata val$headers
final io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl this$1
void (io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl, io.grpc.Metadata)
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl this$1
public final void runInContext ()
io.grpc.Status status
Throwable t
}
io/grpc/internal/ClientCallImpl$ClientStreamListenerImpl$1MessageRead.classClientCallImpl.java
package io.grpc.internal
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1MessageRead extends io.grpc.internal.ContextRunnable {
final java.io.InputStream val$message
final io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl this$1
void (io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl, java.io.InputStream)
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl this$1
public final void runInContext ()
io.grpc.Status status
Throwable t
}
io/grpc/internal/ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.classClientCallImpl.java
package io.grpc.internal
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed extends io.grpc.internal.ContextRunnable {
final io.grpc.Status val$savedStatus
final io.grpc.Metadata val$savedTrailers
final io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl this$1
void (io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl, io.grpc.Status, io.grpc.Metadata)
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl this$1
public final void runInContext ()
}
io/grpc/internal/ClientCallImpl$ClientStreamListenerImpl$1StreamOnReady.classClientCallImpl.java
package io.grpc.internal
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamOnReady extends io.grpc.internal.ContextRunnable {
final io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl this$1
void (io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl)
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl this$1
public final void runInContext ()
io.grpc.Status status
Throwable t
}
io/grpc/internal/ClientCallImpl$ClientStreamListenerImpl.classClientCallImpl.java
package io.grpc.internal
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl extends java.lang.Object implements io.grpc.internal.ClientStreamListener {
private final io.grpc.ClientCall$Listener observer
private boolean closed
final io.grpc.internal.ClientCallImpl this$0
public void (io.grpc.internal.ClientCallImpl, io.grpc.ClientCall$Listener)
io.grpc.ClientCall$Listener observer
public void headersRead (io.grpc.Metadata)
String encoding
io.grpc.Metadata headers
io.grpc.Decompressor decompressor
public void messageRead (java.io.InputStream)
java.io.InputStream message
private void close (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
public void closed (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
io.grpc.Deadline deadline
io.grpc.Status savedStatus
io.grpc.Metadata savedTrailers
public void onReady ()
static boolean access$400 (io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl)
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl x0
static io.grpc.ClientCall$Listener access$500 (io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl)
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl x0
static void access$600 (io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl, io.grpc.Status, io.grpc.Metadata)
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl x0
io.grpc.Status x1
io.grpc.Metadata x2
}
io/grpc/internal/ClientCallImpl$1.classClientCallImpl.java
package io.grpc.internal
io.grpc.internal.ClientCallImpl$1 extends java.lang.Object {
}
io/grpc/internal/ClientCallImpl.classClientCallImpl.java
package io.grpc.internal
final io.grpc.internal.ClientCallImpl extends io.grpc.ClientCall implements io.grpc.Context$CancellationListener {
private static final java.util.logging.Logger log
private final io.grpc.MethodDescriptor method
private final java.util.concurrent.Executor callExecutor
private final io.grpc.Context context
private volatile java.util.concurrent.ScheduledFuture deadlineCancellationFuture
private final boolean unaryRequest
private final io.grpc.CallOptions callOptions
private io.grpc.internal.ClientStream stream
private volatile boolean cancelListenersShouldBeRemoved
private boolean cancelCalled
private boolean halfCloseCalled
private final io.grpc.internal.ClientCallImpl$ClientTransportProvider clientTransportProvider
private java.util.concurrent.ScheduledExecutorService deadlineCancellationExecutor
private io.grpc.DecompressorRegistry decompressorRegistry
private io.grpc.CompressorRegistry compressorRegistry
void (io.grpc.MethodDescriptor, java.util.concurrent.Executor, io.grpc.CallOptions, io.grpc.internal.ClientCallImpl$ClientTransportProvider, java.util.concurrent.ScheduledExecutorService)
io.grpc.MethodDescriptor method
java.util.concurrent.Executor executor
io.grpc.CallOptions callOptions
io.grpc.internal.ClientCallImpl$ClientTransportProvider clientTransportProvider
java.util.concurrent.ScheduledExecutorService deadlineCancellationExecutor
public void cancelled (io.grpc.Context)
io.grpc.Context context
io.grpc.internal.ClientCallImpl setDecompressorRegistry (io.grpc.DecompressorRegistry)
io.grpc.DecompressorRegistry decompressorRegistry
io.grpc.internal.ClientCallImpl setCompressorRegistry (io.grpc.CompressorRegistry)
io.grpc.CompressorRegistry compressorRegistry
static void prepareHeaders (io.grpc.Metadata, io.grpc.DecompressorRegistry, io.grpc.Compressor)
io.grpc.Metadata headers
io.grpc.DecompressorRegistry decompressorRegistry
io.grpc.Compressor compressor
String advertisedEncodings
public void start (io.grpc.ClientCall$Listener, io.grpc.Metadata)
io.grpc.internal.ClientTransport transport
io.grpc.ClientCall$Listener observer
io.grpc.Metadata headers
String compressorName
io.grpc.Compressor compressor
io.grpc.Deadline effectiveDeadline
boolean deadlineExceeded
private static void updateTimeoutHeaders (io.grpc.Deadline, io.grpc.Deadline, io.grpc.Deadline, io.grpc.Metadata)
io.grpc.Deadline effectiveDeadline
io.grpc.Deadline callDeadline
io.grpc.Deadline outerCallDeadline
io.grpc.Metadata headers
long effectiveTimeout
private static void logIfContextNarrowedTimeout (long, io.grpc.Deadline, io.grpc.Deadline, io.grpc.Deadline)
long callTimeout
long effectiveTimeout
io.grpc.Deadline effectiveDeadline
io.grpc.Deadline outerCallDeadline
io.grpc.Deadline callDeadline
StringBuilder builder
private void removeContextListenerAndCancelDeadlineFuture ()
java.util.concurrent.ScheduledFuture f
private java.util.concurrent.ScheduledFuture startDeadlineTimer (io.grpc.Deadline)
io.grpc.Deadline deadline
private io.grpc.Deadline effectiveDeadline ()
private static io.grpc.Deadline min (io.grpc.Deadline, io.grpc.Deadline)
io.grpc.Deadline deadline0
io.grpc.Deadline deadline1
public void request (int)
int numMessages
public void cancel (java.lang.String, java.lang.Throwable)
io.grpc.Status status
String message
Throwable cause
public void halfClose ()
public void sendMessage (java.lang.Object)
java.io.InputStream messageIs
Throwable e
Object message
public void setMessageCompression (boolean)
boolean enabled
public boolean isReady ()
static io.grpc.Context access$000 (io.grpc.internal.ClientCallImpl)
io.grpc.internal.ClientCallImpl x0
static io.grpc.internal.ClientStream access$100 (io.grpc.internal.ClientCallImpl)
io.grpc.internal.ClientCallImpl x0
static io.grpc.DecompressorRegistry access$300 (io.grpc.internal.ClientCallImpl)
io.grpc.internal.ClientCallImpl x0
static java.util.concurrent.Executor access$700 (io.grpc.internal.ClientCallImpl)
io.grpc.internal.ClientCallImpl x0
static io.grpc.MethodDescriptor access$800 (io.grpc.internal.ClientCallImpl)
io.grpc.internal.ClientCallImpl x0
static boolean access$902 (io.grpc.internal.ClientCallImpl, boolean)
io.grpc.internal.ClientCallImpl x0
boolean x1
static void access$1000 (io.grpc.internal.ClientCallImpl)
io.grpc.internal.ClientCallImpl x0
static io.grpc.Deadline access$1100 (io.grpc.internal.ClientCallImpl)
io.grpc.internal.ClientCallImpl x0
static void ()
}
io/grpc/internal/ManagedChannelImpl$1.classManagedChannelImpl.java
package io.grpc.internal
io.grpc.internal.ManagedChannelImpl$1 extends io.grpc.internal.InUseStateAggregator {
final io.grpc.internal.ManagedChannelImpl this$0
void (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl this$0
java.lang.Object getLock ()
java.lang.Runnable handleInUse ()
void handleNotInUse ()
}
io/grpc/internal/ManagedChannelImpl$IdleModeTimer.classManagedChannelImpl.java
package io.grpc.internal
io.grpc.internal.ManagedChannelImpl$IdleModeTimer extends java.lang.Object implements java.lang.Runnable {
boolean cancelled
final io.grpc.internal.ManagedChannelImpl this$0
private void (io.grpc.internal.ManagedChannelImpl)
public void run ()
io.grpc.internal.TransportSet ts
java.util.ArrayList transportsCopy
io.grpc.LoadBalancer savedBalancer
io.grpc.NameResolver oldResolver
void (io.grpc.internal.ManagedChannelImpl, io.grpc.internal.ManagedChannelImpl$1)
io.grpc.internal.ManagedChannelImpl x0
io.grpc.internal.ManagedChannelImpl$1 x1
}
io/grpc/internal/ManagedChannelImpl$1NameResolverStartTask.classManagedChannelImpl.java
package io.grpc.internal
io.grpc.internal.ManagedChannelImpl$1NameResolverStartTask extends java.lang.Object implements java.lang.Runnable {
final io.grpc.NameResolver val$resolver
final io.grpc.LoadBalancer val$balancer
final io.grpc.internal.ManagedChannelImpl this$0
void (io.grpc.internal.ManagedChannelImpl, io.grpc.NameResolver, io.grpc.LoadBalancer)
io.grpc.internal.ManagedChannelImpl this$0
public void run ()
}
io/grpc/internal/ManagedChannelImpl$2.classManagedChannelImpl.java
package io.grpc.internal
io.grpc.internal.ManagedChannelImpl$2 extends java.lang.Object implements io.grpc.internal.ClientCallImpl$ClientTransportProvider {
final io.grpc.internal.ManagedChannelImpl this$0
void (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl this$0
public io.grpc.internal.ClientTransport get (io.grpc.CallOptions)
io.grpc.CallOptions callOptions
io.grpc.LoadBalancer balancer
}
io/grpc/internal/ManagedChannelImpl$RealChannel.classManagedChannelImpl.java
package io.grpc.internal
io.grpc.internal.ManagedChannelImpl$RealChannel extends io.grpc.Channel {
final io.grpc.internal.ManagedChannelImpl this$0
private void (io.grpc.internal.ManagedChannelImpl)
public io.grpc.ClientCall newCall (io.grpc.MethodDescriptor, io.grpc.CallOptions)
io.grpc.MethodDescriptor method
io.grpc.CallOptions callOptions
java.util.concurrent.Executor executor
public java.lang.String authority ()
String authority
void (io.grpc.internal.ManagedChannelImpl, io.grpc.internal.ManagedChannelImpl$1)
io.grpc.internal.ManagedChannelImpl x0
io.grpc.internal.ManagedChannelImpl$1 x1
}
io/grpc/internal/ManagedChannelImpl$3$1.classManagedChannelImpl.java
package io.grpc.internal
io.grpc.internal.ManagedChannelImpl$3$1 extends io.grpc.internal.TransportSet$Callback {
static final boolean $assertionsDisabled
final io.grpc.EquivalentAddressGroup val$addressGroup
final io.grpc.internal.ManagedChannelImpl$3 this$1
void (io.grpc.internal.ManagedChannelImpl$3, io.grpc.EquivalentAddressGroup)
io.grpc.internal.ManagedChannelImpl$3 this$1
public void onTerminated (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet ts
public void onAllAddressesFailed ()
public void onConnectionClosedByServer (io.grpc.Status)
io.grpc.Status status
public java.lang.Runnable onInUse (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet ts
public void onNotInUse (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet ts
Runnable r
static void ()
}
io/grpc/internal/ManagedChannelImpl$3.classManagedChannelImpl.java
package io.grpc.internal
io.grpc.internal.ManagedChannelImpl$3 extends io.grpc.TransportManager {
final io.grpc.internal.ManagedChannelImpl this$0
void (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl this$0
public void updateRetainedTransports (java.util.Collection)
java.util.Collection addrs
public io.grpc.internal.ClientTransport getTransport (io.grpc.EquivalentAddressGroup)
io.grpc.EquivalentAddressGroup addressGroup
io.grpc.internal.TransportSet ts
public io.grpc.Channel makeChannel (io.grpc.internal.ClientTransport)
io.grpc.internal.ClientTransport transport
public io.grpc.internal.ClientTransport createFailingTransport (io.grpc.Status)
io.grpc.Status error
public io.grpc.TransportManager$InterimTransport createInterimTransport ()
public io.grpc.TransportManager$OobTransportProvider createOobTransportProvider (io.grpc.EquivalentAddressGroup, java.lang.String)
io.grpc.EquivalentAddressGroup addressGroup
String authority
public volatile io.grpc.Channel makeChannel (java.lang.Object)
public volatile java.lang.Object createFailingTransport (io.grpc.Status)
public volatile java.lang.Object getTransport (io.grpc.EquivalentAddressGroup)
}
io/grpc/internal/ManagedChannelImpl$NameResolverListenerImpl.classManagedChannelImpl.java
package io.grpc.internal
io.grpc.internal.ManagedChannelImpl$NameResolverListenerImpl extends java.lang.Object implements io.grpc.NameResolver$Listener {
final io.grpc.LoadBalancer balancer
final io.grpc.internal.ManagedChannelImpl this$0
void (io.grpc.internal.ManagedChannelImpl, io.grpc.LoadBalancer)
io.grpc.LoadBalancer balancer
public void onUpdate (java.util.List, io.grpc.Attributes)
Throwable e
java.util.List servers
io.grpc.Attributes config
public void onError (io.grpc.Status)
io.grpc.Status error
}
io/grpc/internal/ManagedChannelImpl$InterimTransportImpl$1.classManagedChannelImpl.java
package io.grpc.internal
io.grpc.internal.ManagedChannelImpl$InterimTransportImpl$1 extends java.lang.Object implements io.grpc.internal.ManagedClientTransport$Listener {
static final boolean $assertionsDisabled
final io.grpc.internal.ManagedChannelImpl val$this$0
final io.grpc.internal.ManagedChannelImpl$InterimTransportImpl this$1
void (io.grpc.internal.ManagedChannelImpl$InterimTransportImpl, io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl$InterimTransportImpl this$1
public void transportShutdown (io.grpc.Status)
io.grpc.Status status
public void transportTerminated ()
Runnable r
public void transportReady ()
public void transportInUse (boolean)
boolean inUse
Runnable r
static void ()
}
io/grpc/internal/ManagedChannelImpl$InterimTransportImpl.classManagedChannelImpl.java
package io.grpc.internal
io.grpc.internal.ManagedChannelImpl$InterimTransportImpl extends java.lang.Object implements io.grpc.TransportManager$InterimTransport {
private final io.grpc.internal.DelayedClientTransport delayedTransport
private boolean closed
final io.grpc.internal.ManagedChannelImpl this$0
void (io.grpc.internal.ManagedChannelImpl)
boolean savedShutdown
public io.grpc.internal.ClientTransport transport ()
public void closeWithRealTransports (com.google.common.base.Supplier)
com.google.common.base.Supplier realTransports
public void closeWithError (io.grpc.Status)
io.grpc.Status error
public volatile java.lang.Object transport ()
static io.grpc.internal.DelayedClientTransport access$2600 (io.grpc.internal.ManagedChannelImpl$InterimTransportImpl)
io.grpc.internal.ManagedChannelImpl$InterimTransportImpl x0
}
io/grpc/internal/ManagedChannelImpl$OobTransportProviderImpl$1.classManagedChannelImpl.java
package io.grpc.internal
io.grpc.internal.ManagedChannelImpl$OobTransportProviderImpl$1 extends io.grpc.internal.TransportSet$Callback {
final io.grpc.internal.ManagedChannelImpl val$this$0
final io.grpc.internal.ManagedChannelImpl$OobTransportProviderImpl this$1
void (io.grpc.internal.ManagedChannelImpl$OobTransportProviderImpl, io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl$OobTransportProviderImpl this$1
public void onTerminated (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet ts
}
io/grpc/internal/ManagedChannelImpl$OobTransportProviderImpl.classManagedChannelImpl.java
package io.grpc.internal
io.grpc.internal.ManagedChannelImpl$OobTransportProviderImpl extends java.lang.Object implements io.grpc.TransportManager$OobTransportProvider {
private final io.grpc.internal.TransportSet transportSet
private final io.grpc.internal.ClientTransport transport
final io.grpc.internal.ManagedChannelImpl this$0
void (io.grpc.internal.ManagedChannelImpl, io.grpc.EquivalentAddressGroup, java.lang.String)
io.grpc.EquivalentAddressGroup addressGroup
String authority
public io.grpc.internal.ClientTransport get ()
public void close ()
void shutdownNow (io.grpc.Status)
io.grpc.Status reason
public volatile java.lang.Object get ()
}
io/grpc/internal/ManagedChannelImpl.classManagedChannelImpl.java
package io.grpc.internal
public final io.grpc.internal.ManagedChannelImpl extends io.grpc.ManagedChannel implements io.grpc.internal.WithLogId {
private static final java.util.logging.Logger log
static final java.util.regex.Pattern URI_PATTERN
static final long IDLE_TIMEOUT_MILLIS_DISABLE
private static final io.grpc.internal.ClientTransport SHUTDOWN_TRANSPORT
static final io.grpc.internal.ClientTransport IDLE_MODE_TRANSPORT
private final String target
private final io.grpc.NameResolver$Factory nameResolverFactory
private final io.grpc.Attributes nameResolverParams
private final io.grpc.LoadBalancer$Factory loadBalancerFactory
private final io.grpc.internal.ClientTransportFactory transportFactory
private final java.util.concurrent.Executor executor
private final boolean usingSharedExecutor
private final Object lock
private final io.grpc.DecompressorRegistry decompressorRegistry
private final io.grpc.CompressorRegistry compressorRegistry
private final io.grpc.internal.SharedResourceHolder$Resource timerService
private final com.google.common.base.Supplier stopwatchSupplier
private final long idleTimeoutMillis
private java.util.concurrent.ScheduledExecutorService scheduledExecutor
private final io.grpc.internal.BackoffPolicy$Provider backoffPolicyProvider
private final io.grpc.Channel interceptorChannel
private final String userAgent
private io.grpc.NameResolver nameResolver
private io.grpc.LoadBalancer loadBalancer
private final java.util.Map transports
private final java.util.HashSet decommissionedTransports
private final java.util.HashSet delayedTransports
final io.grpc.internal.InUseStateAggregator inUseStateAggregator
private java.util.concurrent.ScheduledFuture idleModeTimerFuture
private io.grpc.internal.ManagedChannelImpl$IdleModeTimer idleModeTimer
private final java.util.HashSet oobTransports
private boolean shutdown
private boolean shutdownNowed
private boolean terminated
private final io.grpc.internal.ClientCallImpl$ClientTransportProvider transportProvider
final io.grpc.TransportManager tm
io.grpc.LoadBalancer exitIdleModeAndGetLb ()
Runnable runnable
io.grpc.LoadBalancer balancer
private java.lang.Runnable exitIdleMode ()
io.grpc.LoadBalancer balancer
io.grpc.NameResolver resolver
private void cancelIdleTimer ()
private void rescheduleIdleTimer ()
void (java.lang.String, io.grpc.internal.BackoffPolicy$Provider, io.grpc.NameResolver$Factory, io.grpc.Attributes, io.grpc.LoadBalancer$Factory, io.grpc.internal.ClientTransportFactory, io.grpc.DecompressorRegistry, io.grpc.CompressorRegistry, io.grpc.internal.SharedResourceHolder$Resource, com.google.common.base.Supplier, long, java.util.concurrent.Executor, java.lang.String, java.util.List)
String target
io.grpc.internal.BackoffPolicy$Provider backoffPolicyProvider
io.grpc.NameResolver$Factory nameResolverFactory
io.grpc.Attributes nameResolverParams
io.grpc.LoadBalancer$Factory loadBalancerFactory
io.grpc.internal.ClientTransportFactory transportFactory
io.grpc.DecompressorRegistry decompressorRegistry
io.grpc.CompressorRegistry compressorRegistry
io.grpc.internal.SharedResourceHolder$Resource timerService
com.google.common.base.Supplier stopwatchSupplier
long idleTimeoutMillis
java.util.concurrent.Executor executor
String userAgent
java.util.List interceptors
private static boolean serversAreEmpty (java.util.List)
java.util.List serverInfos
java.util.List servers
static io.grpc.NameResolver getNameResolver (java.lang.String, io.grpc.NameResolver$Factory, io.grpc.Attributes)
java.net.URISyntaxException e
io.grpc.NameResolver resolver
java.net.URISyntaxException e
io.grpc.NameResolver resolver
String target
io.grpc.NameResolver$Factory nameResolverFactory
io.grpc.Attributes nameResolverParams
java.net.URI targetUri
StringBuilder uriSyntaxErrors
public io.grpc.internal.ManagedChannelImpl shutdown ()
io.grpc.internal.TransportSet ts
io.grpc.internal.DelayedClientTransport transport
io.grpc.internal.ManagedChannelImpl$OobTransportProviderImpl provider
java.util.ArrayList transportsCopy
java.util.ArrayList delayedTransportsCopy
java.util.ArrayList oobTransportsCopy
io.grpc.LoadBalancer balancer
io.grpc.NameResolver resolver
public io.grpc.internal.ManagedChannelImpl shutdownNow ()
io.grpc.internal.TransportSet ts
io.grpc.internal.DelayedClientTransport transport
io.grpc.internal.ManagedChannelImpl$OobTransportProviderImpl provider
java.util.List transportsCopy
java.util.List delayedTransportsCopy
java.util.List oobTransportsCopy
io.grpc.Status nowStatus
public boolean isShutdown ()
public boolean awaitTermination (long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
long timeoutNanos
long endTimeNanos
long timeout
java.util.concurrent.TimeUnit unit
public boolean isTerminated ()
public io.grpc.ClientCall newCall (io.grpc.MethodDescriptor, io.grpc.CallOptions)
io.grpc.MethodDescriptor method
io.grpc.CallOptions callOptions
public java.lang.String authority ()
private void maybeTerminateChannel ()
public java.lang.String getLogId ()
public volatile io.grpc.ManagedChannel shutdownNow ()
public volatile io.grpc.ManagedChannel shutdown ()
static java.lang.Object access$000 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static java.lang.Runnable access$100 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static boolean access$200 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static void access$300 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static io.grpc.LoadBalancer access$400 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static io.grpc.LoadBalancer access$402 (io.grpc.internal.ManagedChannelImpl, io.grpc.LoadBalancer)
io.grpc.internal.ManagedChannelImpl x0
io.grpc.LoadBalancer x1
static io.grpc.NameResolver access$500 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static io.grpc.NameResolver access$502 (io.grpc.internal.ManagedChannelImpl, io.grpc.NameResolver)
io.grpc.internal.ManagedChannelImpl x0
io.grpc.NameResolver x1
static java.lang.String access$600 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static io.grpc.NameResolver$Factory access$700 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static io.grpc.Attributes access$800 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static java.util.Map access$900 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static java.util.HashSet access$1000 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static io.grpc.internal.ClientTransport access$1200 ()
static java.util.concurrent.Executor access$1400 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static io.grpc.CompressorRegistry access$1500 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static io.grpc.DecompressorRegistry access$1600 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static io.grpc.internal.ClientCallImpl$ClientTransportProvider access$1700 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static java.util.concurrent.ScheduledExecutorService access$1800 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static java.lang.String access$1900 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static io.grpc.internal.BackoffPolicy$Provider access$2000 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static io.grpc.internal.ClientTransportFactory access$2100 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static com.google.common.base.Supplier access$2200 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static void access$2300 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static java.util.logging.Logger access$2400 ()
static boolean access$2500 (java.util.List)
java.util.List x0
static java.util.HashSet access$2700 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static java.util.HashSet access$2800 (io.grpc.internal.ManagedChannelImpl)
io.grpc.internal.ManagedChannelImpl x0
static void ()
}
io/grpc/internal/BackoffPolicy$Provider.classBackoffPolicy.java
package io.grpc.internal
public abstract io.grpc.internal.BackoffPolicy$Provider extends java.lang.Object {
public abstract io.grpc.internal.BackoffPolicy get ()
}
io/grpc/internal/BackoffPolicy.classBackoffPolicy.java
package io.grpc.internal
abstract io.grpc.internal.BackoffPolicy extends java.lang.Object {
public abstract long nextBackoffMillis ()
}
io/grpc/internal/TransportSet$1.classTransportSet.java
package io.grpc.internal
io.grpc.internal.TransportSet$1 extends io.grpc.internal.InUseStateAggregator {
final io.grpc.internal.TransportSet this$0
void (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet this$0
java.lang.Object getLock ()
java.lang.Runnable handleInUse ()
void handleNotInUse ()
}
io/grpc/internal/TransportSet$1EndOfCurrentBackoff$1.classTransportSet.java
package io.grpc.internal
io.grpc.internal.TransportSet$1EndOfCurrentBackoff$1 extends java.lang.Object implements com.google.common.base.Supplier {
final io.grpc.internal.TransportSet$1EndOfCurrentBackoff this$1
void (io.grpc.internal.TransportSet$1EndOfCurrentBackoff)
io.grpc.internal.TransportSet$1EndOfCurrentBackoff this$1
public io.grpc.internal.ClientTransport get ()
public volatile java.lang.Object get ()
}
io/grpc/internal/TransportSet$1EndOfCurrentBackoff.classTransportSet.java
package io.grpc.internal
io.grpc.internal.TransportSet$1EndOfCurrentBackoff extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.DelayedClientTransport val$delayedTransport
final io.grpc.internal.TransportSet this$0
void (io.grpc.internal.TransportSet, io.grpc.internal.DelayedClientTransport)
io.grpc.internal.TransportSet this$0
public void run ()
boolean shutdownDelayedTransport
Runnable runnable
boolean hasPendingStreams
Throwable t
}
io/grpc/internal/TransportSet$BaseTransportListener.classTransportSet.java
package io.grpc.internal
io.grpc.internal.TransportSet$BaseTransportListener extends java.lang.Object implements io.grpc.internal.ManagedClientTransport$Listener {
protected final io.grpc.internal.ManagedClientTransport transport
static final boolean $assertionsDisabled
final io.grpc.internal.TransportSet this$0
public void (io.grpc.internal.TransportSet, io.grpc.internal.ManagedClientTransport)
io.grpc.internal.ManagedClientTransport transport
public void transportReady ()
public void transportInUse (boolean)
boolean inUse
Runnable r
public void transportShutdown (io.grpc.Status)
io.grpc.Status status
public void transportTerminated ()
boolean runCallback
Runnable r
static void ()
}
io/grpc/internal/TransportSet$TransportListener.classTransportSet.java
package io.grpc.internal
io.grpc.internal.TransportSet$TransportListener extends io.grpc.internal.TransportSet$BaseTransportListener {
private final java.net.SocketAddress address
private final io.grpc.internal.DelayedClientTransport delayedTransport
final io.grpc.internal.TransportSet this$0
public void (io.grpc.internal.TransportSet, io.grpc.internal.ManagedClientTransport, io.grpc.internal.DelayedClientTransport, java.net.SocketAddress)
io.grpc.internal.ManagedClientTransport transport
io.grpc.internal.DelayedClientTransport delayedTransport
java.net.SocketAddress address
public void transportReady ()
boolean savedShutdown
public void transportShutdown (io.grpc.Status)
io.grpc.Status s
boolean allAddressesFailed
boolean closedByServer
Runnable runnable
public void transportTerminated ()
}
io/grpc/internal/TransportSet$Callback.classTransportSet.java
package io.grpc.internal
abstract io.grpc.internal.TransportSet$Callback extends java.lang.Object {
void ()
public void onTerminated (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet ts
public void onAllAddressesFailed ()
public void onConnectionClosedByServer (io.grpc.Status)
io.grpc.Status status
public java.lang.Runnable onInUse (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet ts
public void onNotInUse (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet ts
}
io/grpc/internal/TransportSet.classTransportSet.java
package io.grpc.internal
final io.grpc.internal.TransportSet extends java.lang.Object implements io.grpc.internal.WithLogId {
private static final java.util.logging.Logger log
private static final io.grpc.internal.ClientTransport SHUTDOWN_TRANSPORT
private final Object lock
private final io.grpc.EquivalentAddressGroup addressGroup
private final String authority
private final String userAgent
private final io.grpc.internal.BackoffPolicy$Provider backoffPolicyProvider
private final io.grpc.internal.TransportSet$Callback callback
private final io.grpc.internal.ClientTransportFactory transportFactory
private final java.util.concurrent.ScheduledExecutorService scheduledExecutor
private final java.util.concurrent.Executor appExecutor
private int nextAddressIndex
private io.grpc.internal.BackoffPolicy reconnectPolicy
private final com.google.common.base.Stopwatch connectingTimer
private java.util.concurrent.ScheduledFuture reconnectTask
private final java.util.Collection transports
private final io.grpc.internal.InUseStateAggregator inUseStateAggregator
private io.grpc.internal.ConnectionClientTransport pendingTransport
private final io.grpc.LoadBalancer loadBalancer
private boolean shutdown
private volatile io.grpc.internal.ManagedClientTransport activeTransport
void (io.grpc.EquivalentAddressGroup, java.lang.String, java.lang.String, io.grpc.LoadBalancer, io.grpc.internal.BackoffPolicy$Provider, io.grpc.internal.ClientTransportFactory, java.util.concurrent.ScheduledExecutorService, com.google.common.base.Supplier, java.util.concurrent.Executor, io.grpc.internal.TransportSet$Callback)
io.grpc.EquivalentAddressGroup addressGroup
String authority
String userAgent
io.grpc.LoadBalancer loadBalancer
io.grpc.internal.BackoffPolicy$Provider backoffPolicyProvider
io.grpc.internal.ClientTransportFactory transportFactory
java.util.concurrent.ScheduledExecutorService scheduledExecutor
com.google.common.base.Supplier stopwatchSupplier
java.util.concurrent.Executor appExecutor
io.grpc.internal.TransportSet$Callback callback
final io.grpc.internal.ClientTransport obtainActiveTransport ()
io.grpc.internal.DelayedClientTransport delayedTransport
io.grpc.internal.ClientTransport savedTransport
Runnable runnable
private java.lang.Runnable startNewTransport (io.grpc.internal.DelayedClientTransport)
io.grpc.internal.DelayedClientTransport delayedTransport
java.util.List addrs
java.net.SocketAddress address
io.grpc.internal.ConnectionClientTransport transport
private void scheduleBackoff (io.grpc.internal.DelayedClientTransport, io.grpc.Status)
long delayMillis
io.grpc.internal.DelayedClientTransport delayedTransport
io.grpc.Status status
final void shutdown ()
io.grpc.internal.ManagedClientTransport savedActiveTransport
io.grpc.internal.ConnectionClientTransport savedPendingTransport
boolean runCallback
void shutdownNow (io.grpc.Status)
io.grpc.internal.ManagedClientTransport transport
io.grpc.Status reason
java.util.Collection transportsCopy
private void cancelReconnectTask ()
public java.lang.String getLogId ()
static java.lang.Object access$000 (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet x0
static io.grpc.internal.TransportSet$Callback access$100 (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet x0
static java.util.concurrent.ScheduledFuture access$202 (io.grpc.internal.TransportSet, java.util.concurrent.ScheduledFuture)
io.grpc.internal.TransportSet x0
java.util.concurrent.ScheduledFuture x1
static java.lang.Runnable access$300 (io.grpc.internal.TransportSet, io.grpc.internal.DelayedClientTransport)
io.grpc.internal.TransportSet x0
io.grpc.internal.DelayedClientTransport x1
static io.grpc.internal.ManagedClientTransport access$402 (io.grpc.internal.TransportSet, io.grpc.internal.ManagedClientTransport)
io.grpc.internal.TransportSet x0
io.grpc.internal.ManagedClientTransport x1
static java.util.logging.Logger access$500 ()
static io.grpc.internal.InUseStateAggregator access$600 (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet x0
static java.util.Collection access$700 (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet x0
static boolean access$800 (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet x0
static void access$900 (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet x0
static io.grpc.internal.BackoffPolicy access$1002 (io.grpc.internal.TransportSet, io.grpc.internal.BackoffPolicy)
io.grpc.internal.TransportSet x0
io.grpc.internal.BackoffPolicy x1
static int access$1102 (io.grpc.internal.TransportSet, int)
io.grpc.internal.TransportSet x0
int x1
static io.grpc.internal.ManagedClientTransport access$400 (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet x0
static io.grpc.internal.ConnectionClientTransport access$1200 (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet x0
static io.grpc.internal.ConnectionClientTransport access$1202 (io.grpc.internal.TransportSet, io.grpc.internal.ConnectionClientTransport)
io.grpc.internal.TransportSet x0
io.grpc.internal.ConnectionClientTransport x1
static io.grpc.EquivalentAddressGroup access$1300 (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet x0
static io.grpc.LoadBalancer access$1400 (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet x0
static int access$1100 (io.grpc.internal.TransportSet)
io.grpc.internal.TransportSet x0
static void access$1500 (io.grpc.internal.TransportSet, io.grpc.internal.DelayedClientTransport, io.grpc.Status)
io.grpc.internal.TransportSet x0
io.grpc.internal.DelayedClientTransport x1
io.grpc.Status x2
static void ()
}
io/grpc/internal/DelayedClientTransport$1.classDelayedClientTransport.java
package io.grpc.internal
io.grpc.internal.DelayedClientTransport$1 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.ClientTransport$PingCallback val$callback
final io.grpc.internal.DelayedClientTransport this$0
void (io.grpc.internal.DelayedClientTransport, io.grpc.internal.ClientTransport$PingCallback)
io.grpc.internal.DelayedClientTransport this$0
public void run ()
}
io/grpc/internal/DelayedClientTransport$2.classDelayedClientTransport.java
package io.grpc.internal
io.grpc.internal.DelayedClientTransport$2 extends java.lang.Object implements java.lang.Runnable {
final java.util.Collection val$savedPendingStreams
final com.google.common.base.Supplier val$supplier
final io.grpc.internal.DelayedClientTransport this$0
void (io.grpc.internal.DelayedClientTransport, java.util.Collection, com.google.common.base.Supplier)
io.grpc.internal.DelayedClientTransport this$0
public void run ()
io.grpc.internal.DelayedClientTransport$PendingStream stream
}
io/grpc/internal/DelayedClientTransport$1FailTheFailFastPendingStreams.classDelayedClientTransport.java
package io.grpc.internal
io.grpc.internal.DelayedClientTransport$1FailTheFailFastPendingStreams extends java.lang.Object implements java.lang.Runnable {
final java.util.ArrayList val$failFastPendingStreams
final io.grpc.Status val$status
final io.grpc.internal.DelayedClientTransport this$0
void (io.grpc.internal.DelayedClientTransport, java.util.ArrayList, io.grpc.Status)
io.grpc.internal.DelayedClientTransport this$0
public void run ()
io.grpc.internal.DelayedClientTransport$PendingStream stream
}
io/grpc/internal/DelayedClientTransport$PendingStream.classDelayedClientTransport.java
package io.grpc.internal
io.grpc.internal.DelayedClientTransport$PendingStream extends io.grpc.internal.DelayedStream {
private final io.grpc.MethodDescriptor method
private final io.grpc.Metadata headers
private final io.grpc.CallOptions callOptions
final io.grpc.internal.DelayedClientTransport this$0
private void (io.grpc.internal.DelayedClientTransport, io.grpc.MethodDescriptor, io.grpc.Metadata, io.grpc.CallOptions)
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
io.grpc.CallOptions callOptions
private void createRealStream (io.grpc.internal.ClientTransport)
io.grpc.internal.ClientTransport transport
public void cancel (io.grpc.Status)
boolean justRemovedAnElement
io.grpc.Status reason
void (io.grpc.internal.DelayedClientTransport, io.grpc.MethodDescriptor, io.grpc.Metadata, io.grpc.CallOptions, io.grpc.internal.DelayedClientTransport$1)
io.grpc.internal.DelayedClientTransport x0
io.grpc.MethodDescriptor x1
io.grpc.Metadata x2
io.grpc.CallOptions x3
io.grpc.internal.DelayedClientTransport$1 x4
static void access$100 (io.grpc.internal.DelayedClientTransport$PendingStream, io.grpc.internal.ClientTransport)
io.grpc.internal.DelayedClientTransport$PendingStream x0
io.grpc.internal.ClientTransport x1
static io.grpc.CallOptions access$400 (io.grpc.internal.DelayedClientTransport$PendingStream)
io.grpc.internal.DelayedClientTransport$PendingStream x0
}
io/grpc/internal/DelayedClientTransport$PendingPing$1.classDelayedClientTransport.java
package io.grpc.internal
io.grpc.internal.DelayedClientTransport$PendingPing$1 extends java.lang.Object implements java.lang.Runnable {
final UnsupportedOperationException val$ex
final io.grpc.internal.DelayedClientTransport$PendingPing this$0
void (io.grpc.internal.DelayedClientTransport$PendingPing, java.lang.UnsupportedOperationException)
io.grpc.internal.DelayedClientTransport$PendingPing this$0
public void run ()
}
io/grpc/internal/DelayedClientTransport$PendingPing.classDelayedClientTransport.java
package io.grpc.internal
io.grpc.internal.DelayedClientTransport$PendingPing extends java.lang.Object {
private final io.grpc.internal.ClientTransport$PingCallback callback
private final java.util.concurrent.Executor executor
public void (io.grpc.internal.ClientTransport$PingCallback, java.util.concurrent.Executor)
io.grpc.internal.ClientTransport$PingCallback callback
java.util.concurrent.Executor executor
public void createRealPing (io.grpc.internal.ClientTransport)
UnsupportedOperationException ex
io.grpc.internal.ClientTransport transport
static io.grpc.internal.ClientTransport$PingCallback access$700 (io.grpc.internal.DelayedClientTransport$PendingPing)
io.grpc.internal.DelayedClientTransport$PendingPing x0
}
io/grpc/internal/DelayedClientTransport.classDelayedClientTransport.java
package io.grpc.internal
io.grpc.internal.DelayedClientTransport extends java.lang.Object implements io.grpc.internal.ManagedClientTransport {
private final Object lock
private final java.util.concurrent.Executor streamCreationExecutor
private io.grpc.internal.ManagedClientTransport$Listener listener
private volatile com.google.common.base.Supplier transportSupplier
private java.util.Collection pendingStreams
private java.util.Collection pendingPings
private boolean shutdown
private io.grpc.Status backoffStatus
void (java.util.concurrent.Executor)
java.util.concurrent.Executor streamCreationExecutor
public java.lang.Runnable start (io.grpc.internal.ManagedClientTransport$Listener)
io.grpc.internal.ManagedClientTransport$Listener listener
public io.grpc.internal.ClientStream newStream (io.grpc.MethodDescriptor, io.grpc.Metadata, io.grpc.CallOptions)
io.grpc.internal.DelayedClientTransport$PendingStream pendingStream
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
io.grpc.CallOptions callOptions
com.google.common.base.Supplier supplier
public io.grpc.internal.ClientStream newStream (io.grpc.MethodDescriptor, io.grpc.Metadata)
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
public void ping (io.grpc.internal.ClientTransport$PingCallback, java.util.concurrent.Executor)
io.grpc.internal.DelayedClientTransport$PendingPing pendingPing
io.grpc.internal.ClientTransport$PingCallback callback
java.util.concurrent.Executor executor
com.google.common.base.Supplier supplier
public void shutdown ()
public void shutdownNow (io.grpc.Status)
io.grpc.internal.DelayedClientTransport$PendingStream stream
io.grpc.Status status
java.util.Collection savedPendingStreams
public void setTransport (io.grpc.internal.ClientTransport)
io.grpc.internal.ClientTransport transport
public void setTransportSupplier (com.google.common.base.Supplier)
io.grpc.internal.DelayedClientTransport$PendingPing ping
java.util.Collection savedPendingStreams
com.google.common.base.Supplier supplier
public boolean hasPendingStreams ()
int getPendingStreamsCount ()
boolean isInBackoffPeriod ()
void startBackoff (io.grpc.Status)
io.grpc.internal.DelayedClientTransport$PendingStream stream
java.util.Iterator it
java.util.ArrayList failFastPendingStreams
io.grpc.Status status
void endBackoff ()
public java.lang.String getLogId ()
com.google.common.base.Supplier getTransportSupplier ()
static java.lang.Object access$200 (io.grpc.internal.DelayedClientTransport)
io.grpc.internal.DelayedClientTransport x0
static io.grpc.internal.ManagedClientTransport$Listener access$300 (io.grpc.internal.DelayedClientTransport)
io.grpc.internal.DelayedClientTransport x0
static java.util.Collection access$500 (io.grpc.internal.DelayedClientTransport)
io.grpc.internal.DelayedClientTransport x0
static boolean access$600 (io.grpc.internal.DelayedClientTransport)
io.grpc.internal.DelayedClientTransport x0
static java.util.Collection access$502 (io.grpc.internal.DelayedClientTransport, java.util.Collection)
io.grpc.internal.DelayedClientTransport x0
java.util.Collection x1
}
io/grpc/internal/InUseStateAggregator.classInUseStateAggregator.java
package io.grpc.internal
abstract io.grpc.internal.InUseStateAggregator extends java.lang.Object {
private final java.util.HashSet inUseObjects
void ()
final java.lang.Runnable updateObjectInUse (java.lang.Object, boolean)
boolean removed
int origSize
Object object
boolean inUse
Runnable runnable
final boolean isInUse ()
abstract java.lang.Object getLock ()
abstract java.lang.Runnable handleInUse ()
abstract void handleNotInUse ()
}
io/grpc/internal/DelayedStream$1.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$1 extends java.lang.Object implements java.lang.Runnable {
final String val$authority
final io.grpc.internal.DelayedStream this$0
void (io.grpc.internal.DelayedStream, java.lang.String)
io.grpc.internal.DelayedStream this$0
public void run ()
}
io/grpc/internal/DelayedStream$2.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$2 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.ClientStreamListener val$finalListener
final io.grpc.internal.DelayedStream this$0
void (io.grpc.internal.DelayedStream, io.grpc.internal.ClientStreamListener)
io.grpc.internal.DelayedStream this$0
public void run ()
}
io/grpc/internal/DelayedStream$3.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$3 extends java.lang.Object implements java.lang.Runnable {
final java.io.InputStream val$message
final io.grpc.internal.DelayedStream this$0
void (io.grpc.internal.DelayedStream, java.io.InputStream)
io.grpc.internal.DelayedStream this$0
public void run ()
}
io/grpc/internal/DelayedStream$4.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$4 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.DelayedStream this$0
void (io.grpc.internal.DelayedStream)
io.grpc.internal.DelayedStream this$0
public void run ()
}
io/grpc/internal/DelayedStream$5.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$5 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.Status val$reason
final io.grpc.internal.DelayedStream this$0
void (io.grpc.internal.DelayedStream, io.grpc.Status)
io.grpc.internal.DelayedStream this$0
public void run ()
}
io/grpc/internal/DelayedStream$6.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$6 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.DelayedStream this$0
void (io.grpc.internal.DelayedStream)
io.grpc.internal.DelayedStream this$0
public void run ()
}
io/grpc/internal/DelayedStream$7.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$7 extends java.lang.Object implements java.lang.Runnable {
final int val$numMessages
final io.grpc.internal.DelayedStream this$0
void (io.grpc.internal.DelayedStream, int)
io.grpc.internal.DelayedStream this$0
public void run ()
}
io/grpc/internal/DelayedStream$8.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$8 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.Compressor val$compressor
final io.grpc.internal.DelayedStream this$0
void (io.grpc.internal.DelayedStream, io.grpc.Compressor)
io.grpc.internal.DelayedStream this$0
public void run ()
}
io/grpc/internal/DelayedStream$9.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$9 extends java.lang.Object implements java.lang.Runnable {
final boolean val$enable
final io.grpc.internal.DelayedStream this$0
void (io.grpc.internal.DelayedStream, boolean)
io.grpc.internal.DelayedStream this$0
public void run ()
}
io/grpc/internal/DelayedStream$DelayedStreamListener$1.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$DelayedStreamListener$1 extends java.lang.Object implements java.lang.Runnable {
final java.io.InputStream val$message
final io.grpc.internal.DelayedStream$DelayedStreamListener this$0
void (io.grpc.internal.DelayedStream$DelayedStreamListener, java.io.InputStream)
io.grpc.internal.DelayedStream$DelayedStreamListener this$0
public void run ()
}
io/grpc/internal/DelayedStream$DelayedStreamListener$2.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$DelayedStreamListener$2 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.DelayedStream$DelayedStreamListener this$0
void (io.grpc.internal.DelayedStream$DelayedStreamListener)
io.grpc.internal.DelayedStream$DelayedStreamListener this$0
public void run ()
}
io/grpc/internal/DelayedStream$DelayedStreamListener$3.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$DelayedStreamListener$3 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.Metadata val$headers
final io.grpc.internal.DelayedStream$DelayedStreamListener this$0
void (io.grpc.internal.DelayedStream$DelayedStreamListener, io.grpc.Metadata)
io.grpc.internal.DelayedStream$DelayedStreamListener this$0
public void run ()
}
io/grpc/internal/DelayedStream$DelayedStreamListener$4.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$DelayedStreamListener$4 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.Status val$status
final io.grpc.Metadata val$trailers
final io.grpc.internal.DelayedStream$DelayedStreamListener this$0
void (io.grpc.internal.DelayedStream$DelayedStreamListener, io.grpc.Status, io.grpc.Metadata)
io.grpc.internal.DelayedStream$DelayedStreamListener this$0
public void run ()
}
io/grpc/internal/DelayedStream$DelayedStreamListener.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream$DelayedStreamListener extends java.lang.Object implements io.grpc.internal.ClientStreamListener {
private final io.grpc.internal.ClientStreamListener realListener
private volatile boolean passThrough
private java.util.List pendingCallbacks
static final boolean $assertionsDisabled
public void (io.grpc.internal.ClientStreamListener)
io.grpc.internal.ClientStreamListener listener
private void delayOrExecute (java.lang.Runnable)
Runnable runnable
public void messageRead (java.io.InputStream)
java.io.InputStream message
public void onReady ()
public void headersRead (io.grpc.Metadata)
io.grpc.Metadata headers
public void closed (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
public void drainPendingCallbacks ()
java.util.List tmp
Runnable runnable
java.util.List toRun
static io.grpc.internal.ClientStreamListener access$100 (io.grpc.internal.DelayedStream$DelayedStreamListener)
io.grpc.internal.DelayedStream$DelayedStreamListener x0
static void ()
}
io/grpc/internal/DelayedStream.classDelayedStream.java
package io.grpc.internal
io.grpc.internal.DelayedStream extends java.lang.Object implements io.grpc.internal.ClientStream {
private volatile boolean passThrough
private io.grpc.internal.ClientStreamListener listener
private io.grpc.internal.ClientStream realStream
private io.grpc.Status error
private java.util.List pendingCalls
private io.grpc.internal.DelayedStream$DelayedStreamListener delayedListener
static final boolean $assertionsDisabled
void ()
final void setStream (io.grpc.internal.ClientStream)
io.grpc.internal.ClientStream stream
private void drainPendingCalls ()
java.util.List tmp
Runnable runnable
java.util.List toRun
io.grpc.internal.DelayedStream$DelayedStreamListener delayedListener
private void delayOrExecute (java.lang.Runnable)
Runnable runnable
public void setAuthority (java.lang.String)
String authority
public void start (io.grpc.internal.ClientStreamListener)
io.grpc.internal.ClientStreamListener finalListener
io.grpc.internal.ClientStreamListener listener
io.grpc.Status savedError
boolean savedPassThrough
public void writeMessage (java.io.InputStream)
java.io.InputStream message
public void flush ()
public void cancel (io.grpc.Status)
io.grpc.Status reason
boolean delegateToRealStream
io.grpc.internal.ClientStreamListener listenerToClose
public void halfClose ()
public void request (int)
int numMessages
public void setCompressor (io.grpc.Compressor)
io.grpc.Compressor compressor
public void setDecompressor (io.grpc.Decompressor)
io.grpc.Decompressor decompressor
public boolean isReady ()
public void setMessageCompression (boolean)
boolean enable
io.grpc.internal.ClientStream getRealStream ()
static io.grpc.internal.ClientStream access$000 (io.grpc.internal.DelayedStream)
io.grpc.internal.DelayedStream x0
static void ()
}
io/grpc/internal/AbstractServerImplBuilder$1.classAbstractServerImplBuilder.java
package io.grpc.internal
final io.grpc.internal.AbstractServerImplBuilder$1 extends io.grpc.HandlerRegistry {
void ()
public io.grpc.ServerMethodDefinition lookupMethod (java.lang.String, java.lang.String)
String methodName
String authority
}
io/grpc/internal/AbstractServerImplBuilder.classAbstractServerImplBuilder.java
package io.grpc.internal
public abstract io.grpc.internal.AbstractServerImplBuilder extends io.grpc.ServerBuilder {
private static final io.grpc.HandlerRegistry EMPTY_FALLBACK_REGISTRY
private final io.grpc.internal.InternalHandlerRegistry$Builder registryBuilder
private io.grpc.HandlerRegistry fallbackRegistry
private java.util.concurrent.Executor executor
private io.grpc.DecompressorRegistry decompressorRegistry
private io.grpc.CompressorRegistry compressorRegistry
public void ()
public final io.grpc.internal.AbstractServerImplBuilder directExecutor ()
public final io.grpc.internal.AbstractServerImplBuilder executor (java.util.concurrent.Executor)
java.util.concurrent.Executor executor
public final io.grpc.internal.AbstractServerImplBuilder addService (io.grpc.ServerServiceDefinition)
io.grpc.ServerServiceDefinition service
public final io.grpc.internal.AbstractServerImplBuilder addService (io.grpc.BindableService)
io.grpc.BindableService bindableService
public final io.grpc.internal.AbstractServerImplBuilder fallbackHandlerRegistry (io.grpc.HandlerRegistry)
io.grpc.HandlerRegistry registry
public final io.grpc.internal.AbstractServerImplBuilder decompressorRegistry (io.grpc.DecompressorRegistry)
io.grpc.DecompressorRegistry registry
public final io.grpc.internal.AbstractServerImplBuilder compressorRegistry (io.grpc.CompressorRegistry)
io.grpc.CompressorRegistry registry
public io.grpc.internal.ServerImpl build ()
io.grpc.internal.InternalServer transportServer
protected abstract io.grpc.internal.InternalServer buildTransportServer ()
private io.grpc.internal.AbstractServerImplBuilder thisT ()
io.grpc.internal.AbstractServerImplBuilder thisT
public volatile io.grpc.Server build ()
public volatile io.grpc.ServerBuilder compressorRegistry (io.grpc.CompressorRegistry)
public volatile io.grpc.ServerBuilder decompressorRegistry (io.grpc.DecompressorRegistry)
public volatile io.grpc.ServerBuilder fallbackHandlerRegistry (io.grpc.HandlerRegistry)
public volatile io.grpc.ServerBuilder addService (io.grpc.BindableService)
public volatile io.grpc.ServerBuilder addService (io.grpc.ServerServiceDefinition)
public volatile io.grpc.ServerBuilder executor (java.util.concurrent.Executor)
public volatile io.grpc.ServerBuilder directExecutor ()
static void ()
}
io/grpc/internal/InternalHandlerRegistry$Builder.classInternalHandlerRegistry.java
package io.grpc.internal
io.grpc.internal.InternalHandlerRegistry$Builder extends java.lang.Object {
private final java.util.HashMap services
void ()
io.grpc.internal.InternalHandlerRegistry$Builder addService (io.grpc.ServerServiceDefinition)
io.grpc.ServerServiceDefinition service
io.grpc.internal.InternalHandlerRegistry build ()
io.grpc.ServerMethodDefinition method
io.grpc.ServerServiceDefinition service
com.google.common.collect.ImmutableMap$Builder mapBuilder
}
io/grpc/internal/InternalHandlerRegistry$1.classInternalHandlerRegistry.java
package io.grpc.internal
io.grpc.internal.InternalHandlerRegistry$1 extends java.lang.Object {
}
io/grpc/internal/InternalHandlerRegistry.classInternalHandlerRegistry.java
package io.grpc.internal
final io.grpc.internal.InternalHandlerRegistry extends java.lang.Object {
private final com.google.common.collect.ImmutableMap methods
private void (com.google.common.collect.ImmutableMap)
com.google.common.collect.ImmutableMap methods
io.grpc.ServerMethodDefinition lookupMethod (java.lang.String)
String methodName
void (com.google.common.collect.ImmutableMap, io.grpc.internal.InternalHandlerRegistry$1)
com.google.common.collect.ImmutableMap x0
io.grpc.internal.InternalHandlerRegistry$1 x1
}
io/grpc/internal/ServerImpl$ServerListenerImpl.classServerImpl.java
package io.grpc.internal
io.grpc.internal.ServerImpl$ServerListenerImpl extends java.lang.Object implements io.grpc.internal.ServerListener {
final io.grpc.internal.ServerImpl this$0
private void (io.grpc.internal.ServerImpl)
public io.grpc.internal.ServerTransportListener transportCreated (io.grpc.internal.ServerTransport)
io.grpc.internal.ServerTransport transport
public void serverShutdown ()
io.grpc.internal.ServerTransport transport
java.util.ArrayList copiedTransports
io.grpc.Status shutdownNowStatusCopy
void (io.grpc.internal.ServerImpl, io.grpc.internal.ServerImpl$1)
io.grpc.internal.ServerImpl x0
io.grpc.internal.ServerImpl$1 x1
}
io/grpc/internal/ServerImpl$ServerTransportListenerImpl$1.classServerImpl.java
package io.grpc.internal
io.grpc.internal.ServerImpl$ServerTransportListenerImpl$1 extends io.grpc.internal.ContextRunnable {
final String val$methodName
final io.grpc.internal.ServerStream val$stream
final io.grpc.Context$CancellableContext val$context
final io.grpc.Metadata val$headers
final io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener val$jumpListener
final io.grpc.internal.ServerImpl$ServerTransportListenerImpl this$1
void (io.grpc.internal.ServerImpl$ServerTransportListenerImpl, io.grpc.Context, java.lang.String, io.grpc.internal.ServerStream, io.grpc.Context$CancellableContext, io.grpc.Metadata, io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener)
io.grpc.internal.ServerImpl$ServerTransportListenerImpl this$1
io.grpc.Context context
public void runInContext ()
io.grpc.ServerMethodDefinition method
RuntimeException e
Error e
io.grpc.internal.ServerStreamListener listener
}
io/grpc/internal/ServerImpl$ServerTransportListenerImpl$2.classServerImpl.java
package io.grpc.internal
io.grpc.internal.ServerImpl$ServerTransportListenerImpl$2 extends java.lang.Object implements io.grpc.Context$CancellationListener {
final io.grpc.internal.ServerStream val$stream
final io.grpc.internal.ServerImpl$ServerTransportListenerImpl this$1
void (io.grpc.internal.ServerImpl$ServerTransportListenerImpl, io.grpc.internal.ServerStream)
io.grpc.internal.ServerImpl$ServerTransportListenerImpl this$1
public void cancelled (io.grpc.Context)
io.grpc.Context context
io.grpc.Status status
}
io/grpc/internal/ServerImpl$ServerTransportListenerImpl.classServerImpl.java
package io.grpc.internal
io.grpc.internal.ServerImpl$ServerTransportListenerImpl extends java.lang.Object implements io.grpc.internal.ServerTransportListener {
private final io.grpc.internal.ServerTransport transport
final io.grpc.internal.ServerImpl this$0
public void (io.grpc.internal.ServerImpl, io.grpc.internal.ServerTransport)
io.grpc.internal.ServerTransport transport
public void transportTerminated ()
public void streamCreated (io.grpc.internal.ServerStream, java.lang.String, io.grpc.Metadata)
java.util.concurrent.Executor wrappedExecutor
io.grpc.internal.ServerStream stream
String methodName
io.grpc.Metadata headers
io.grpc.Context$CancellableContext context
java.util.concurrent.Executor wrappedExecutor
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener jumpListener
private io.grpc.Context$CancellableContext createContext (io.grpc.internal.ServerStream, io.grpc.Metadata)
io.grpc.internal.ServerStream stream
io.grpc.Metadata headers
Long timeoutNanos
io.grpc.Context$CancellableContext context
private io.grpc.internal.ServerStreamListener startCall (io.grpc.internal.ServerStream, java.lang.String, io.grpc.ServerMethodDefinition, io.grpc.Metadata, io.grpc.Context$CancellableContext)
io.grpc.internal.ServerStream stream
String fullMethodName
io.grpc.ServerMethodDefinition methodDef
io.grpc.Metadata headers
io.grpc.Context$CancellableContext context
io.grpc.internal.ServerCallImpl call
io.grpc.ServerCall$Listener listener
static io.grpc.internal.ServerStreamListener access$1300 (io.grpc.internal.ServerImpl$ServerTransportListenerImpl, io.grpc.internal.ServerStream, java.lang.String, io.grpc.ServerMethodDefinition, io.grpc.Metadata, io.grpc.Context$CancellableContext)
io.grpc.internal.ServerImpl$ServerTransportListenerImpl x0
io.grpc.internal.ServerStream x1
String x2
io.grpc.ServerMethodDefinition x3
io.grpc.Metadata x4
io.grpc.Context$CancellableContext x5
}
io/grpc/internal/ServerImpl$NoopListener.classServerImpl.java
package io.grpc.internal
io.grpc.internal.ServerImpl$NoopListener extends java.lang.Object implements io.grpc.internal.ServerStreamListener {
private void ()
public void messageRead (java.io.InputStream)
java.io.IOException e
java.io.InputStream value
public void halfClosed ()
public void closed (io.grpc.Status)
io.grpc.Status status
public void onReady ()
void (io.grpc.internal.ServerImpl$1)
io.grpc.internal.ServerImpl$1 x0
}
io/grpc/internal/ServerImpl$JumpToApplicationThreadServerStreamListener$1.classServerImpl.java
package io.grpc.internal
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1 extends io.grpc.internal.ContextRunnable {
final java.io.InputStream val$message
final io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener this$0
void (io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener, io.grpc.Context, java.io.InputStream)
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener this$0
io.grpc.Context context
public void runInContext ()
RuntimeException e
Error e
}
io/grpc/internal/ServerImpl$JumpToApplicationThreadServerStreamListener$2.classServerImpl.java
package io.grpc.internal
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$2 extends io.grpc.internal.ContextRunnable {
final io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener this$0
void (io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener, io.grpc.Context)
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener this$0
io.grpc.Context context
public void runInContext ()
RuntimeException e
Error e
}
io/grpc/internal/ServerImpl$JumpToApplicationThreadServerStreamListener$3.classServerImpl.java
package io.grpc.internal
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$3 extends io.grpc.internal.ContextRunnable {
final io.grpc.Status val$status
final io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener this$0
void (io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener, io.grpc.Context, io.grpc.Status)
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener this$0
io.grpc.Context context
public void runInContext ()
}
io/grpc/internal/ServerImpl$JumpToApplicationThreadServerStreamListener$4.classServerImpl.java
package io.grpc.internal
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$4 extends io.grpc.internal.ContextRunnable {
final io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener this$0
void (io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener, io.grpc.Context)
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener this$0
io.grpc.Context context
public void runInContext ()
}
io/grpc/internal/ServerImpl$JumpToApplicationThreadServerStreamListener.classServerImpl.java
package io.grpc.internal
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener extends java.lang.Object implements io.grpc.internal.ServerStreamListener {
private final java.util.concurrent.Executor callExecutor
private final io.grpc.Context$CancellableContext context
private final io.grpc.internal.ServerStream stream
private io.grpc.internal.ServerStreamListener listener
public void (java.util.concurrent.Executor, io.grpc.internal.ServerStream, io.grpc.Context$CancellableContext)
java.util.concurrent.Executor executor
io.grpc.internal.ServerStream stream
io.grpc.Context$CancellableContext context
private io.grpc.internal.ServerStreamListener getListener ()
private void setListener (io.grpc.internal.ServerStreamListener)
io.grpc.internal.ServerStreamListener listener
private void internalClose (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
public void messageRead (java.io.InputStream)
java.io.InputStream message
public void halfClosed ()
public void closed (io.grpc.Status)
io.grpc.Status status
public void onReady ()
static void access$1400 (io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener, io.grpc.internal.ServerStreamListener)
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener x0
io.grpc.internal.ServerStreamListener x1
static io.grpc.internal.ServerStreamListener access$1900 (io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener)
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener x0
static void access$2000 (io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener, io.grpc.Status, io.grpc.Metadata)
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener x0
io.grpc.Status x1
io.grpc.Metadata x2
static io.grpc.Context$CancellableContext access$2100 (io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener)
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener x0
}
io/grpc/internal/ServerImpl$1.classServerImpl.java
package io.grpc.internal
io.grpc.internal.ServerImpl$1 extends java.lang.Object {
}
io/grpc/internal/ServerImpl.classServerImpl.java
package io.grpc.internal
public final io.grpc.internal.ServerImpl extends io.grpc.Server {
private static final io.grpc.internal.ServerStreamListener NOOP_LISTENER
private java.util.concurrent.Executor executor
private boolean usingSharedExecutor
private final io.grpc.internal.InternalHandlerRegistry registry
private final io.grpc.HandlerRegistry fallbackRegistry
private boolean started
private boolean shutdown
private io.grpc.Status shutdownNowStatus
private boolean serverShutdownCallbackInvoked
private boolean terminated
private final io.grpc.internal.InternalServer transportServer
private final Object lock
private boolean transportServerTerminated
private final java.util.Collection transports
private final java.util.concurrent.ScheduledExecutorService timeoutService
private final io.grpc.Context rootContext
private final io.grpc.DecompressorRegistry decompressorRegistry
private final io.grpc.CompressorRegistry compressorRegistry
void (java.util.concurrent.Executor, io.grpc.internal.InternalHandlerRegistry, io.grpc.HandlerRegistry, io.grpc.internal.InternalServer, io.grpc.Context, io.grpc.DecompressorRegistry, io.grpc.CompressorRegistry)
java.util.concurrent.Executor executor
io.grpc.internal.InternalHandlerRegistry registry
io.grpc.HandlerRegistry fallbackRegistry
io.grpc.internal.InternalServer transportServer
io.grpc.Context rootContext
io.grpc.DecompressorRegistry decompressorRegistry
io.grpc.CompressorRegistry compressorRegistry
public io.grpc.internal.ServerImpl start () throws java.io.IOException
public int getPort ()
public io.grpc.internal.ServerImpl shutdown ()
boolean shutdownTransportServer
public io.grpc.internal.ServerImpl shutdownNow ()
io.grpc.internal.ServerTransport transport
java.util.Collection transportsCopy
io.grpc.Status nowStatus
boolean savedServerShutdownCallbackInvoked
public boolean isShutdown ()
public boolean awaitTermination (long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
long timeoutNanos
long endTimeNanos
long timeout
java.util.concurrent.TimeUnit unit
public void awaitTermination () throws java.lang.InterruptedException
public boolean isTerminated ()
private void transportClosed (io.grpc.internal.ServerTransport)
io.grpc.internal.ServerTransport transport
private void checkForTermination ()
public volatile io.grpc.Server shutdownNow ()
public volatile io.grpc.Server shutdown ()
public volatile io.grpc.Server start () throws java.io.IOException
static java.lang.Object access$200 (io.grpc.internal.ServerImpl)
io.grpc.internal.ServerImpl x0
static java.util.Collection access$300 (io.grpc.internal.ServerImpl)
io.grpc.internal.ServerImpl x0
static io.grpc.Status access$400 (io.grpc.internal.ServerImpl)
io.grpc.internal.ServerImpl x0
static boolean access$502 (io.grpc.internal.ServerImpl, boolean)
io.grpc.internal.ServerImpl x0
boolean x1
static boolean access$602 (io.grpc.internal.ServerImpl, boolean)
io.grpc.internal.ServerImpl x0
boolean x1
static void access$700 (io.grpc.internal.ServerImpl)
io.grpc.internal.ServerImpl x0
static void access$800 (io.grpc.internal.ServerImpl, io.grpc.internal.ServerTransport)
io.grpc.internal.ServerImpl x0
io.grpc.internal.ServerTransport x1
static java.util.concurrent.Executor access$900 (io.grpc.internal.ServerImpl)
io.grpc.internal.ServerImpl x0
static io.grpc.internal.ServerStreamListener access$1000 ()
static io.grpc.internal.InternalHandlerRegistry access$1100 (io.grpc.internal.ServerImpl)
io.grpc.internal.ServerImpl x0
static io.grpc.HandlerRegistry access$1200 (io.grpc.internal.ServerImpl)
io.grpc.internal.ServerImpl x0
static io.grpc.Context access$1500 (io.grpc.internal.ServerImpl)
io.grpc.internal.ServerImpl x0
static java.util.concurrent.ScheduledExecutorService access$1600 (io.grpc.internal.ServerImpl)
io.grpc.internal.ServerImpl x0
static io.grpc.DecompressorRegistry access$1700 (io.grpc.internal.ServerImpl)
io.grpc.internal.ServerImpl x0
static io.grpc.CompressorRegistry access$1800 (io.grpc.internal.ServerImpl)
io.grpc.internal.ServerImpl x0
static void ()
}
io/grpc/internal/AbstractReadableBuffer.classAbstractReadableBuffer.java
package io.grpc.internal
public abstract io.grpc.internal.AbstractReadableBuffer extends java.lang.Object implements io.grpc.internal.ReadableBuffer {
public void ()
public final int readUnsignedMedium ()
int b1
int b2
int b3
public final int readUnsignedShort ()
int b1
int b2
public final int readInt ()
int b1
int b2
int b3
int b4
public boolean hasArray ()
public byte[] array ()
public int arrayOffset ()
public void close ()
protected final void checkReadable (int)
int length
}
io/grpc/internal/ReadableBuffer.classReadableBuffer.java
package io.grpc.internal
public abstract io.grpc.internal.ReadableBuffer extends java.lang.Object implements java.io.Closeable {
public abstract int readableBytes ()
public abstract int readUnsignedByte ()
public abstract int readUnsignedMedium ()
public abstract int readUnsignedShort ()
public abstract int readInt ()
public abstract void skipBytes (int)
public abstract void readBytes (byte[], int, int)
public abstract void readBytes (java.nio.ByteBuffer)
public abstract void readBytes (java.io.OutputStream, int) throws java.io.IOException
public abstract io.grpc.internal.ReadableBuffer readBytes (int)
public abstract boolean hasArray ()
public abstract byte[] array ()
public abstract int arrayOffset ()
public abstract void close ()
}
io/grpc/internal/ContextRunnable.classContextRunnable.java
package io.grpc.internal
abstract io.grpc.internal.ContextRunnable extends java.lang.Object implements java.lang.Runnable {
private final io.grpc.Context context
public void (io.grpc.Context)
io.grpc.Context context
public final void run ()
io.grpc.Context previous
public abstract void runInContext ()
}
io/grpc/internal/DnsNameResolverProvider.classDnsNameResolverProvider.java
package io.grpc.internal
public final io.grpc.internal.DnsNameResolverProvider extends io.grpc.NameResolverProvider {
private static final String SCHEME
public void ()
public io.grpc.internal.DnsNameResolver newNameResolver (java.net.URI, io.grpc.Attributes)
String targetPath
String name
java.net.URI targetUri
io.grpc.Attributes params
public java.lang.String getDefaultScheme ()
protected boolean isAvailable ()
protected int priority ()
public volatile io.grpc.NameResolver newNameResolver (java.net.URI, io.grpc.Attributes)
}
io/grpc/internal/DnsNameResolver$1.classDnsNameResolver.java
package io.grpc.internal
io.grpc.internal.DnsNameResolver$1 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.DnsNameResolver this$0
void (io.grpc.internal.DnsNameResolver)
io.grpc.internal.DnsNameResolver this$0
public void run ()
java.net.UnknownHostException e
java.net.InetAddress inetAddr
int i
java.util.List servers
java.net.InetAddress[] inetAddrs
java.net.InetAddress[] inetAddrs
io.grpc.NameResolver$Listener savedListener
}
io/grpc/internal/DnsNameResolver$2.classDnsNameResolver.java
package io.grpc.internal
io.grpc.internal.DnsNameResolver$2 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.DnsNameResolver this$0
void (io.grpc.internal.DnsNameResolver)
io.grpc.internal.DnsNameResolver this$0
public void run ()
}
io/grpc/internal/DnsNameResolver.classDnsNameResolver.java
package io.grpc.internal
io.grpc.internal.DnsNameResolver extends io.grpc.NameResolver {
private final String authority
private final String host
private final int port
private final io.grpc.internal.SharedResourceHolder$Resource timerServiceResource
private final io.grpc.internal.SharedResourceHolder$Resource executorResource
private boolean shutdown
private java.util.concurrent.ScheduledExecutorService timerService
private java.util.concurrent.ExecutorService executor
private java.util.concurrent.ScheduledFuture resolutionTask
private boolean resolving
private io.grpc.NameResolver$Listener listener
private final Runnable resolutionRunnable
private final Runnable resolutionRunnableOnExecutor
void (java.lang.String, java.lang.String, io.grpc.Attributes, io.grpc.internal.SharedResourceHolder$Resource, io.grpc.internal.SharedResourceHolder$Resource)
Integer defaultPort
String nsAuthority
String name
io.grpc.Attributes params
io.grpc.internal.SharedResourceHolder$Resource timerServiceResource
io.grpc.internal.SharedResourceHolder$Resource executorResource
java.net.URI nameUri
public final java.lang.String getServiceAuthority ()
public final synchronized void start (io.grpc.NameResolver$Listener)
io.grpc.NameResolver$Listener listener
public final synchronized void refresh ()
java.net.InetAddress[] getAllByName (java.lang.String) throws java.net.UnknownHostException
String host
private void resolve ()
public final synchronized void shutdown ()
final int getPort ()
static java.util.concurrent.ScheduledFuture access$000 (io.grpc.internal.DnsNameResolver)
io.grpc.internal.DnsNameResolver x0
static java.util.concurrent.ScheduledFuture access$002 (io.grpc.internal.DnsNameResolver, java.util.concurrent.ScheduledFuture)
io.grpc.internal.DnsNameResolver x0
java.util.concurrent.ScheduledFuture x1
static boolean access$100 (io.grpc.internal.DnsNameResolver)
io.grpc.internal.DnsNameResolver x0
static io.grpc.NameResolver$Listener access$200 (io.grpc.internal.DnsNameResolver)
io.grpc.internal.DnsNameResolver x0
static boolean access$302 (io.grpc.internal.DnsNameResolver, boolean)
io.grpc.internal.DnsNameResolver x0
boolean x1
static java.lang.String access$400 (io.grpc.internal.DnsNameResolver)
io.grpc.internal.DnsNameResolver x0
static java.lang.Runnable access$500 (io.grpc.internal.DnsNameResolver)
io.grpc.internal.DnsNameResolver x0
static java.util.concurrent.ScheduledExecutorService access$600 (io.grpc.internal.DnsNameResolver)
io.grpc.internal.DnsNameResolver x0
static int access$700 (io.grpc.internal.DnsNameResolver)
io.grpc.internal.DnsNameResolver x0
static java.lang.Runnable access$800 (io.grpc.internal.DnsNameResolver)
io.grpc.internal.DnsNameResolver x0
static java.util.concurrent.ExecutorService access$900 (io.grpc.internal.DnsNameResolver)
io.grpc.internal.DnsNameResolver x0
}
io/grpc/internal/ExponentialBackoffPolicy$Provider.classExponentialBackoffPolicy.java
package io.grpc.internal
final io.grpc.internal.ExponentialBackoffPolicy$Provider extends java.lang.Object implements io.grpc.internal.BackoffPolicy$Provider {
void ()
public io.grpc.internal.BackoffPolicy get ()
}
io/grpc/internal/ExponentialBackoffPolicy.classExponentialBackoffPolicy.java
package io.grpc.internal
final io.grpc.internal.ExponentialBackoffPolicy extends java.lang.Object implements io.grpc.internal.BackoffPolicy {
private java.util.Random random
private long initialBackoffMillis
private long maxBackoffMillis
private double multiplier
private double jitter
private long nextBackoffMillis
void ()
public long nextBackoffMillis ()
long currentBackoffMillis
private long uniformRandom (double, double)
double low
double high
double mag
io.grpc.internal.ExponentialBackoffPolicy setRandom (java.util.Random)
java.util.Random random
io.grpc.internal.ExponentialBackoffPolicy setInitialBackoffMillis (long)
long initialBackoffMillis
io.grpc.internal.ExponentialBackoffPolicy setMaxBackoffMillis (long)
long maxBackoffMillis
io.grpc.internal.ExponentialBackoffPolicy setMultiplier (double)
double multiplier
io.grpc.internal.ExponentialBackoffPolicy setJitter (double)
double jitter
}
io/grpc/internal/FailingClientStream.classFailingClientStream.java
package io.grpc.internal
io.grpc.internal.FailingClientStream extends io.grpc.internal.NoopClientStream {
private boolean started
private final io.grpc.Status error
public void (io.grpc.Status)
io.grpc.Status error
public void start (io.grpc.internal.ClientStreamListener)
io.grpc.internal.ClientStreamListener listener
io.grpc.Status getError ()
}
io/grpc/internal/NoopClientStream.classNoopClientStream.java
package io.grpc.internal
public io.grpc.internal.NoopClientStream extends java.lang.Object implements io.grpc.internal.ClientStream {
public static io.grpc.internal.NoopClientStream INSTANCE
public void ()
public void setAuthority (java.lang.String)
String authority
public void start (io.grpc.internal.ClientStreamListener)
io.grpc.internal.ClientStreamListener listener
public void request (int)
int numMessages
public void writeMessage (java.io.InputStream)
java.io.InputStream message
public void flush ()
public boolean isReady ()
public void cancel (io.grpc.Status)
io.grpc.Status status
public void halfClose ()
public void setMessageCompression (boolean)
boolean enable
public void setCompressor (io.grpc.Compressor)
io.grpc.Compressor compressor
public void setDecompressor (io.grpc.Decompressor)
io.grpc.Decompressor decompressor
static void ()
}
io/grpc/internal/ForwardingReadableBuffer.classForwardingReadableBuffer.java
package io.grpc.internal
public abstract io.grpc.internal.ForwardingReadableBuffer extends java.lang.Object implements io.grpc.internal.ReadableBuffer {
private final io.grpc.internal.ReadableBuffer buf
public void (io.grpc.internal.ReadableBuffer)
io.grpc.internal.ReadableBuffer buf
public int readableBytes ()
public int readUnsignedByte ()
public int readUnsignedMedium ()
public int readUnsignedShort ()
public int readInt ()
public void skipBytes (int)
int length
public void readBytes (byte[], int, int)
byte[] dest
int destOffset
int length
public void readBytes (java.nio.ByteBuffer)
java.nio.ByteBuffer dest
public void readBytes (java.io.OutputStream, int) throws java.io.IOException
java.io.OutputStream dest
int length
public io.grpc.internal.ReadableBuffer readBytes (int)
int length
public boolean hasArray ()
public byte[] array ()
public int arrayOffset ()
public void close ()
}
io/grpc/internal/KeepAliveManager$1.classKeepAliveManager.java
package io.grpc.internal
io.grpc.internal.KeepAliveManager$1 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.KeepAliveManager this$0
void (io.grpc.internal.KeepAliveManager)
io.grpc.internal.KeepAliveManager this$0
public void run ()
boolean shouldShutdown
}
io/grpc/internal/KeepAliveManager$2.classKeepAliveManager.java
package io.grpc.internal
io.grpc.internal.KeepAliveManager$2 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.KeepAliveManager this$0
void (io.grpc.internal.KeepAliveManager)
io.grpc.internal.KeepAliveManager this$0
public void run ()
boolean shouldSendPing
}
io/grpc/internal/KeepAliveManager$State.classKeepAliveManager.java
package io.grpc.internal
final io.grpc.internal.KeepAliveManager$State extends java.lang.Enum {
public static final io.grpc.internal.KeepAliveManager$State IDLE
public static final io.grpc.internal.KeepAliveManager$State PING_SCHEDULED
public static final io.grpc.internal.KeepAliveManager$State PING_DELAYED
public static final io.grpc.internal.KeepAliveManager$State PING_SENT
public static final io.grpc.internal.KeepAliveManager$State IDLE_AND_PING_SENT
public static final io.grpc.internal.KeepAliveManager$State DISCONNECTED
private static final io.grpc.internal.KeepAliveManager$State[] $VALUES
public static io.grpc.internal.KeepAliveManager$State[] values ()
public static io.grpc.internal.KeepAliveManager$State valueOf (java.lang.String)
String name
private void (java.lang.String, int)
static void ()
}
io/grpc/internal/KeepAliveManager$KeepAlivePingCallback.classKeepAliveManager.java
package io.grpc.internal
io.grpc.internal.KeepAliveManager$KeepAlivePingCallback extends java.lang.Object implements io.grpc.internal.ClientTransport$PingCallback {
final io.grpc.internal.KeepAliveManager this$0
private void (io.grpc.internal.KeepAliveManager)
public void onSuccess (long)
long roundTripTimeNanos
public void onFailure (java.lang.Throwable)
Throwable cause
void (io.grpc.internal.KeepAliveManager, io.grpc.internal.KeepAliveManager$1)
io.grpc.internal.KeepAliveManager x0
io.grpc.internal.KeepAliveManager$1 x1
}
io/grpc/internal/KeepAliveManager$Ticker.classKeepAliveManager.java
package io.grpc.internal
abstract io.grpc.internal.KeepAliveManager$Ticker extends java.lang.Object {
void ()
public abstract long read ()
}
io/grpc/internal/KeepAliveManager$SystemTicker.classKeepAliveManager.java
package io.grpc.internal
io.grpc.internal.KeepAliveManager$SystemTicker extends io.grpc.internal.KeepAliveManager$Ticker {
private void ()
public long read ()
void (io.grpc.internal.KeepAliveManager$1)
io.grpc.internal.KeepAliveManager$1 x0
}
io/grpc/internal/KeepAliveManager.classKeepAliveManager.java
package io.grpc.internal
public io.grpc.internal.KeepAliveManager extends java.lang.Object {
private static final io.grpc.internal.KeepAliveManager$SystemTicker SYSTEM_TICKER
private static final long MIN_KEEPALIVE_DELAY_NANOS
private final java.util.concurrent.ScheduledExecutorService scheduler
private final io.grpc.internal.ManagedClientTransport transport
private final io.grpc.internal.KeepAliveManager$Ticker ticker
private io.grpc.internal.KeepAliveManager$State state
private long nextKeepaliveTime
private java.util.concurrent.ScheduledFuture shutdownFuture
private java.util.concurrent.ScheduledFuture pingFuture
private final Runnable shutdown
private final Runnable sendPing
private final io.grpc.internal.KeepAliveManager$KeepAlivePingCallback pingCallback
private long keepAliveDelayInNanos
private long keepAliveTimeoutInNanos
public void (io.grpc.internal.ManagedClientTransport, java.util.concurrent.ScheduledExecutorService, long, long)
io.grpc.internal.ManagedClientTransport transport
java.util.concurrent.ScheduledExecutorService scheduler
long keepAliveDelayInNanos
long keepAliveTimeoutInNanos
void (io.grpc.internal.ManagedClientTransport, java.util.concurrent.ScheduledExecutorService, io.grpc.internal.KeepAliveManager$Ticker, long, long)
io.grpc.internal.ManagedClientTransport transport
java.util.concurrent.ScheduledExecutorService scheduler
io.grpc.internal.KeepAliveManager$Ticker ticker
long keepAliveDelayInNanos
long keepAliveTimeoutInNanos
public synchronized void onDataReceived ()
public synchronized void onTransportActive ()
public synchronized void onTransportIdle ()
public synchronized void onTransportShutdown ()
static io.grpc.internal.KeepAliveManager$State access$100 (io.grpc.internal.KeepAliveManager)
io.grpc.internal.KeepAliveManager x0
static io.grpc.internal.KeepAliveManager$State access$102 (io.grpc.internal.KeepAliveManager, io.grpc.internal.KeepAliveManager$State)
io.grpc.internal.KeepAliveManager x0
io.grpc.internal.KeepAliveManager$State x1
static io.grpc.internal.ManagedClientTransport access$200 (io.grpc.internal.KeepAliveManager)
io.grpc.internal.KeepAliveManager x0
static java.util.concurrent.ScheduledFuture access$302 (io.grpc.internal.KeepAliveManager, java.util.concurrent.ScheduledFuture)
io.grpc.internal.KeepAliveManager x0
java.util.concurrent.ScheduledFuture x1
static java.lang.Runnable access$400 (io.grpc.internal.KeepAliveManager)
io.grpc.internal.KeepAliveManager x0
static long access$500 (io.grpc.internal.KeepAliveManager)
io.grpc.internal.KeepAliveManager x0
static java.util.concurrent.ScheduledExecutorService access$600 (io.grpc.internal.KeepAliveManager)
io.grpc.internal.KeepAliveManager x0
static java.util.concurrent.ScheduledFuture access$702 (io.grpc.internal.KeepAliveManager, java.util.concurrent.ScheduledFuture)
io.grpc.internal.KeepAliveManager x0
java.util.concurrent.ScheduledFuture x1
static java.lang.Runnable access$800 (io.grpc.internal.KeepAliveManager)
io.grpc.internal.KeepAliveManager x0
static long access$900 (io.grpc.internal.KeepAliveManager)
io.grpc.internal.KeepAliveManager x0
static io.grpc.internal.KeepAliveManager$Ticker access$1000 (io.grpc.internal.KeepAliveManager)
io.grpc.internal.KeepAliveManager x0
static io.grpc.internal.KeepAliveManager$KeepAlivePingCallback access$1100 (io.grpc.internal.KeepAliveManager)
io.grpc.internal.KeepAliveManager x0
static java.util.concurrent.ScheduledFuture access$300 (io.grpc.internal.KeepAliveManager)
io.grpc.internal.KeepAliveManager x0
static long access$902 (io.grpc.internal.KeepAliveManager, long)
io.grpc.internal.KeepAliveManager x0
long x1
static long access$1300 (io.grpc.internal.KeepAliveManager)
io.grpc.internal.KeepAliveManager x0
static void ()
}
io/grpc/internal/SerializeReentrantCallsDirectExecutor.classSerializeReentrantCallsDirectExecutor.java
package io.grpc.internal
io.grpc.internal.SerializeReentrantCallsDirectExecutor extends java.lang.Object implements java.util.concurrent.Executor {
private static final java.util.logging.Logger log
private boolean executing
private java.util.ArrayDeque taskQueue
void ()
public void execute (java.lang.Runnable)
Throwable t
Runnable task
private void completeQueuedTasks ()
Throwable t
Runnable task
private void enqueue (java.lang.Runnable)
Runnable r
static void ()
}
io/grpc/internal/SerializingExecutor$1.classSerializingExecutor.java
package io.grpc.internal
io.grpc.internal.SerializingExecutor$1 extends java.lang.Object {
final io.grpc.internal.SerializingExecutor this$0
void (io.grpc.internal.SerializingExecutor)
io.grpc.internal.SerializingExecutor this$0
public java.lang.String toString ()
}
io/grpc/internal/SerializingExecutor$TaskRunner.classSerializingExecutor.java
package io.grpc.internal
io.grpc.internal.SerializingExecutor$TaskRunner extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.SerializingExecutor this$0
private void (io.grpc.internal.SerializingExecutor)
public void run ()
RuntimeException e
Runnable nextToRun
boolean stillRunning
void (io.grpc.internal.SerializingExecutor, io.grpc.internal.SerializingExecutor$1)
io.grpc.internal.SerializingExecutor x0
io.grpc.internal.SerializingExecutor$1 x1
}
io/grpc/internal/SerializingExecutor.classSerializingExecutor.java
package io.grpc.internal
public final io.grpc.internal.SerializingExecutor extends java.lang.Object implements java.util.concurrent.Executor {
private static final java.util.logging.Logger log
private final java.util.concurrent.Executor executor
private final java.util.Queue waitQueue
private boolean isThreadScheduled
private final io.grpc.internal.SerializingExecutor$TaskRunner taskRunner
private final Object internalLock
public void (java.util.concurrent.Executor)
java.util.concurrent.Executor executor
public void execute (java.lang.Runnable)
boolean threw
Runnable r
boolean scheduleTaskRunner
static java.lang.Object access$100 (io.grpc.internal.SerializingExecutor)
io.grpc.internal.SerializingExecutor x0
static boolean access$200 (io.grpc.internal.SerializingExecutor)
io.grpc.internal.SerializingExecutor x0
static java.util.Queue access$300 (io.grpc.internal.SerializingExecutor)
io.grpc.internal.SerializingExecutor x0
static boolean access$202 (io.grpc.internal.SerializingExecutor, boolean)
io.grpc.internal.SerializingExecutor x0
boolean x1
static java.util.logging.Logger access$400 ()
static void ()
}
io/grpc/internal/WritableBuffer.classWritableBuffer.java
package io.grpc.internal
public abstract io.grpc.internal.WritableBuffer extends java.lang.Object {
public abstract void write (byte[], int, int)
public abstract void write (byte)
public abstract int writableBytes ()
public abstract int readableBytes ()
public abstract void release ()
}
io/grpc/internal/WritableBufferAllocator.classWritableBufferAllocator.java
package io.grpc.internal
public abstract io.grpc.internal.WritableBufferAllocator extends java.lang.Object {
public abstract io.grpc.internal.WritableBuffer allocate (int)
}
io/grpc/internal/AbstractClientStream$1.classAbstractClientStream.java
package io.grpc.internal
io.grpc.internal.AbstractClientStream$1 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.Status val$status
final io.grpc.Metadata val$trailers
final io.grpc.internal.AbstractClientStream this$0
void (io.grpc.internal.AbstractClientStream, io.grpc.Status, io.grpc.Metadata)
io.grpc.internal.AbstractClientStream this$0
public void run ()
}
io/grpc/internal/AbstractClientStream.classAbstractClientStream.java
package io.grpc.internal
public abstract io.grpc.internal.AbstractClientStream extends io.grpc.internal.AbstractStream implements io.grpc.internal.ClientStream {
private static final java.util.logging.Logger log
private io.grpc.internal.ClientStreamListener listener
private boolean listenerClosed
private io.grpc.Status status
private io.grpc.Metadata trailers
private Runnable closeListenerTask
private volatile boolean cancelled
protected void (io.grpc.internal.WritableBufferAllocator, int)
io.grpc.internal.WritableBufferAllocator bufferAllocator
int maxMessageSize
protected final io.grpc.internal.ClientStreamListener listener ()
public void start (io.grpc.internal.ClientStreamListener)
io.grpc.internal.ClientStreamListener listener
protected void receiveMessage (java.io.InputStream)
java.io.InputStream is
protected void inboundTransportError (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status errorStatus
io.grpc.Metadata metadata
protected void inboundHeadersReceived (io.grpc.Metadata)
io.grpc.Metadata headers
protected void inboundDataReceived (io.grpc.internal.ReadableBuffer)
io.grpc.internal.ReadableBuffer frame
boolean needToCloseFrame
protected void inboundDeliveryPaused ()
protected final void deframeFailed (java.lang.Throwable)
Throwable cause
protected void inboundTrailersReceived (io.grpc.Metadata, io.grpc.Status)
io.grpc.Metadata trailers
io.grpc.Status status
protected void remoteEndClosed ()
protected final void internalSendFrame (io.grpc.internal.WritableBuffer, boolean, boolean)
io.grpc.internal.WritableBuffer frame
boolean endOfStream
boolean flush
protected abstract void sendFrame (io.grpc.internal.WritableBuffer, boolean, boolean)
public void transportReportStatus (io.grpc.Status, boolean, io.grpc.Metadata)
io.grpc.Status newStatus
boolean stopDelivery
io.grpc.Metadata trailers
boolean closingLater
boolean deliveryStalled
private java.lang.Runnable newCloseListenerTask (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
private void closeListener (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status newStatus
io.grpc.Metadata trailers
private void runCloseListenerTask ()
public final void halfClose ()
public final void cancel (io.grpc.Status)
io.grpc.Status reason
public final boolean isReady ()
protected abstract void sendCancel (io.grpc.Status)
protected com.google.common.base.MoreObjects$ToStringHelper toStringHelper ()
com.google.common.base.MoreObjects$ToStringHelper toStringHelper
public boolean isClosed ()
protected volatile io.grpc.internal.StreamListener listener ()
static void access$000 (io.grpc.internal.AbstractClientStream, io.grpc.Status, io.grpc.Metadata)
io.grpc.internal.AbstractClientStream x0
io.grpc.Status x1
io.grpc.Metadata x2
static void ()
}
io/grpc/internal/AbstractStream$Phase.classAbstractStream.java
package io.grpc.internal
public final io.grpc.internal.AbstractStream$Phase extends java.lang.Enum {
public static final io.grpc.internal.AbstractStream$Phase HEADERS
public static final io.grpc.internal.AbstractStream$Phase MESSAGE
public static final io.grpc.internal.AbstractStream$Phase STATUS
private static final io.grpc.internal.AbstractStream$Phase[] $VALUES
public static io.grpc.internal.AbstractStream$Phase[] values ()
public static io.grpc.internal.AbstractStream$Phase valueOf (java.lang.String)
String name
private void (java.lang.String, int)
static void ()
}
io/grpc/internal/AbstractStream$FramerSink.classAbstractStream.java
package io.grpc.internal
io.grpc.internal.AbstractStream$FramerSink extends java.lang.Object implements io.grpc.internal.MessageFramer$Sink {
final io.grpc.internal.AbstractStream this$0
void (io.grpc.internal.AbstractStream)
io.grpc.internal.AbstractStream this$0
public void deliverFrame (io.grpc.internal.WritableBuffer, boolean, boolean)
io.grpc.internal.WritableBuffer frame
boolean endOfStream
boolean flush
}
io/grpc/internal/AbstractStream$DeframerListener.classAbstractStream.java
package io.grpc.internal
io.grpc.internal.AbstractStream$DeframerListener extends java.lang.Object implements io.grpc.internal.MessageDeframer$Listener {
final io.grpc.internal.AbstractStream this$0
void (io.grpc.internal.AbstractStream)
io.grpc.internal.AbstractStream this$0
public void bytesRead (int)
int numBytes
public void messageRead (java.io.InputStream)
java.io.InputStream input
public void deliveryStalled ()
public void endOfStream ()
}
io/grpc/internal/AbstractStream.classAbstractStream.java
package io.grpc.internal
public abstract io.grpc.internal.AbstractStream extends java.lang.Object implements io.grpc.internal.Stream {
public static final int DEFAULT_ONREADY_THRESHOLD
private final io.grpc.internal.MessageFramer framer
private final io.grpc.internal.MessageDeframer deframer
private io.grpc.internal.AbstractStream$Phase inboundPhase
private io.grpc.internal.AbstractStream$Phase outboundPhase
private int onReadyThreshold
private int numSentBytesQueued
private boolean allocated
private final Object onReadyLock
void (io.grpc.internal.WritableBufferAllocator, int)
io.grpc.internal.WritableBufferAllocator bufferAllocator
int maxMessageSize
void (io.grpc.internal.MessageFramer, io.grpc.internal.MessageDeframer)
io.grpc.internal.MessageFramer framer
io.grpc.internal.MessageDeframer deframer
protected abstract io.grpc.internal.StreamListener listener ()
public abstract java.lang.Object id ()
public int getOnReadyThreshold ()
public void writeMessage (java.io.InputStream)
java.io.InputStream message
public final void setMessageCompression (boolean)
boolean enable
public final void flush ()
public boolean isReady ()
final void closeFramer ()
public void dispose ()
protected abstract void internalSendFrame (io.grpc.internal.WritableBuffer, boolean, boolean)
protected abstract void receiveMessage (java.io.InputStream)
protected abstract void inboundDeliveryPaused ()
protected abstract void remoteEndClosed ()
protected abstract void returnProcessedBytes (int)
protected abstract void deframeFailed (java.lang.Throwable)
protected final void closeDeframer ()
protected final void deframe (io.grpc.internal.ReadableBuffer, boolean)
Throwable t
io.grpc.internal.ReadableBuffer frame
boolean endOfStream
protected final boolean isDeframerStalled ()
protected final void requestMessagesFromDeframer (int)
Throwable t
int numMessages
public final void setCompressor (io.grpc.Compressor)
io.grpc.Compressor compressor
public final void setDecompressor (io.grpc.Decompressor)
io.grpc.Decompressor decompressor
protected final void onStreamAllocated ()
protected final void onSendingBytes (int)
int numBytes
protected final void onSentBytes (int)
boolean belowThresholdBefore
boolean belowThresholdAfter
int numBytes
boolean doNotify
final void notifyIfReady ()
boolean doNotify
final io.grpc.internal.AbstractStream$Phase inboundPhase ()
final io.grpc.internal.AbstractStream$Phase inboundPhase (io.grpc.internal.AbstractStream$Phase)
io.grpc.internal.AbstractStream$Phase nextPhase
io.grpc.internal.AbstractStream$Phase tmp
final io.grpc.internal.AbstractStream$Phase outboundPhase ()
final io.grpc.internal.AbstractStream$Phase outboundPhase (io.grpc.internal.AbstractStream$Phase)
io.grpc.internal.AbstractStream$Phase nextPhase
io.grpc.internal.AbstractStream$Phase tmp
io.grpc.internal.AbstractStream$Phase verifyNextPhase (io.grpc.internal.AbstractStream$Phase, io.grpc.internal.AbstractStream$Phase)
io.grpc.internal.AbstractStream$Phase currentPhase
io.grpc.internal.AbstractStream$Phase nextPhase
public boolean canReceive ()
public boolean canSend ()
public boolean isClosed ()
public java.lang.String toString ()
protected com.google.common.base.MoreObjects$ToStringHelper toStringHelper ()
}
io/grpc/internal/MessageFramer$Sink.classMessageFramer.java
package io.grpc.internal
public abstract io.grpc.internal.MessageFramer$Sink extends java.lang.Object {
public abstract void deliverFrame (io.grpc.internal.WritableBuffer, boolean, boolean)
}
io/grpc/internal/MessageFramer$OutputStreamAdapter.classMessageFramer.java
package io.grpc.internal
io.grpc.internal.MessageFramer$OutputStreamAdapter extends java.io.OutputStream {
private final byte[] singleByte
final io.grpc.internal.MessageFramer this$0
private void (io.grpc.internal.MessageFramer)
public void write (int)
int b
public void write (byte[], int, int)
byte[] b
int off
int len
void (io.grpc.internal.MessageFramer, io.grpc.internal.MessageFramer$1)
io.grpc.internal.MessageFramer x0
io.grpc.internal.MessageFramer$1 x1
}
io/grpc/internal/MessageFramer$BufferChainOutputStream.classMessageFramer.java
package io.grpc.internal
final io.grpc.internal.MessageFramer$BufferChainOutputStream extends java.io.OutputStream {
private final java.util.List bufferList
private io.grpc.internal.WritableBuffer current
final io.grpc.internal.MessageFramer this$0
private void (io.grpc.internal.MessageFramer)
public void write (int) throws java.io.IOException
int b
byte[] singleByte
public void write (byte[], int, int)
int needed
int canWrite
byte[] b
int off
int len
private int readableBytes ()
io.grpc.internal.WritableBuffer writableBuffer
int readable
void (io.grpc.internal.MessageFramer, io.grpc.internal.MessageFramer$1)
io.grpc.internal.MessageFramer x0
io.grpc.internal.MessageFramer$1 x1
static int access$200 (io.grpc.internal.MessageFramer$BufferChainOutputStream)
io.grpc.internal.MessageFramer$BufferChainOutputStream x0
static java.util.List access$300 (io.grpc.internal.MessageFramer$BufferChainOutputStream)
io.grpc.internal.MessageFramer$BufferChainOutputStream x0
}
io/grpc/internal/MessageFramer$1.classMessageFramer.java
package io.grpc.internal
io.grpc.internal.MessageFramer$1 extends java.lang.Object {
}
io/grpc/internal/MessageFramer.classMessageFramer.java
package io.grpc.internal
public io.grpc.internal.MessageFramer extends java.lang.Object {
private static final int HEADER_LENGTH
private static final byte UNCOMPRESSED
private static final byte COMPRESSED
private final io.grpc.internal.MessageFramer$Sink sink
private io.grpc.internal.WritableBuffer buffer
private io.grpc.Compressor compressor
private boolean messageCompression
private final io.grpc.internal.MessageFramer$OutputStreamAdapter outputStreamAdapter
private final byte[] headerScratch
private final io.grpc.internal.WritableBufferAllocator bufferAllocator
private boolean closed
public void (io.grpc.internal.MessageFramer$Sink, io.grpc.internal.WritableBufferAllocator)
io.grpc.internal.MessageFramer$Sink sink
io.grpc.internal.WritableBufferAllocator bufferAllocator
io.grpc.internal.MessageFramer setCompressor (io.grpc.Compressor)
io.grpc.Compressor compressor
io.grpc.internal.MessageFramer setMessageCompression (boolean)
boolean enable
public void writePayload (java.io.InputStream)
java.io.IOException e
RuntimeException e
String err
java.io.InputStream message
boolean compressed
int written
int messageLength
private int writeUncompressed (java.io.InputStream, int) throws java.io.IOException
java.io.InputStream message
int messageLength
io.grpc.internal.MessageFramer$BufferChainOutputStream bufferChain
int written
private int writeCompressed (java.io.InputStream, int) throws java.io.IOException
java.io.InputStream message
int messageLength
io.grpc.internal.MessageFramer$BufferChainOutputStream bufferChain
java.io.OutputStream compressingStream
int written
private int getKnownLength (java.io.InputStream) throws java.io.IOException
java.io.InputStream inputStream
private int writeKnownLength (java.io.InputStream, int, boolean) throws java.io.IOException
java.io.InputStream message
int messageLength
boolean compressed
java.nio.ByteBuffer header
private void writeBufferChain (io.grpc.internal.MessageFramer$BufferChainOutputStream, boolean)
int i
io.grpc.internal.MessageFramer$BufferChainOutputStream bufferChain
boolean compressed
java.nio.ByteBuffer header
int messageLength
io.grpc.internal.WritableBuffer writeableHeader
java.util.List bufferList
private static int writeToOutputStream (java.io.InputStream, java.io.OutputStream) throws java.io.IOException
long written
java.io.InputStream message
java.io.OutputStream outputStream
private void writeRaw (byte[], int, int)
int toWrite
byte[] b
int off
int len
public void flush ()
public boolean isClosed ()
public void close ()
public void dispose ()
private void releaseBuffer ()
private void commitToSink (boolean, boolean)
boolean endOfStream
boolean flush
io.grpc.internal.WritableBuffer buf
private void verifyNotClosed ()
static void access$400 (io.grpc.internal.MessageFramer, byte[], int, int)
io.grpc.internal.MessageFramer x0
byte[] x1
int x2
int x3
static io.grpc.internal.WritableBufferAllocator access$500 (io.grpc.internal.MessageFramer)
io.grpc.internal.MessageFramer x0
}
io/grpc/internal/MessageDeframer$Listener.classMessageDeframer.java
package io.grpc.internal
public abstract io.grpc.internal.MessageDeframer$Listener extends java.lang.Object {
public abstract void bytesRead (int)
public abstract void messageRead (java.io.InputStream)
public abstract void deliveryStalled ()
public abstract void endOfStream ()
}
io/grpc/internal/MessageDeframer$State.classMessageDeframer.java
package io.grpc.internal
final io.grpc.internal.MessageDeframer$State extends java.lang.Enum {
public static final io.grpc.internal.MessageDeframer$State HEADER
public static final io.grpc.internal.MessageDeframer$State BODY
private static final io.grpc.internal.MessageDeframer$State[] $VALUES
public static io.grpc.internal.MessageDeframer$State[] values ()
public static io.grpc.internal.MessageDeframer$State valueOf (java.lang.String)
String name
private void (java.lang.String, int)
static void ()
}
io/grpc/internal/MessageDeframer$SizeEnforcingInputStream.classMessageDeframer.java
package io.grpc.internal
final io.grpc.internal.MessageDeframer$SizeEnforcingInputStream extends java.io.FilterInputStream {
private final int maxMessageSize
private long count
private long mark
void (java.io.InputStream, int)
java.io.InputStream in
int maxMessageSize
public int read () throws java.io.IOException
int result
public int read (byte[], int, int) throws java.io.IOException
byte[] b
int off
int len
int result
public long skip (long) throws java.io.IOException
long n
long result
public synchronized void mark (int)
int readlimit
public synchronized void reset () throws java.io.IOException
private void verifySize ()
}
io/grpc/internal/MessageDeframer$1.classMessageDeframer.java
package io.grpc.internal
io.grpc.internal.MessageDeframer$1 extends java.lang.Object {
static final int[] $SwitchMap$io$grpc$internal$MessageDeframer$State
static void ()
}
io/grpc/internal/MessageDeframer.classMessageDeframer.java
package io.grpc.internal
public io.grpc.internal.MessageDeframer extends java.lang.Object implements java.io.Closeable {
private static final int HEADER_LENGTH
private static final int COMPRESSED_FLAG_MASK
private static final int RESERVED_MASK
private final io.grpc.internal.MessageDeframer$Listener listener
private final int maxMessageSize
private io.grpc.Decompressor decompressor
private io.grpc.internal.MessageDeframer$State state
private int requiredLength
private boolean compressedFlag
private boolean endOfStream
private io.grpc.internal.CompositeReadableBuffer nextFrame
private io.grpc.internal.CompositeReadableBuffer unprocessed
private long pendingDeliveries
private boolean deliveryStalled
private boolean inDelivery
public void (io.grpc.internal.MessageDeframer$Listener, io.grpc.Decompressor, int)
io.grpc.internal.MessageDeframer$Listener listener
io.grpc.Decompressor decompressor
int maxMessageSize
public void setDecompressor (io.grpc.Decompressor)
io.grpc.Decompressor decompressor
public void request (int)
int numMessages
public void deframe (io.grpc.internal.ReadableBuffer, boolean)
io.grpc.internal.ReadableBuffer data
boolean endOfStream
boolean needToCloseData
public boolean isStalled ()
public void close ()
public boolean isClosed ()
private void checkNotClosed ()
private void deliver ()
boolean havePartialMessage
boolean stalled
boolean previouslyStalled
private boolean readRequiredBytes ()
int toRead
int missingBytes
int totalBytesRead
private void processHeader ()
int type
private void processBody ()
java.io.InputStream stream
private java.io.InputStream getUncompressedBody ()
private java.io.InputStream getCompressedBody ()
java.io.InputStream unlimitedStream
java.io.IOException e
}
io/grpc/internal/CompositeReadableBuffer$1.classCompositeReadableBuffer.java
package io.grpc.internal
io.grpc.internal.CompositeReadableBuffer$1 extends io.grpc.internal.CompositeReadableBuffer$ReadOperation {
final io.grpc.internal.CompositeReadableBuffer this$0
void (io.grpc.internal.CompositeReadableBuffer)
io.grpc.internal.CompositeReadableBuffer this$0
int readInternal (io.grpc.internal.ReadableBuffer, int)
io.grpc.internal.ReadableBuffer buffer
int length
}
io/grpc/internal/CompositeReadableBuffer$2.classCompositeReadableBuffer.java
package io.grpc.internal
io.grpc.internal.CompositeReadableBuffer$2 extends io.grpc.internal.CompositeReadableBuffer$ReadOperation {
final io.grpc.internal.CompositeReadableBuffer this$0
void (io.grpc.internal.CompositeReadableBuffer)
io.grpc.internal.CompositeReadableBuffer this$0
public int readInternal (io.grpc.internal.ReadableBuffer, int)
io.grpc.internal.ReadableBuffer buffer
int length
}
io/grpc/internal/CompositeReadableBuffer$3.classCompositeReadableBuffer.java
package io.grpc.internal
io.grpc.internal.CompositeReadableBuffer$3 extends io.grpc.internal.CompositeReadableBuffer$ReadOperation {
int currentOffset
final int val$destOffset
final byte[] val$dest
final io.grpc.internal.CompositeReadableBuffer this$0
void (io.grpc.internal.CompositeReadableBuffer, int, byte[])
io.grpc.internal.CompositeReadableBuffer this$0
public int readInternal (io.grpc.internal.ReadableBuffer, int)
io.grpc.internal.ReadableBuffer buffer
int length
}
io/grpc/internal/CompositeReadableBuffer$4.classCompositeReadableBuffer.java
package io.grpc.internal
io.grpc.internal.CompositeReadableBuffer$4 extends io.grpc.internal.CompositeReadableBuffer$ReadOperation {
final java.nio.ByteBuffer val$dest
final io.grpc.internal.CompositeReadableBuffer this$0
void (io.grpc.internal.CompositeReadableBuffer, java.nio.ByteBuffer)
io.grpc.internal.CompositeReadableBuffer this$0
public int readInternal (io.grpc.internal.ReadableBuffer, int)
io.grpc.internal.ReadableBuffer buffer
int length
int prevLimit
}
io/grpc/internal/CompositeReadableBuffer$5.classCompositeReadableBuffer.java
package io.grpc.internal
io.grpc.internal.CompositeReadableBuffer$5 extends io.grpc.internal.CompositeReadableBuffer$ReadOperation {
final java.io.OutputStream val$dest
final io.grpc.internal.CompositeReadableBuffer this$0
void (io.grpc.internal.CompositeReadableBuffer, java.io.OutputStream)
io.grpc.internal.CompositeReadableBuffer this$0
public int readInternal (io.grpc.internal.ReadableBuffer, int) throws java.io.IOException
io.grpc.internal.ReadableBuffer buffer
int length
}
io/grpc/internal/CompositeReadableBuffer$ReadOperation.classCompositeReadableBuffer.java
package io.grpc.internal
abstract io.grpc.internal.CompositeReadableBuffer$ReadOperation extends java.lang.Object {
int value
java.io.IOException ex
final io.grpc.internal.CompositeReadableBuffer this$0
private void (io.grpc.internal.CompositeReadableBuffer)
final void read (io.grpc.internal.ReadableBuffer, int)
java.io.IOException e
io.grpc.internal.ReadableBuffer buffer
int length
final boolean isError ()
abstract int readInternal (io.grpc.internal.ReadableBuffer, int) throws java.io.IOException
void (io.grpc.internal.CompositeReadableBuffer, io.grpc.internal.CompositeReadableBuffer$1)
io.grpc.internal.CompositeReadableBuffer x0
io.grpc.internal.CompositeReadableBuffer$1 x1
}
io/grpc/internal/CompositeReadableBuffer.classCompositeReadableBuffer.java
package io.grpc.internal
public io.grpc.internal.CompositeReadableBuffer extends io.grpc.internal.AbstractReadableBuffer {
private int readableBytes
private final java.util.Queue buffers
public void ()
public void addBuffer (io.grpc.internal.ReadableBuffer)
io.grpc.internal.ReadableBuffer subBuffer
io.grpc.internal.ReadableBuffer buffer
io.grpc.internal.CompositeReadableBuffer compositeBuffer
public int readableBytes ()
public int readUnsignedByte ()
io.grpc.internal.CompositeReadableBuffer$ReadOperation op
public void skipBytes (int)
int length
public void readBytes (byte[], int, int)
byte[] dest
int destOffset
int length
public void readBytes (java.nio.ByteBuffer)
java.nio.ByteBuffer dest
public void readBytes (java.io.OutputStream, int) throws java.io.IOException
java.io.OutputStream dest
int length
io.grpc.internal.CompositeReadableBuffer$ReadOperation op
public io.grpc.internal.CompositeReadableBuffer readBytes (int)
io.grpc.internal.ReadableBuffer buffer
int length
io.grpc.internal.CompositeReadableBuffer newBuffer
public void close ()
private void execute (io.grpc.internal.CompositeReadableBuffer$ReadOperation, int)
io.grpc.internal.ReadableBuffer buffer
int lengthToCopy
io.grpc.internal.CompositeReadableBuffer$ReadOperation op
int length
private void advanceBufferIfNecessary ()
io.grpc.internal.ReadableBuffer buffer
public volatile io.grpc.internal.ReadableBuffer readBytes (int)
}
io/grpc/internal/AbstractServerStream$Sink.classAbstractServerStream.java
package io.grpc.internal
public abstract io.grpc.internal.AbstractServerStream$Sink extends java.lang.Object {
public abstract void writeHeaders (io.grpc.Metadata)
public abstract void writeFrame (io.grpc.internal.WritableBuffer, boolean)
public abstract void writeTrailers (io.grpc.Metadata, boolean)
public abstract void request (int)
public abstract void cancel (io.grpc.Status)
}
io/grpc/internal/AbstractServerStream$TransportState.classAbstractServerStream.java
package io.grpc.internal
public abstract io.grpc.internal.AbstractServerStream$TransportState extends io.grpc.internal.AbstractStream2$TransportState {
private boolean listenerClosed
private io.grpc.internal.ServerStreamListener listener
protected void (int)
int maxMessageSize
public final void setListener (io.grpc.internal.ServerStreamListener)
io.grpc.internal.ServerStreamListener listener
public final void onStreamAllocated ()
public void deliveryStalled ()
public void endOfStream ()
protected io.grpc.internal.ServerStreamListener listener ()
public void inboundDataReceived (io.grpc.internal.ReadableBuffer, boolean)
io.grpc.internal.ReadableBuffer frame
boolean endOfStream
public final void transportReportStatus (io.grpc.Status)
io.grpc.Status status
public void complete ()
private void closeListener (io.grpc.Status)
io.grpc.Status newStatus
protected volatile io.grpc.internal.StreamListener listener ()
}
io/grpc/internal/AbstractServerStream.classAbstractServerStream.java
package io.grpc.internal
public abstract io.grpc.internal.AbstractServerStream extends io.grpc.internal.AbstractStream2 implements io.grpc.internal.ServerStream io.grpc.internal.MessageFramer$Sink {
private final io.grpc.internal.MessageFramer framer
private boolean outboundClosed
private boolean headersSent
protected void (io.grpc.internal.WritableBufferAllocator)
io.grpc.internal.WritableBufferAllocator bufferAllocator
protected abstract io.grpc.internal.AbstractServerStream$TransportState transportState ()
protected abstract io.grpc.internal.AbstractServerStream$Sink abstractServerStreamSink ()
protected final io.grpc.internal.MessageFramer framer ()
public final void request (int)
int numMessages
public final void writeHeaders (io.grpc.Metadata)
io.grpc.Metadata headers
public final void deliverFrame (io.grpc.internal.WritableBuffer, boolean, boolean)
io.grpc.internal.WritableBuffer frame
boolean endOfStream
boolean flush
public final void close (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
private void addStatusToTrailers (io.grpc.Metadata, io.grpc.Status)
io.grpc.Metadata trailers
io.grpc.Status status
public final void cancel (io.grpc.Status)
io.grpc.Status status
public io.grpc.Attributes attributes ()
protected volatile io.grpc.internal.AbstractStream2$TransportState transportState ()
}
io/grpc/internal/AbstractStream2$TransportState.classAbstractStream2.java
package io.grpc.internal
public abstract io.grpc.internal.AbstractStream2$TransportState extends java.lang.Object implements io.grpc.internal.MessageDeframer$Listener {
private static final int DEFAULT_ONREADY_THRESHOLD
private final io.grpc.internal.MessageDeframer deframer
private final Object onReadyLock
private int numSentBytesQueued
private boolean allocated
protected void (int)
int maxMessageSize
void (io.grpc.internal.MessageDeframer)
io.grpc.internal.MessageDeframer deframer
protected abstract io.grpc.internal.StreamListener listener ()
public void messageRead (java.io.InputStream)
java.io.InputStream is
protected abstract void deframeFailed (java.lang.Throwable)
protected final void closeDeframer ()
protected final void deframe (io.grpc.internal.ReadableBuffer, boolean)
Throwable t
io.grpc.internal.ReadableBuffer frame
boolean endOfStream
public final void requestMessagesFromDeframer (int)
Throwable t
int numMessages
private void setDecompressor (io.grpc.Decompressor)
io.grpc.Decompressor decompressor
private boolean isReady ()
protected void onStreamAllocated ()
private void onSendingBytes (int)
int numBytes
public final void onSentBytes (int)
boolean belowThresholdBefore
boolean belowThresholdAfter
int numBytes
boolean doNotify
private void notifyIfReady ()
boolean doNotify
static void access$000 (io.grpc.internal.AbstractStream2$TransportState, io.grpc.Decompressor)
io.grpc.internal.AbstractStream2$TransportState x0
io.grpc.Decompressor x1
static boolean access$100 (io.grpc.internal.AbstractStream2$TransportState)
io.grpc.internal.AbstractStream2$TransportState x0
static void access$200 (io.grpc.internal.AbstractStream2$TransportState, int)
io.grpc.internal.AbstractStream2$TransportState x0
int x1
}
io/grpc/internal/AbstractStream2.classAbstractStream2.java
package io.grpc.internal
public abstract io.grpc.internal.AbstractStream2 extends java.lang.Object implements io.grpc.internal.Stream {
public void ()
protected abstract io.grpc.internal.MessageFramer framer ()
protected abstract io.grpc.internal.AbstractStream2$TransportState transportState ()
public final void setMessageCompression (boolean)
boolean enable
public final void writeMessage (java.io.InputStream)
java.io.InputStream message
public final void flush ()
protected final void endOfMessages ()
public final void setCompressor (io.grpc.Compressor)
io.grpc.Compressor compressor
public final void setDecompressor (io.grpc.Decompressor)
io.grpc.Decompressor decompressor
public final boolean isReady ()
protected final void onSendingBytes (int)
int numBytes
}
io/grpc/internal/CallCredentialsApplyingTransportFactory$CallCredentialsApplyingTransport.classCallCredentialsApplyingTransportFactory.java
package io.grpc.internal
io.grpc.internal.CallCredentialsApplyingTransportFactory$CallCredentialsApplyingTransport extends io.grpc.internal.ForwardingConnectionClientTransport {
private final io.grpc.internal.ConnectionClientTransport delegate
private final String authority
final io.grpc.internal.CallCredentialsApplyingTransportFactory this$0
void (io.grpc.internal.CallCredentialsApplyingTransportFactory, io.grpc.internal.ConnectionClientTransport, java.lang.String)
io.grpc.internal.ConnectionClientTransport delegate
String authority
protected io.grpc.internal.ConnectionClientTransport delegate ()
public io.grpc.internal.ClientStream newStream (io.grpc.MethodDescriptor, io.grpc.Metadata, io.grpc.CallOptions)
io.grpc.internal.MetadataApplierImpl applier
io.grpc.Attributes$Builder effectiveAttrsBuilder
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
io.grpc.CallOptions callOptions
io.grpc.CallCredentials creds
}
io/grpc/internal/CallCredentialsApplyingTransportFactory.classCallCredentialsApplyingTransportFactory.java
package io.grpc.internal
final io.grpc.internal.CallCredentialsApplyingTransportFactory extends java.lang.Object implements io.grpc.internal.ClientTransportFactory {
private final io.grpc.internal.ClientTransportFactory delegate
private final java.util.concurrent.Executor appExecutor
void (io.grpc.internal.ClientTransportFactory, java.util.concurrent.Executor)
io.grpc.internal.ClientTransportFactory delegate
java.util.concurrent.Executor appExecutor
public io.grpc.internal.ConnectionClientTransport newClientTransport (java.net.SocketAddress, java.lang.String, java.lang.String)
java.net.SocketAddress serverAddress
String authority
String userAgent
public void close ()
static java.util.concurrent.Executor access$000 (io.grpc.internal.CallCredentialsApplyingTransportFactory)
io.grpc.internal.CallCredentialsApplyingTransportFactory x0
}
io/grpc/internal/ForwardingConnectionClientTransport.classForwardingConnectionClientTransport.java
package io.grpc.internal
abstract io.grpc.internal.ForwardingConnectionClientTransport extends java.lang.Object implements io.grpc.internal.ConnectionClientTransport {
void ()
public java.lang.Runnable start (io.grpc.internal.ManagedClientTransport$Listener)
io.grpc.internal.ManagedClientTransport$Listener listener
public void shutdown ()
public void shutdownNow (io.grpc.Status)
io.grpc.Status status
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 void ping (io.grpc.internal.ClientTransport$PingCallback, java.util.concurrent.Executor)
io.grpc.internal.ClientTransport$PingCallback callback
java.util.concurrent.Executor executor
public java.lang.String getLogId ()
public io.grpc.Attributes getAttrs ()
public java.lang.String toString ()
protected abstract io.grpc.internal.ConnectionClientTransport delegate ()
}
io/grpc/internal/FailingClientTransport$1.classFailingClientTransport.java
package io.grpc.internal
io.grpc.internal.FailingClientTransport$1 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.ClientTransport$PingCallback val$callback
final io.grpc.internal.FailingClientTransport this$0
void (io.grpc.internal.FailingClientTransport, io.grpc.internal.ClientTransport$PingCallback)
io.grpc.internal.FailingClientTransport this$0
public void run ()
}
io/grpc/internal/FailingClientTransport.classFailingClientTransport.java
package io.grpc.internal
io.grpc.internal.FailingClientTransport extends java.lang.Object implements io.grpc.internal.ClientTransport {
final io.grpc.Status error
void (io.grpc.Status)
io.grpc.Status error
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 void ping (io.grpc.internal.ClientTransport$PingCallback, java.util.concurrent.Executor)
io.grpc.internal.ClientTransport$PingCallback callback
java.util.concurrent.Executor executor
}
io/grpc/internal/Http2ClientStream$1.classHttp2ClientStream.java
package io.grpc.internal
final io.grpc.internal.Http2ClientStream$1 extends java.lang.Object implements io.grpc.Metadata$AsciiMarshaller {
void ()
public java.lang.String toAsciiString (java.lang.Integer)
Integer value
public java.lang.Integer parseAsciiString (java.lang.String)
String serialized
public volatile java.lang.Object parseAsciiString (java.lang.String)
public volatile java.lang.String toAsciiString (java.lang.Object)
}
io/grpc/internal/Http2ClientStream.classHttp2ClientStream.java
package io.grpc.internal
public abstract io.grpc.internal.Http2ClientStream extends io.grpc.internal.AbstractClientStream {
private static final io.grpc.Metadata$AsciiMarshaller HTTP_STATUS_LINE_MARSHALLER
private static final io.grpc.Metadata$Key HTTP2_STATUS
private io.grpc.Status transportError
private io.grpc.Metadata transportErrorMetadata
private java.nio.charset.Charset errorCharset
private boolean headersReceived
protected void (io.grpc.internal.WritableBufferAllocator, int)
io.grpc.internal.WritableBufferAllocator bufferAllocator
int maxMessageSize
protected void transportHeadersReceived (io.grpc.Metadata)
Integer httpStatus
io.grpc.Metadata headers
protected void transportDataReceived (io.grpc.internal.ReadableBuffer, boolean)
io.grpc.internal.ReadableBuffer frame
boolean endOfStream
protected void transportTrailersReceived (io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
private io.grpc.Status statusFromTrailers (io.grpc.Metadata)
io.grpc.Metadata trailers
io.grpc.Status status
Integer httpStatus
private io.grpc.Status validateInitialMetadata (io.grpc.Metadata)
io.grpc.Metadata headers
Integer httpStatus
String contentType
private static java.nio.charset.Charset extractCharset (io.grpc.Metadata)
String[] split
io.grpc.Metadata headers
String contentType
private static void stripTransportDetails (io.grpc.Metadata)
io.grpc.Metadata metadata
static void ()
}
io/grpc/internal/Http2Ping$1.classHttp2Ping.java
package io.grpc.internal
final io.grpc.internal.Http2Ping$1 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.ClientTransport$PingCallback val$callback
final long val$roundTripTimeNanos
void (io.grpc.internal.ClientTransport$PingCallback, long)
public void run ()
}
io/grpc/internal/Http2Ping$2.classHttp2Ping.java
package io.grpc.internal
final io.grpc.internal.Http2Ping$2 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.ClientTransport$PingCallback val$callback
final Throwable val$failureCause
void (io.grpc.internal.ClientTransport$PingCallback, java.lang.Throwable)
public void run ()
}
io/grpc/internal/Http2Ping.classHttp2Ping.java
package io.grpc.internal
public io.grpc.internal.Http2Ping extends java.lang.Object {
private static final java.util.logging.Logger log
private final long data
private final com.google.common.base.Stopwatch stopwatch
private java.util.Map callbacks
private boolean completed
private Throwable failureCause
private long roundTripTimeNanos
public void (long, com.google.common.base.Stopwatch)
long data
com.google.common.base.Stopwatch stopwatch
public void addCallback (io.grpc.internal.ClientTransport$PingCallback, java.util.concurrent.Executor)
io.grpc.internal.ClientTransport$PingCallback callback
java.util.concurrent.Executor executor
Runnable runnable
public long payload ()
public boolean complete ()
java.util.Map$Entry entry
java.util.Map callbacks
long roundTripTimeNanos
public void failed (java.lang.Throwable)
java.util.Map$Entry entry
Throwable failureCause
java.util.Map callbacks
public static void notifyFailed (io.grpc.internal.ClientTransport$PingCallback, java.util.concurrent.Executor, java.lang.Throwable)
io.grpc.internal.ClientTransport$PingCallback callback
java.util.concurrent.Executor executor
Throwable cause
private static void doExecute (java.util.concurrent.Executor, java.lang.Runnable)
Throwable th
java.util.concurrent.Executor executor
Runnable runnable
private static java.lang.Runnable asRunnable (io.grpc.internal.ClientTransport$PingCallback, long)
io.grpc.internal.ClientTransport$PingCallback callback
long roundTripTimeNanos
private static java.lang.Runnable asRunnable (io.grpc.internal.ClientTransport$PingCallback, java.lang.Throwable)
io.grpc.internal.ClientTransport$PingCallback callback
Throwable failureCause
static void ()
}
io/grpc/internal/LogExceptionRunnable.classLogExceptionRunnable.java
package io.grpc.internal
public final io.grpc.internal.LogExceptionRunnable extends java.lang.Object implements java.lang.Runnable {
private static final java.util.logging.Logger log
private final Runnable task
public void (java.lang.Runnable)
Runnable task
public void run ()
Throwable t
public java.lang.String toString ()
static void ()
}
io/grpc/internal/MetadataApplierImpl.classMetadataApplierImpl.java
package io.grpc.internal
final io.grpc.internal.MetadataApplierImpl extends java.lang.Object implements io.grpc.CallCredentials$MetadataApplier {
private final io.grpc.internal.ClientTransport transport
private final io.grpc.MethodDescriptor method
private final io.grpc.Metadata origHeaders
private final io.grpc.CallOptions callOptions
private final Object lock
private io.grpc.internal.ClientStream returnedStream
boolean finalized
io.grpc.internal.DelayedStream delayedStream
void (io.grpc.internal.ClientTransport, io.grpc.MethodDescriptor, io.grpc.Metadata, io.grpc.CallOptions)
io.grpc.internal.ClientTransport transport
io.grpc.MethodDescriptor method
io.grpc.Metadata origHeaders
io.grpc.CallOptions callOptions
public void apply (io.grpc.Metadata)
io.grpc.Metadata headers
public void fail (io.grpc.Status)
io.grpc.Status status
private void finalizeWith (io.grpc.internal.ClientStream)
io.grpc.internal.ClientStream stream
io.grpc.internal.ClientStream returnStream ()
}
io/grpc/internal/ReadableBuffers$1.classReadableBuffers.java
package io.grpc.internal
final io.grpc.internal.ReadableBuffers$1 extends io.grpc.internal.ForwardingReadableBuffer {
void (io.grpc.internal.ReadableBuffer)
io.grpc.internal.ReadableBuffer buf
public void close ()
}
io/grpc/internal/ReadableBuffers$ByteArrayWrapper.classReadableBuffers.java
package io.grpc.internal
io.grpc.internal.ReadableBuffers$ByteArrayWrapper extends io.grpc.internal.AbstractReadableBuffer {
int offset
final int end
final byte[] bytes
void (byte[])
byte[] bytes
void (byte[], int, int)
byte[] bytes
int offset
int length
public int readableBytes ()
public void skipBytes (int)
int length
public int readUnsignedByte ()
public void readBytes (byte[], int, int)
byte[] dest
int destIndex
int length
public void readBytes (java.nio.ByteBuffer)
java.nio.ByteBuffer dest
int length
public void readBytes (java.io.OutputStream, int) throws java.io.IOException
java.io.OutputStream dest
int length
public io.grpc.internal.ReadableBuffers$ByteArrayWrapper readBytes (int)
int length
int originalOffset
public boolean hasArray ()
public byte[] array ()
public int arrayOffset ()
public volatile io.grpc.internal.ReadableBuffer readBytes (int)
}
io/grpc/internal/ReadableBuffers$ByteReadableBufferWrapper.classReadableBuffers.java
package io.grpc.internal
io.grpc.internal.ReadableBuffers$ByteReadableBufferWrapper extends io.grpc.internal.AbstractReadableBuffer {
final java.nio.ByteBuffer bytes
void (java.nio.ByteBuffer)
java.nio.ByteBuffer bytes
public int readableBytes ()
public int readUnsignedByte ()
public void skipBytes (int)
int length
public void readBytes (byte[], int, int)
byte[] dest
int destOffset
int length
public void readBytes (java.nio.ByteBuffer)
java.nio.ByteBuffer dest
int length
int prevLimit
public void readBytes (java.io.OutputStream, int) throws java.io.IOException
byte[] array
java.io.OutputStream dest
int length
public io.grpc.internal.ReadableBuffers$ByteReadableBufferWrapper readBytes (int)
int length
java.nio.ByteBuffer buffer
public boolean hasArray ()
public byte[] array ()
public int arrayOffset ()
public volatile io.grpc.internal.ReadableBuffer readBytes (int)
}
io/grpc/internal/ReadableBuffers$BufferInputStream.classReadableBuffers.java
package io.grpc.internal
io.grpc.internal.ReadableBuffers$BufferInputStream extends java.io.InputStream implements io.grpc.KnownLength {
final io.grpc.internal.ReadableBuffer buffer
public void (io.grpc.internal.ReadableBuffer)
io.grpc.internal.ReadableBuffer buffer
public int available () throws java.io.IOException
public int read ()
public int read (byte[], int, int) throws java.io.IOException
byte[] dest
int destOffset
int length
}
io/grpc/internal/ReadableBuffers.classReadableBuffers.java
package io.grpc.internal
public final io.grpc.internal.ReadableBuffers extends java.lang.Object {
private static final io.grpc.internal.ReadableBuffer EMPTY_BUFFER
public static io.grpc.internal.ReadableBuffer empty ()
public static io.grpc.internal.ReadableBuffer wrap (byte[])
byte[] bytes
public static io.grpc.internal.ReadableBuffer wrap (byte[], int, int)
byte[] bytes
int offset
int length
public static io.grpc.internal.ReadableBuffer wrap (java.nio.ByteBuffer)
java.nio.ByteBuffer bytes
public static byte[] readArray (io.grpc.internal.ReadableBuffer)
io.grpc.internal.ReadableBuffer buffer
int length
byte[] bytes
public static java.lang.String readAsString (io.grpc.internal.ReadableBuffer, java.nio.charset.Charset)
io.grpc.internal.ReadableBuffer buffer
java.nio.charset.Charset charset
byte[] bytes
public static java.lang.String readAsStringUtf8 (io.grpc.internal.ReadableBuffer)
io.grpc.internal.ReadableBuffer buffer
public static java.io.InputStream openStream (io.grpc.internal.ReadableBuffer, boolean)
io.grpc.internal.ReadableBuffer buffer
boolean owner
public static io.grpc.internal.ReadableBuffer ignoreClose (io.grpc.internal.ReadableBuffer)
io.grpc.internal.ReadableBuffer buffer
private void ()
static void ()
}
io/grpc/internal/RoundRobinServerList$Builder.classRoundRobinServerList.java
package io.grpc.internal
public io.grpc.internal.RoundRobinServerList$Builder extends java.lang.Object {
private final com.google.common.collect.ImmutableList$Builder listBuilder
private final io.grpc.TransportManager tm
public void (io.grpc.TransportManager)
io.grpc.TransportManager tm
public void add (java.net.SocketAddress)
java.net.SocketAddress address
public void addList (java.util.List)
java.util.List addresses
public io.grpc.internal.RoundRobinServerList build ()
}
io/grpc/internal/RoundRobinServerList$1.classRoundRobinServerList.java
package io.grpc.internal
io.grpc.internal.RoundRobinServerList$1 extends java.lang.Object {
}
io/grpc/internal/RoundRobinServerList.classRoundRobinServerList.java
package io.grpc.internal
public io.grpc.internal.RoundRobinServerList extends java.lang.Object {
private final io.grpc.TransportManager tm
private final java.util.List list
private final java.util.Iterator cyclingIter
private final Object requestDroppingTransport
private void (io.grpc.TransportManager, java.util.List)
io.grpc.TransportManager tm
java.util.List list
public java.lang.Object getTransportForNextServer ()
io.grpc.EquivalentAddressGroup currentServer
public java.util.List getList ()
public int size ()
void (io.grpc.TransportManager, java.util.List, io.grpc.internal.RoundRobinServerList$1)
io.grpc.TransportManager x0
java.util.List x1
io.grpc.internal.RoundRobinServerList$1 x2
}
io/grpc/internal/ServerCallImpl$ServerStreamListenerImpl.classServerCallImpl.java
package io.grpc.internal
final io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl extends java.lang.Object implements io.grpc.internal.ServerStreamListener {
private final io.grpc.internal.ServerCallImpl call
private final io.grpc.ServerCall$Listener listener
private final io.grpc.Context$CancellableContext context
private boolean messageReceived
public void (io.grpc.internal.ServerCallImpl, io.grpc.ServerCall$Listener, io.grpc.Context$CancellableContext)
io.grpc.internal.ServerCallImpl call
io.grpc.ServerCall$Listener listener
io.grpc.Context$CancellableContext context
public void messageRead (java.io.InputStream)
java.io.IOException e
java.io.IOException e
java.io.IOException e
Throwable e
java.io.IOException e
java.io.IOException e
java.io.InputStream message
Throwable t
public void halfClosed ()
public void closed (io.grpc.Status)
io.grpc.Status status
public void onReady ()
}
io/grpc/internal/ServerCallImpl.classServerCallImpl.java
package io.grpc.internal
final io.grpc.internal.ServerCallImpl extends io.grpc.ServerCall {
private final io.grpc.internal.ServerStream stream
private final io.grpc.MethodDescriptor method
private final io.grpc.Context$CancellableContext context
private final String messageAcceptEncoding
private final io.grpc.DecompressorRegistry decompressorRegistry
private final io.grpc.CompressorRegistry compressorRegistry
private volatile boolean cancelled
private boolean sendHeadersCalled
private boolean closeCalled
private io.grpc.Compressor compressor
void (io.grpc.internal.ServerStream, io.grpc.MethodDescriptor, io.grpc.Metadata, io.grpc.Context$CancellableContext, io.grpc.DecompressorRegistry, io.grpc.CompressorRegistry)
String encoding
io.grpc.Decompressor decompressor
io.grpc.internal.ServerStream stream
io.grpc.MethodDescriptor method
io.grpc.Metadata inboundHeaders
io.grpc.Context$CancellableContext context
io.grpc.DecompressorRegistry decompressorRegistry
io.grpc.CompressorRegistry compressorRegistry
public void request (int)
int numMessages
public void sendHeaders (io.grpc.Metadata)
java.util.List acceptedEncodingsList
io.grpc.Metadata headers
String advertisedEncodings
public void sendMessage (java.lang.Object)
java.io.InputStream resp
RuntimeException e
Throwable t
Object message
public void setMessageCompression (boolean)
boolean enable
public void setCompression (java.lang.String)
String compressorName
public boolean isReady ()
public void close (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
public boolean isCancelled ()
io.grpc.internal.ServerStreamListener newServerStreamListener (io.grpc.ServerCall$Listener)
io.grpc.ServerCall$Listener listener
public io.grpc.Attributes attributes ()
public io.grpc.MethodDescriptor getMethodDescriptor ()
static boolean access$000 (io.grpc.internal.ServerCallImpl)
io.grpc.internal.ServerCallImpl x0
static io.grpc.MethodDescriptor access$100 (io.grpc.internal.ServerCallImpl)
io.grpc.internal.ServerCallImpl x0
static io.grpc.internal.ServerStream access$200 (io.grpc.internal.ServerCallImpl)
io.grpc.internal.ServerCallImpl x0
static boolean access$002 (io.grpc.internal.ServerCallImpl, boolean)
io.grpc.internal.ServerCallImpl x0
boolean x1
}
io/grpc/internal/SingleTransportChannel$1.classSingleTransportChannel.java
package io.grpc.internal
io.grpc.internal.SingleTransportChannel$1 extends java.lang.Object implements io.grpc.internal.ClientCallImpl$ClientTransportProvider {
final io.grpc.internal.SingleTransportChannel this$0
void (io.grpc.internal.SingleTransportChannel)
io.grpc.internal.SingleTransportChannel this$0
public io.grpc.internal.ClientTransport get (io.grpc.CallOptions)
io.grpc.CallOptions callOptions
}
io/grpc/internal/SingleTransportChannel.classSingleTransportChannel.java
package io.grpc.internal
final io.grpc.internal.SingleTransportChannel extends io.grpc.Channel {
private final io.grpc.internal.ClientTransport transport
private final java.util.concurrent.Executor executor
private final String authority
private final java.util.concurrent.ScheduledExecutorService deadlineCancellationExecutor
private final io.grpc.internal.ClientCallImpl$ClientTransportProvider transportProvider
public void (io.grpc.internal.ClientTransport, java.util.concurrent.Executor, java.util.concurrent.ScheduledExecutorService, java.lang.String)
io.grpc.internal.ClientTransport transport
java.util.concurrent.Executor executor
java.util.concurrent.ScheduledExecutorService deadlineCancellationExecutor
String authority
public io.grpc.ClientCall newCall (io.grpc.MethodDescriptor, io.grpc.CallOptions)
io.grpc.MethodDescriptor methodDescriptor
io.grpc.CallOptions callOptions
public java.lang.String authority ()
static io.grpc.internal.ClientTransport access$000 (io.grpc.internal.SingleTransportChannel)
io.grpc.internal.SingleTransportChannel x0
}
io/grpc/internal/TransportFrameUtil.classTransportFrameUtil.java
package io.grpc.internal
public final io.grpc.internal.TransportFrameUtil extends java.lang.Object {
private static final java.util.logging.Logger logger
private static final byte[] binaryHeaderSuffixBytes
public static byte[][] toHttp2Headers (io.grpc.Metadata)
String keyString
byte[] key
byte[] value
int i
io.grpc.Metadata headers
byte[][] serializedHeaders
int k
public static byte[][] toRawSerializedHeaders (byte[][])
byte[] key
byte[] value
int i
byte[][] http2Headers
private static boolean endsWith (byte[], byte[])
int i
byte[] subject
byte[] suffix
int start
private static boolean isSpecCompliantAscii (byte[])
byte b
byte[] subject
private void ()
static void ()
}
io/grpc/BindableService.classBindableService.java
package io.grpc
public abstract io.grpc.BindableService extends java.lang.Object {
public abstract io.grpc.ServerServiceDefinition bindService ()
}
io/grpc/ServerServiceDefinition$Builder.classServerServiceDefinition.java
package io.grpc
public final io.grpc.ServerServiceDefinition$Builder extends java.lang.Object {
private final String serviceName
private final io.grpc.ServiceDescriptor serviceDescriptor
private final java.util.Map methods
private void (java.lang.String)
String serviceName
private void (io.grpc.ServiceDescriptor)
io.grpc.ServiceDescriptor serviceDescriptor
public io.grpc.ServerServiceDefinition$Builder addMethod (io.grpc.MethodDescriptor, io.grpc.ServerCallHandler)
io.grpc.MethodDescriptor method
io.grpc.ServerCallHandler handler
public io.grpc.ServerServiceDefinition$Builder addMethod (io.grpc.ServerMethodDefinition)
io.grpc.ServerMethodDefinition def
io.grpc.MethodDescriptor method
String name
public io.grpc.ServerServiceDefinition build ()
io.grpc.ServerMethodDefinition serverMethod
java.util.List methodDescriptors
io.grpc.ServerMethodDefinition removed
io.grpc.MethodDescriptor descriptorMethod
io.grpc.ServiceDescriptor serviceDescriptor
java.util.Map tmpMethods
void (java.lang.String, io.grpc.ServerServiceDefinition$1)
String x0
io.grpc.ServerServiceDefinition$1 x1
void (io.grpc.ServiceDescriptor, io.grpc.ServerServiceDefinition$1)
io.grpc.ServiceDescriptor x0
io.grpc.ServerServiceDefinition$1 x1
}
io/grpc/ServerServiceDefinition$1.classServerServiceDefinition.java
package io.grpc
io.grpc.ServerServiceDefinition$1 extends java.lang.Object {
}
io/grpc/ServerServiceDefinition.classServerServiceDefinition.java
package io.grpc
public final io.grpc.ServerServiceDefinition extends java.lang.Object {
private final io.grpc.ServiceDescriptor serviceDescriptor
private final com.google.common.collect.ImmutableMap methods
public static io.grpc.ServerServiceDefinition$Builder builder (java.lang.String)
String serviceName
public static io.grpc.ServerServiceDefinition$Builder builder (io.grpc.ServiceDescriptor)
io.grpc.ServiceDescriptor serviceDescriptor
private void (io.grpc.ServiceDescriptor, java.util.Map)
io.grpc.ServiceDescriptor serviceDescriptor
java.util.Map methods
public io.grpc.ServiceDescriptor getServiceDescriptor ()
public java.util.Collection getMethods ()
public io.grpc.ServerMethodDefinition getMethod (java.lang.String)
String methodName
void (io.grpc.ServiceDescriptor, java.util.Map, io.grpc.ServerServiceDefinition$1)
io.grpc.ServiceDescriptor x0
java.util.Map x1
io.grpc.ServerServiceDefinition$1 x2
}
io/grpc/ServiceDescriptor.classServiceDescriptor.java
package io.grpc
public final io.grpc.ServiceDescriptor extends java.lang.Object {
private final String name
private final java.util.Collection methods
public transient void (java.lang.String, io.grpc.MethodDescriptor[])
String name
io.grpc.MethodDescriptor[] methods
public void (java.lang.String, java.util.Collection)
String name
java.util.Collection methods
public java.lang.String getName ()
public java.util.Collection getMethods ()
}
io/grpc/ServerMethodDefinition.classServerMethodDefinition.java
package io.grpc
public final io.grpc.ServerMethodDefinition extends java.lang.Object {
private final io.grpc.MethodDescriptor method
private final io.grpc.ServerCallHandler handler
private void (io.grpc.MethodDescriptor, io.grpc.ServerCallHandler)
io.grpc.MethodDescriptor method
io.grpc.ServerCallHandler handler
public static io.grpc.ServerMethodDefinition create (io.grpc.MethodDescriptor, io.grpc.ServerCallHandler)
io.grpc.MethodDescriptor method
io.grpc.ServerCallHandler handler
public io.grpc.MethodDescriptor getMethodDescriptor ()
public io.grpc.ServerCallHandler getServerCallHandler ()
public io.grpc.ServerMethodDefinition withServerCallHandler (io.grpc.ServerCallHandler)
io.grpc.ServerCallHandler handler
}
io/grpc/MethodDescriptor$MethodType.classMethodDescriptor.java
package io.grpc
public final io.grpc.MethodDescriptor$MethodType extends java.lang.Enum {
public static final io.grpc.MethodDescriptor$MethodType UNARY
public static final io.grpc.MethodDescriptor$MethodType CLIENT_STREAMING
public static final io.grpc.MethodDescriptor$MethodType SERVER_STREAMING
public static final io.grpc.MethodDescriptor$MethodType BIDI_STREAMING
public static final io.grpc.MethodDescriptor$MethodType UNKNOWN
private static final io.grpc.MethodDescriptor$MethodType[] $VALUES
public static io.grpc.MethodDescriptor$MethodType[] values ()
public static io.grpc.MethodDescriptor$MethodType valueOf (java.lang.String)
String name
private void (java.lang.String, int)
public final boolean clientSendsOneMessage ()
public final boolean serverSendsOneMessage ()
static void ()
}
io/grpc/MethodDescriptor$Marshaller.classMethodDescriptor.java
package io.grpc
public abstract io.grpc.MethodDescriptor$Marshaller extends java.lang.Object {
public abstract java.io.InputStream stream (java.lang.Object)
public abstract java.lang.Object parse (java.io.InputStream)
}
io/grpc/MethodDescriptor.classMethodDescriptor.java
package io.grpc
public io.grpc.MethodDescriptor extends java.lang.Object {
private final io.grpc.MethodDescriptor$MethodType type
private final String fullMethodName
private final io.grpc.MethodDescriptor$Marshaller requestMarshaller
private final io.grpc.MethodDescriptor$Marshaller responseMarshaller
private final boolean idempotent
public static io.grpc.MethodDescriptor create (io.grpc.MethodDescriptor$MethodType, java.lang.String, io.grpc.MethodDescriptor$Marshaller, io.grpc.MethodDescriptor$Marshaller)
io.grpc.MethodDescriptor$MethodType type
String fullMethodName
io.grpc.MethodDescriptor$Marshaller requestMarshaller
io.grpc.MethodDescriptor$Marshaller responseMarshaller
private void (io.grpc.MethodDescriptor$MethodType, java.lang.String, io.grpc.MethodDescriptor$Marshaller, io.grpc.MethodDescriptor$Marshaller, boolean)
io.grpc.MethodDescriptor$MethodType type
String fullMethodName
io.grpc.MethodDescriptor$Marshaller requestMarshaller
io.grpc.MethodDescriptor$Marshaller responseMarshaller
boolean idempotent
public io.grpc.MethodDescriptor$MethodType getType ()
public java.lang.String getFullMethodName ()
public java.lang.Object parseResponse (java.io.InputStream)
java.io.InputStream input
public java.io.InputStream streamRequest (java.lang.Object)
Object requestMessage
public java.lang.Object parseRequest (java.io.InputStream)
java.io.InputStream input
public java.io.InputStream streamResponse (java.lang.Object)
Object response
public boolean isIdempotent ()
public io.grpc.MethodDescriptor withIdempotent (boolean)
boolean idempotent
public static java.lang.String generateFullMethodName (java.lang.String, java.lang.String)
String fullServiceName
String methodName
public static java.lang.String extractFullServiceName (java.lang.String)
String fullMethodName
int index
}
io/grpc/ServerCallHandler.classServerCallHandler.java
package io.grpc
public abstract io.grpc.ServerCallHandler extends java.lang.Object {
public abstract io.grpc.ServerCall$Listener startCall (io.grpc.ServerCall, io.grpc.Metadata)
}
io/grpc/ExperimentalApi.classExperimentalApi.java
package io.grpc
public abstract io.grpc.ExperimentalApi extends java.lang.Object implements java.lang.annotation.Annotation {
public abstract java.lang.String value ()
}
io/grpc/Internal.classInternal.java
package io.grpc
public abstract io.grpc.Internal extends java.lang.Object implements java.lang.annotation.Annotation {
}
io/grpc/ServerCall$Listener.classServerCall.java
package io.grpc
public abstract io.grpc.ServerCall$Listener extends java.lang.Object {
public void ()
public void onMessage (java.lang.Object)
Object message
public void onHalfClose ()
public void onCancel ()
public void onComplete ()
public void onReady ()
}
io/grpc/ServerCall.classServerCall.java
package io.grpc
public abstract io.grpc.ServerCall extends java.lang.Object {
public static final io.grpc.Attributes$Key REMOTE_ADDR_KEY
public static final io.grpc.Attributes$Key SSL_SESSION_KEY
public void ()
public abstract void request (int)
public abstract void sendHeaders (io.grpc.Metadata)
public abstract void sendMessage (java.lang.Object)
public boolean isReady ()
public abstract void close (io.grpc.Status, io.grpc.Metadata)
public abstract boolean isCancelled ()
public void setMessageCompression (boolean)
boolean enabled
public void setCompression (java.lang.String)
String compressor
public io.grpc.Attributes attributes ()
public abstract io.grpc.MethodDescriptor getMethodDescriptor ()
static void ()
}
io/grpc/Metadata$1.classMetadata.java
package io.grpc
final io.grpc.Metadata$1 extends java.lang.Object implements io.grpc.Metadata$BinaryMarshaller {
void ()
public byte[] toBytes (byte[])
byte[] value
public byte[] parseBytes (byte[])
byte[] serialized
public volatile java.lang.Object parseBytes (byte[])
public volatile byte[] toBytes (java.lang.Object)
}
io/grpc/Metadata$2.classMetadata.java
package io.grpc
final io.grpc.Metadata$2 extends java.lang.Object implements io.grpc.Metadata$AsciiMarshaller {
void ()
public java.lang.String toAsciiString (java.lang.String)
String value
public java.lang.String parseAsciiString (java.lang.String)
String serialized
public volatile java.lang.Object parseAsciiString (java.lang.String)
public volatile java.lang.String toAsciiString (java.lang.Object)
}
io/grpc/Metadata$3.classMetadata.java
package io.grpc
final io.grpc.Metadata$3 extends java.lang.Object implements io.grpc.Metadata$AsciiMarshaller {
void ()
public java.lang.String toAsciiString (java.lang.Integer)
Integer value
public java.lang.Integer parseAsciiString (java.lang.String)
String serialized
public volatile java.lang.Object parseAsciiString (java.lang.String)
public volatile java.lang.String toAsciiString (java.lang.Object)
}
io/grpc/Metadata$4.classMetadata.java
package io.grpc
io.grpc.Metadata$4 extends java.lang.Object implements com.google.common.base.Function {
final io.grpc.Metadata$Key val$key
final io.grpc.Metadata this$0
void (io.grpc.Metadata, io.grpc.Metadata$Key)
io.grpc.Metadata this$0
public java.lang.Object apply (io.grpc.Metadata$MetadataEntry)
io.grpc.Metadata$MetadataEntry entry
public volatile java.lang.Object apply (java.lang.Object)
}
io/grpc/Metadata$5.classMetadata.java
package io.grpc
io.grpc.Metadata$5 extends java.lang.Object implements com.google.common.base.Function {
final io.grpc.Metadata$Key val$key
final io.grpc.Metadata this$0
void (io.grpc.Metadata, io.grpc.Metadata$Key)
io.grpc.Metadata this$0
public java.lang.Object apply (io.grpc.Metadata$MetadataEntry)
io.grpc.Metadata$MetadataEntry metadataEntry
public volatile java.lang.Object apply (java.lang.Object)
}
io/grpc/Metadata$BinaryMarshaller.classMetadata.java
package io.grpc
public abstract io.grpc.Metadata$BinaryMarshaller extends java.lang.Object {
public abstract byte[] toBytes (java.lang.Object)
public abstract java.lang.Object parseBytes (byte[])
}
io/grpc/Metadata$AsciiMarshaller.classMetadata.java
package io.grpc
public abstract io.grpc.Metadata$AsciiMarshaller extends java.lang.Object {
public abstract java.lang.String toAsciiString (java.lang.Object)
public abstract java.lang.Object parseAsciiString (java.lang.String)
}
io/grpc/Metadata$Key.classMetadata.java
package io.grpc
public abstract io.grpc.Metadata$Key extends java.lang.Object {
private static final java.util.BitSet VALID_T_CHARS
private final String originalName
private final String name
private final byte[] nameBytes
public static io.grpc.Metadata$Key of (java.lang.String, io.grpc.Metadata$BinaryMarshaller)
String name
io.grpc.Metadata$BinaryMarshaller marshaller
public static io.grpc.Metadata$Key of (java.lang.String, io.grpc.Metadata$AsciiMarshaller)
String name
io.grpc.Metadata$AsciiMarshaller marshaller
private static java.util.BitSet generateValidTChars ()
char c
char c
java.util.BitSet valid
private static java.lang.String validateName (java.lang.String)
char tChar
int i
String n
private void (java.lang.String)
String name
public final java.lang.String originalName ()
public final java.lang.String name ()
byte[] asciiName ()
public boolean equals (java.lang.Object)
Object o
io.grpc.Metadata$Key key
public int hashCode ()
public java.lang.String toString ()
abstract byte[] toBytes (java.lang.Object)
abstract java.lang.Object parseBytes (byte[])
static java.lang.String access$100 (io.grpc.Metadata$Key)
io.grpc.Metadata$Key x0
void (java.lang.String, io.grpc.Metadata$1)
String x0
io.grpc.Metadata$1 x1
static void ()
}
io/grpc/Metadata$BinaryKey.classMetadata.java
package io.grpc
io.grpc.Metadata$BinaryKey extends io.grpc.Metadata$Key {
private final io.grpc.Metadata$BinaryMarshaller marshaller
private void (java.lang.String, io.grpc.Metadata$BinaryMarshaller)
String name
io.grpc.Metadata$BinaryMarshaller marshaller
byte[] toBytes (java.lang.Object)
Object value
java.lang.Object parseBytes (byte[])
byte[] serialized
void (java.lang.String, io.grpc.Metadata$BinaryMarshaller, io.grpc.Metadata$1)
String x0
io.grpc.Metadata$BinaryMarshaller x1
io.grpc.Metadata$1 x2
}
io/grpc/Metadata$AsciiKey.classMetadata.java
package io.grpc
io.grpc.Metadata$AsciiKey extends io.grpc.Metadata$Key {
private final io.grpc.Metadata$AsciiMarshaller marshaller
private void (java.lang.String, io.grpc.Metadata$AsciiMarshaller)
String name
io.grpc.Metadata$AsciiMarshaller marshaller
byte[] toBytes (java.lang.Object)
Object value
java.lang.Object parseBytes (byte[])
byte[] serialized
void (java.lang.String, io.grpc.Metadata$AsciiMarshaller, io.grpc.Metadata$1)
String x0
io.grpc.Metadata$AsciiMarshaller x1
io.grpc.Metadata$1 x2
}
io/grpc/Metadata$MetadataEntry.classMetadata.java
package io.grpc
io.grpc.Metadata$MetadataEntry extends java.lang.Object {
Object parsed
io.grpc.Metadata$Key key
boolean isBinary
byte[] serializedBinary
private void (io.grpc.Metadata$Key, java.lang.Object)
io.grpc.Metadata$Key key
Object parsed
private void (boolean, byte[])
boolean isBinary
byte[] serialized
private void (io.grpc.Metadata$MetadataEntry)
io.grpc.Metadata$MetadataEntry entry
public java.lang.Object getParsed (io.grpc.Metadata$Key)
io.grpc.Metadata$Key key
Object value
public byte[] getSerialized ()
public java.lang.String toString ()
void (boolean, byte[], io.grpc.Metadata$1)
boolean x0
byte[] x1
io.grpc.Metadata$1 x2
void (io.grpc.Metadata$Key, java.lang.Object, io.grpc.Metadata$1)
io.grpc.Metadata$Key x0
Object x1
io.grpc.Metadata$1 x2
void (io.grpc.Metadata$MetadataEntry, io.grpc.Metadata$1)
io.grpc.Metadata$MetadataEntry x0
io.grpc.Metadata$1 x1
}
io/grpc/Metadata.classMetadata.java
package io.grpc
public final io.grpc.Metadata extends java.lang.Object {
public static final String BINARY_HEADER_SUFFIX
public static final io.grpc.Metadata$BinaryMarshaller BINARY_BYTE_MARSHALLER
public static final io.grpc.Metadata$AsciiMarshaller ASCII_STRING_MARSHALLER
static final io.grpc.Metadata$AsciiMarshaller INTEGER_MARSHALLER
private final java.util.Map store
private int storeCount
public transient void (byte[][])
String name
int i
byte[][] binaryValues
public void ()
private void storeAdd (java.lang.String, io.grpc.Metadata$MetadataEntry)
String name
io.grpc.Metadata$MetadataEntry value
java.util.List values
public int headerCount ()
public boolean containsKey (io.grpc.Metadata$Key)
io.grpc.Metadata$Key key
public java.lang.Object get (io.grpc.Metadata$Key)
io.grpc.Metadata$Key key
java.util.List values
io.grpc.Metadata$MetadataEntry metadataEntry
public java.lang.Iterable getAll (io.grpc.Metadata$Key)
io.grpc.Metadata$Key key
public java.util.Set keys ()
public void put (io.grpc.Metadata$Key, java.lang.Object)
io.grpc.Metadata$Key key
Object value
public boolean remove (io.grpc.Metadata$Key, java.lang.Object)
io.grpc.Metadata$MetadataEntry entry
int i
io.grpc.Metadata$Key key
Object value
java.util.List values
public java.lang.Iterable removeAll (io.grpc.Metadata$Key)
io.grpc.Metadata$Key key
java.util.List values
public byte[][] serialize ()
int k
java.util.List values
java.util.Map$Entry storeEntry
byte[][] serialized
int i
public void merge (io.grpc.Metadata)
int i
java.util.Map$Entry keyEntry
io.grpc.Metadata other
public void merge (io.grpc.Metadata, java.util.Set)
int i
java.util.List values
io.grpc.Metadata$Key key
io.grpc.Metadata other
java.util.Set keys
public java.lang.String toString ()
private java.lang.String toStringInternal ()
static void ()
}
io/grpc/Attributes$Key.classAttributes.java
package io.grpc
public final io.grpc.Attributes$Key extends java.lang.Object {
private final String name
private void (java.lang.String)
String name
public java.lang.String toString ()
public static io.grpc.Attributes$Key of (java.lang.String)
String name
}
io/grpc/Attributes$Builder.classAttributes.java
package io.grpc
public final io.grpc.Attributes$Builder extends java.lang.Object {
private io.grpc.Attributes product
private void ()
public io.grpc.Attributes$Builder set (io.grpc.Attributes$Key, java.lang.Object)
io.grpc.Attributes$Key key
Object value
public io.grpc.Attributes$Builder setAll (io.grpc.Attributes)
io.grpc.Attributes other
public io.grpc.Attributes build ()
io.grpc.Attributes result
void (io.grpc.Attributes$1)
io.grpc.Attributes$1 x0
}
io/grpc/Attributes$1.classAttributes.java
package io.grpc
io.grpc.Attributes$1 extends java.lang.Object {
}
io/grpc/Attributes.classAttributes.java
package io.grpc
public final io.grpc.Attributes extends java.lang.Object {
private final java.util.HashMap data
public static final io.grpc.Attributes EMPTY
private void ()
public java.lang.Object get (io.grpc.Attributes$Key)
io.grpc.Attributes$Key key
public java.util.Set keys ()
public static io.grpc.Attributes$Builder newBuilder ()
public java.lang.String toString ()
void (io.grpc.Attributes$1)
io.grpc.Attributes$1 x0
static java.util.HashMap access$200 (io.grpc.Attributes)
io.grpc.Attributes x0
static void ()
}
io/grpc/Status$Code.classStatus.java
package io.grpc
public final io.grpc.Status$Code extends java.lang.Enum {
public static final io.grpc.Status$Code OK
public static final io.grpc.Status$Code CANCELLED
public static final io.grpc.Status$Code UNKNOWN
public static final io.grpc.Status$Code INVALID_ARGUMENT
public static final io.grpc.Status$Code DEADLINE_EXCEEDED
public static final io.grpc.Status$Code NOT_FOUND
public static final io.grpc.Status$Code ALREADY_EXISTS
public static final io.grpc.Status$Code PERMISSION_DENIED
public static final io.grpc.Status$Code RESOURCE_EXHAUSTED
public static final io.grpc.Status$Code FAILED_PRECONDITION
public static final io.grpc.Status$Code ABORTED
public static final io.grpc.Status$Code OUT_OF_RANGE
public static final io.grpc.Status$Code UNIMPLEMENTED
public static final io.grpc.Status$Code INTERNAL
public static final io.grpc.Status$Code UNAVAILABLE
public static final io.grpc.Status$Code DATA_LOSS
public static final io.grpc.Status$Code UNAUTHENTICATED
private final int value
private final String valueAscii
private static final io.grpc.Status$Code[] $VALUES
public static io.grpc.Status$Code[] values ()
public static io.grpc.Status$Code valueOf (java.lang.String)
String name
private void (java.lang.String, int, int)
int value
public int value ()
public io.grpc.Status toStatus ()
private java.lang.String valueAscii ()
static java.lang.String access$200 (io.grpc.Status$Code)
io.grpc.Status$Code x0
static void ()
}
io/grpc/Status$1.classStatus.java
package io.grpc
final io.grpc.Status$1 extends java.lang.Object implements io.grpc.Metadata$AsciiMarshaller {
void ()
public java.lang.String toAsciiString (java.lang.String)
byte b
String value
StringBuilder sb
public java.lang.String parseAsciiString (java.lang.String)
int i
String value
java.nio.charset.Charset transerEncoding
byte[] source
java.nio.ByteBuffer buf
public volatile java.lang.Object parseAsciiString (java.lang.String)
public volatile java.lang.String toAsciiString (java.lang.Object)
}
io/grpc/Status$StatusCodeMarshaller.classStatus.java
package io.grpc
io.grpc.Status$StatusCodeMarshaller extends java.lang.Object implements io.grpc.Metadata$AsciiMarshaller {
private void ()
public java.lang.String toAsciiString (io.grpc.Status)
io.grpc.Status status
public io.grpc.Status parseAsciiString (java.lang.String)
String serialized
public volatile java.lang.Object parseAsciiString (java.lang.String)
public volatile java.lang.String toAsciiString (java.lang.Object)
void (io.grpc.Status$1)
io.grpc.Status$1 x0
}
io/grpc/Status.classStatus.java
package io.grpc
public final io.grpc.Status extends java.lang.Object {
private static final java.util.List STATUS_LIST
public static final io.grpc.Status OK
public static final io.grpc.Status CANCELLED
public static final io.grpc.Status UNKNOWN
public static final io.grpc.Status INVALID_ARGUMENT
public static final io.grpc.Status DEADLINE_EXCEEDED
public static final io.grpc.Status NOT_FOUND
public static final io.grpc.Status ALREADY_EXISTS
public static final io.grpc.Status PERMISSION_DENIED
public static final io.grpc.Status UNAUTHENTICATED
public static final io.grpc.Status RESOURCE_EXHAUSTED
public static final io.grpc.Status FAILED_PRECONDITION
public static final io.grpc.Status ABORTED
public static final io.grpc.Status OUT_OF_RANGE
public static final io.grpc.Status UNIMPLEMENTED
public static final io.grpc.Status INTERNAL
public static final io.grpc.Status UNAVAILABLE
public static final io.grpc.Status DATA_LOSS
public static final io.grpc.Metadata$Key CODE_KEY
private static final io.grpc.Metadata$AsciiMarshaller STATUS_MESSAGE_MARSHALLER
public static final io.grpc.Metadata$Key MESSAGE_KEY
private final io.grpc.Status$Code code
private final String description
private final Throwable cause
private static java.util.List buildStatusList ()
io.grpc.Status replaced
io.grpc.Status$Code code
java.util.TreeMap canonicalizer
public static io.grpc.Status fromCodeValue (int)
int codeValue
public static io.grpc.Status fromCode (io.grpc.Status$Code)
io.grpc.Status$Code code
public static io.grpc.Status fromThrowable (java.lang.Throwable)
Throwable t
Throwable cause
public static io.grpc.Metadata trailersFromThrowable (java.lang.Throwable)
Throwable t
Throwable cause
static java.lang.String formatThrowableMessage (io.grpc.Status)
io.grpc.Status status
private void (io.grpc.Status$Code)
io.grpc.Status$Code code
private void (io.grpc.Status$Code, java.lang.String, java.lang.Throwable)
io.grpc.Status$Code code
String description
Throwable cause
public io.grpc.Status withCause (java.lang.Throwable)
Throwable cause
public io.grpc.Status withDescription (java.lang.String)
String description
public io.grpc.Status augmentDescription (java.lang.String)
String additionalDetail
public io.grpc.Status$Code getCode ()
public java.lang.String getDescription ()
public java.lang.Throwable getCause ()
public boolean isOk ()
public io.grpc.StatusRuntimeException asRuntimeException ()
public io.grpc.StatusRuntimeException asRuntimeException (io.grpc.Metadata)
io.grpc.Metadata trailers
public io.grpc.StatusException asException ()
public io.grpc.StatusException asException (io.grpc.Metadata)
io.grpc.Metadata trailers
public java.lang.String toString ()
public boolean equals (java.lang.Object)
Object obj
public int hashCode ()
static java.util.List access$000 ()
static void ()
}
io/grpc/StatusRuntimeException.classStatusRuntimeException.java
package io.grpc
public io.grpc.StatusRuntimeException extends java.lang.RuntimeException {
private static final long serialVersionUID
private final io.grpc.Status status
private final io.grpc.Metadata trailers
public void (io.grpc.Status)
io.grpc.Status status
public void (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
public final io.grpc.Status getStatus ()
public final io.grpc.Metadata getTrailers ()
}
io/grpc/StatusException.classStatusException.java
package io.grpc
public io.grpc.StatusException extends java.lang.Exception {
private static final long serialVersionUID
private final io.grpc.Status status
private final io.grpc.Metadata trailers
public void (io.grpc.Status)
io.grpc.Status status
public void (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
public final io.grpc.Status getStatus ()
public final io.grpc.Metadata getTrailers ()
}
io/grpc/Channel.classChannel.java
package io.grpc
public abstract io.grpc.Channel extends java.lang.Object {
public void ()
public abstract io.grpc.ClientCall newCall (io.grpc.MethodDescriptor, io.grpc.CallOptions)
public abstract java.lang.String authority ()
}
io/grpc/CallOptions$Key.classCallOptions.java
package io.grpc
public final io.grpc.CallOptions$Key extends java.lang.Object {
private final String name
private final Object defaultValue
private void (java.lang.String, java.lang.Object)
String name
Object defaultValue
public java.lang.Object getDefault ()
public java.lang.String toString ()
public static io.grpc.CallOptions$Key of (java.lang.String, java.lang.Object)
String name
Object defaultValue
static java.lang.Object access$000 (io.grpc.CallOptions$Key)
io.grpc.CallOptions$Key x0
}
io/grpc/CallOptions.classCallOptions.java
package io.grpc
public final io.grpc.CallOptions extends java.lang.Object {
public static final io.grpc.CallOptions DEFAULT
private io.grpc.Deadline deadline
private java.util.concurrent.Executor executor
private String authority
private io.grpc.CallCredentials credentials
private io.grpc.Attributes affinity
private String compressorName
private Object[][] customOptions
private boolean waitForReady
public io.grpc.CallOptions withAuthority (java.lang.String)
String authority
io.grpc.CallOptions newOptions
public io.grpc.CallOptions withCallCredentials (io.grpc.CallCredentials)
io.grpc.CallCredentials credentials
io.grpc.CallOptions newOptions
public io.grpc.CallOptions withCompression (java.lang.String)
String compressorName
io.grpc.CallOptions newOptions
public io.grpc.CallOptions withDeadline (io.grpc.Deadline)
io.grpc.Deadline deadline
io.grpc.CallOptions newOptions
public io.grpc.CallOptions withDeadlineNanoTime (java.lang.Long)
Long deadlineNanoTime
io.grpc.Deadline deadline
public io.grpc.CallOptions withDeadlineAfter (long, java.util.concurrent.TimeUnit)
long duration
java.util.concurrent.TimeUnit unit
public java.lang.Long getDeadlineNanoTime ()
public io.grpc.Deadline getDeadline ()
public io.grpc.CallOptions withAffinity (io.grpc.Attributes)
io.grpc.Attributes affinity
io.grpc.CallOptions newOptions
public io.grpc.CallOptions withWaitForReady ()
io.grpc.CallOptions newOptions
public io.grpc.CallOptions withoutWaitForReady ()
io.grpc.CallOptions newOptions
public io.grpc.Attributes getAffinity ()
public java.lang.String getCompressor ()
public java.lang.String getAuthority ()
public io.grpc.CallCredentials getCredentials ()
public io.grpc.CallOptions withExecutor (java.util.concurrent.Executor)
java.util.concurrent.Executor executor
io.grpc.CallOptions newOptions
public io.grpc.CallOptions withOption (io.grpc.CallOptions$Key, java.lang.Object)
int i
io.grpc.CallOptions$Key key
Object value
io.grpc.CallOptions newOptions
int existingIdx
public java.lang.Object getOption (io.grpc.CallOptions$Key)
int i
io.grpc.CallOptions$Key key
public java.util.concurrent.Executor getExecutor ()
private void ()
public boolean isWaitForReady ()
private void (io.grpc.CallOptions)
io.grpc.CallOptions other
public java.lang.String toString ()
com.google.common.base.MoreObjects$ToStringHelper toStringHelper
static void ()
}
io/grpc/ClientCall$Listener.classClientCall.java
package io.grpc
public abstract io.grpc.ClientCall$Listener extends java.lang.Object {
public void ()
public void onHeaders (io.grpc.Metadata)
io.grpc.Metadata headers
public void onMessage (java.lang.Object)
Object message
public void onClose (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
public void onReady ()
}
io/grpc/ClientCall.classClientCall.java
package io.grpc
public abstract io.grpc.ClientCall extends java.lang.Object {
public void ()
public abstract void start (io.grpc.ClientCall$Listener, io.grpc.Metadata)
public abstract void request (int)
public abstract void cancel (java.lang.String, java.lang.Throwable)
public abstract void halfClose ()
public abstract void sendMessage (java.lang.Object)
public boolean isReady ()
public void setMessageCompression (boolean)
boolean enabled
}
io/grpc/CallCredentials$MetadataApplier.classCallCredentials.java
package io.grpc
public abstract io.grpc.CallCredentials$MetadataApplier extends java.lang.Object {
public abstract void apply (io.grpc.Metadata)
public abstract void fail (io.grpc.Status)
}
io/grpc/CallCredentials.classCallCredentials.java
package io.grpc
public abstract io.grpc.CallCredentials extends java.lang.Object {
public static final io.grpc.Attributes$Key ATTR_SECURITY_LEVEL
public static final io.grpc.Attributes$Key ATTR_AUTHORITY
public abstract void applyRequestMetadata (io.grpc.MethodDescriptor, io.grpc.Attributes, java.util.concurrent.Executor, io.grpc.CallCredentials$MetadataApplier)
static void ()
}
io/grpc/SecurityLevel.classSecurityLevel.java
package io.grpc
public final io.grpc.SecurityLevel extends java.lang.Enum {
public static final io.grpc.SecurityLevel NONE
public static final io.grpc.SecurityLevel INTEGRITY
public static final io.grpc.SecurityLevel PRIVACY_AND_INTEGRITY
private static final io.grpc.SecurityLevel[] $VALUES
public static io.grpc.SecurityLevel[] values ()
public static io.grpc.SecurityLevel valueOf (java.lang.String)
String name
private void (java.lang.String, int)
static void ()
}
io/grpc/ClientInterceptor.classClientInterceptor.java
package io.grpc
public abstract io.grpc.ClientInterceptor extends java.lang.Object {
public abstract io.grpc.ClientCall interceptCall (io.grpc.MethodDescriptor, io.grpc.CallOptions, io.grpc.Channel)
}
io/grpc/Codec$Gzip.classCodec.java
package io.grpc
public final io.grpc.Codec$Gzip extends java.lang.Object implements io.grpc.Codec {
public void ()
public java.lang.String getMessageEncoding ()
public java.io.OutputStream compress (java.io.OutputStream) throws java.io.IOException
java.io.OutputStream os
public java.io.InputStream decompress (java.io.InputStream) throws java.io.IOException
java.io.InputStream is
}
io/grpc/Codec$Identity.classCodec.java
package io.grpc
public final io.grpc.Codec$Identity extends java.lang.Object implements io.grpc.Codec {
public static final io.grpc.Codec NONE
public java.io.InputStream decompress (java.io.InputStream) throws java.io.IOException
java.io.InputStream is
public java.lang.String getMessageEncoding ()
public java.io.OutputStream compress (java.io.OutputStream) throws java.io.IOException
java.io.OutputStream os
private void ()
static void ()
}
io/grpc/Codec.classCodec.java
package io.grpc
public abstract io.grpc.Codec extends java.lang.Object implements io.grpc.Compressor io.grpc.Decompressor {
}
io/grpc/Compressor.classCompressor.java
package io.grpc
public abstract io.grpc.Compressor extends java.lang.Object {
public abstract java.lang.String getMessageEncoding ()
public abstract java.io.OutputStream compress (java.io.OutputStream) throws java.io.IOException
}
io/grpc/Decompressor.classDecompressor.java
package io.grpc
public abstract io.grpc.Decompressor extends java.lang.Object {
public abstract java.lang.String getMessageEncoding ()
public abstract java.io.InputStream decompress (java.io.InputStream) throws java.io.IOException
}
io/grpc/CompressorRegistry.classCompressorRegistry.java
package io.grpc
public final io.grpc.CompressorRegistry extends java.lang.Object {
private static final io.grpc.CompressorRegistry DEFAULT_INSTANCE
private final java.util.concurrent.ConcurrentMap compressors
public static io.grpc.CompressorRegistry getDefaultInstance ()
public static io.grpc.CompressorRegistry newEmptyInstance ()
transient void (io.grpc.Compressor[])
io.grpc.Compressor c
io.grpc.Compressor[] cs
public io.grpc.Compressor lookupCompressor (java.lang.String)
String compressorName
public void register (io.grpc.Compressor)
io.grpc.Compressor c
String encoding
static void ()
}
io/grpc/Contexts$ContextualizedServerCallListener.classContexts.java
package io.grpc
io.grpc.Contexts$ContextualizedServerCallListener extends io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener {
private final io.grpc.Context context
public void (io.grpc.ServerCall$Listener, io.grpc.Context)
io.grpc.ServerCall$Listener delegate
io.grpc.Context context
public void onMessage (java.lang.Object)
Object message
io.grpc.Context previous
public void onHalfClose ()
io.grpc.Context previous
public void onCancel ()
io.grpc.Context previous
public void onComplete ()
io.grpc.Context previous
public void onReady ()
io.grpc.Context previous
}
io/grpc/Contexts.classContexts.java
package io.grpc
public io.grpc.Contexts extends java.lang.Object {
private void ()
public static io.grpc.ServerCall$Listener interceptCall (io.grpc.Context, io.grpc.ServerCall, io.grpc.Metadata, io.grpc.ServerCallHandler)
io.grpc.Context context
io.grpc.ServerCall call
io.grpc.Metadata headers
io.grpc.ServerCallHandler next
io.grpc.Context previous
public static io.grpc.Status statusFromCancelled (io.grpc.Context)
io.grpc.Context context
Throwable cancellationCause
io.grpc.Status status
}
io/grpc/ForwardingServerCallListener$SimpleForwardingServerCallListener.classForwardingServerCallListener.java
package io.grpc
public abstract io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener extends io.grpc.ForwardingServerCallListener {
private final io.grpc.ServerCall$Listener delegate
protected void (io.grpc.ServerCall$Listener)
io.grpc.ServerCall$Listener delegate
protected io.grpc.ServerCall$Listener delegate ()
public volatile void onReady ()
public volatile void onComplete ()
public volatile void onCancel ()
public volatile void onHalfClose ()
}
io/grpc/ForwardingServerCallListener.classForwardingServerCallListener.java
package io.grpc
public abstract io.grpc.ForwardingServerCallListener extends io.grpc.PartialForwardingServerCallListener {
public void ()
protected abstract io.grpc.ServerCall$Listener delegate ()
public void onMessage (java.lang.Object)
Object message
public volatile void onReady ()
public volatile void onComplete ()
public volatile void onCancel ()
public volatile void onHalfClose ()
}
io/grpc/PartialForwardingServerCallListener.classPartialForwardingServerCallListener.java
package io.grpc
abstract io.grpc.PartialForwardingServerCallListener extends io.grpc.ServerCall$Listener {
void ()
protected abstract io.grpc.ServerCall$Listener delegate ()
public void onHalfClose ()
public void onCancel ()
public void onComplete ()
public void onReady ()
}
io/grpc/Drainable.classDrainable.java
package io.grpc
public abstract io.grpc.Drainable extends java.lang.Object {
public abstract int drainTo (java.io.OutputStream) throws java.io.IOException
}
io/grpc/ForwardingClientCall$SimpleForwardingClientCall.classForwardingClientCall.java
package io.grpc
public abstract io.grpc.ForwardingClientCall$SimpleForwardingClientCall extends io.grpc.ForwardingClientCall {
private final io.grpc.ClientCall delegate
protected void (io.grpc.ClientCall)
io.grpc.ClientCall delegate
protected io.grpc.ClientCall delegate ()
}
io/grpc/ForwardingClientCall.classForwardingClientCall.java
package io.grpc
public abstract io.grpc.ForwardingClientCall extends io.grpc.ClientCall {
public void ()
protected abstract io.grpc.ClientCall delegate ()
public void start (io.grpc.ClientCall$Listener, io.grpc.Metadata)
io.grpc.ClientCall$Listener responseListener
io.grpc.Metadata headers
public void request (int)
int numMessages
public void cancel (java.lang.String, java.lang.Throwable)
String message
Throwable cause
public void halfClose ()
public void sendMessage (java.lang.Object)
Object message
public void setMessageCompression (boolean)
boolean enabled
public boolean isReady ()
}
io/grpc/ForwardingClientCallListener$SimpleForwardingClientCallListener.classForwardingClientCallListener.java
package io.grpc
public abstract io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener extends io.grpc.ForwardingClientCallListener {
private final io.grpc.ClientCall$Listener delegate
protected void (io.grpc.ClientCall$Listener)
io.grpc.ClientCall$Listener delegate
protected io.grpc.ClientCall$Listener delegate ()
}
io/grpc/ForwardingClientCallListener.classForwardingClientCallListener.java
package io.grpc
public abstract io.grpc.ForwardingClientCallListener extends io.grpc.ClientCall$Listener {
public void ()
protected abstract io.grpc.ClientCall$Listener delegate ()
public void onHeaders (io.grpc.Metadata)
io.grpc.Metadata headers
public void onMessage (java.lang.Object)
Object message
public void onClose (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
public void onReady ()
}
io/grpc/ForwardingServerCall$SimpleForwardingServerCall.classForwardingServerCall.java
package io.grpc
public abstract io.grpc.ForwardingServerCall$SimpleForwardingServerCall extends io.grpc.ForwardingServerCall {
private final io.grpc.ServerCall delegate
protected void (io.grpc.ServerCall)
io.grpc.ServerCall delegate
protected io.grpc.ServerCall delegate ()
public io.grpc.MethodDescriptor getMethodDescriptor ()
public volatile io.grpc.Attributes attributes ()
public volatile void setCompression (java.lang.String)
public volatile void setMessageCompression (boolean)
public volatile boolean isCancelled ()
public volatile void close (io.grpc.Status, io.grpc.Metadata)
public volatile boolean isReady ()
public volatile void sendHeaders (io.grpc.Metadata)
public volatile void request (int)
}
io/grpc/ForwardingServerCall.classForwardingServerCall.java
package io.grpc
public abstract io.grpc.ForwardingServerCall extends io.grpc.PartialForwardingServerCall {
public void ()
protected abstract io.grpc.ServerCall delegate ()
public void sendMessage (java.lang.Object)
Object message
public volatile io.grpc.Attributes attributes ()
public volatile void setCompression (java.lang.String)
public volatile void setMessageCompression (boolean)
public volatile boolean isCancelled ()
public volatile void close (io.grpc.Status, io.grpc.Metadata)
public volatile boolean isReady ()
public volatile void sendHeaders (io.grpc.Metadata)
public volatile void request (int)
}
io/grpc/PartialForwardingServerCall.classPartialForwardingServerCall.java
package io.grpc
abstract io.grpc.PartialForwardingServerCall extends io.grpc.ServerCall {
void ()
protected abstract io.grpc.ServerCall delegate ()
public void request (int)
int numMessages
public void sendHeaders (io.grpc.Metadata)
io.grpc.Metadata headers
public boolean isReady ()
public void close (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
public boolean isCancelled ()
public void setMessageCompression (boolean)
boolean enabled
public void setCompression (java.lang.String)
String compressor
public io.grpc.Attributes attributes ()
}
io/grpc/KnownLength.classKnownLength.java
package io.grpc
public abstract io.grpc.KnownLength extends java.lang.Object {
public abstract int available () throws java.io.IOException
}
io/grpc/ServerInterceptor.classServerInterceptor.java
package io.grpc
public abstract io.grpc.ServerInterceptor extends java.lang.Object {
public abstract io.grpc.ServerCall$Listener interceptCall (io.grpc.ServerCall, io.grpc.Metadata, io.grpc.ServerCallHandler)
}
io/grpc/ManagedChannelProvider$1.classManagedChannelProvider.java
package io.grpc
final io.grpc.ManagedChannelProvider$1 extends java.lang.Object implements java.util.Comparator {
void ()
public int compare (io.grpc.ManagedChannelProvider, io.grpc.ManagedChannelProvider)
io.grpc.ManagedChannelProvider f1
io.grpc.ManagedChannelProvider f2
public volatile int compare (java.lang.Object, java.lang.Object)
}
io/grpc/ManagedChannelProvider$ProviderNotFoundException.classManagedChannelProvider.java
package io.grpc
public final io.grpc.ManagedChannelProvider$ProviderNotFoundException extends java.lang.RuntimeException {
private static final long serialVersionUID
public void (java.lang.String)
String msg
}
io/grpc/ManagedChannelProvider.classManagedChannelProvider.java
package io.grpc
public abstract io.grpc.ManagedChannelProvider extends java.lang.Object {
private static final io.grpc.ManagedChannelProvider provider
public void ()
static io.grpc.ManagedChannelProvider load (java.lang.ClassLoader)
Iterable candidates
io.grpc.ManagedChannelProvider current
ClassLoader classLoader
Iterable candidates
java.util.List list
public static java.lang.Iterable getCandidatesViaServiceLoader (java.lang.ClassLoader)
ClassLoader classLoader
public static java.lang.Iterable getCandidatesViaHardCoded (java.lang.ClassLoader)
ClassLoader classLoader
java.util.List list
static io.grpc.ManagedChannelProvider create (java.lang.Class)
Throwable t
Class rawClass
public static io.grpc.ManagedChannelProvider provider ()
private static java.lang.ClassLoader getCorrectClassLoader ()
protected static boolean isAndroid ()
Exception e
protected abstract boolean isAvailable ()
protected abstract int priority ()
protected abstract io.grpc.ManagedChannelBuilder builderForAddress (java.lang.String, int)
protected abstract io.grpc.ManagedChannelBuilder builderForTarget (java.lang.String)
static void ()
}
io/grpc/ServerProvider.classServerProvider.java
package io.grpc
public abstract io.grpc.ServerProvider extends java.lang.Object {
private static final io.grpc.ServerProvider provider
public void ()
static final io.grpc.ServerProvider load (java.lang.ClassLoader)
io.grpc.ServerProvider current
ClassLoader cl
java.util.ServiceLoader providers
io.grpc.ServerProvider best
public static io.grpc.ServerProvider provider ()
protected abstract boolean isAvailable ()
protected abstract int priority ()
protected abstract io.grpc.ServerBuilder builderForPort (int)
static void ()
}
io/grpc/ServerBuilder.classServerBuilder.java
package io.grpc
public abstract io.grpc.ServerBuilder extends java.lang.Object {
public void ()
public static io.grpc.ServerBuilder forPort (int)
int port
public abstract io.grpc.ServerBuilder directExecutor ()
public abstract io.grpc.ServerBuilder executor (java.util.concurrent.Executor)
public abstract io.grpc.ServerBuilder addService (io.grpc.ServerServiceDefinition)
public abstract io.grpc.ServerBuilder addService (io.grpc.BindableService)
public abstract io.grpc.ServerBuilder fallbackHandlerRegistry (io.grpc.HandlerRegistry)
public abstract io.grpc.ServerBuilder useTransportSecurity (java.io.File, java.io.File)
public abstract io.grpc.ServerBuilder decompressorRegistry (io.grpc.DecompressorRegistry)
public abstract io.grpc.ServerBuilder compressorRegistry (io.grpc.CompressorRegistry)
public abstract io.grpc.Server build ()
}
io/grpc/ManagedChannelBuilder.classManagedChannelBuilder.java
package io.grpc
public abstract io.grpc.ManagedChannelBuilder extends java.lang.Object {
public void ()
public static io.grpc.ManagedChannelBuilder forAddress (java.lang.String, int)
String name
int port
public static io.grpc.ManagedChannelBuilder forTarget (java.lang.String)
String target
public abstract io.grpc.ManagedChannelBuilder directExecutor ()
public abstract io.grpc.ManagedChannelBuilder executor (java.util.concurrent.Executor)
public abstract io.grpc.ManagedChannelBuilder intercept (java.util.List)
public transient abstract io.grpc.ManagedChannelBuilder intercept (io.grpc.ClientInterceptor[])
public abstract io.grpc.ManagedChannelBuilder userAgent (java.lang.String)
public abstract io.grpc.ManagedChannelBuilder overrideAuthority (java.lang.String)
public abstract io.grpc.ManagedChannelBuilder usePlaintext (boolean)
public abstract io.grpc.ManagedChannelBuilder nameResolverFactory (io.grpc.NameResolver$Factory)
public abstract io.grpc.ManagedChannelBuilder loadBalancerFactory (io.grpc.LoadBalancer$Factory)
public abstract io.grpc.ManagedChannelBuilder decompressorRegistry (io.grpc.DecompressorRegistry)
public abstract io.grpc.ManagedChannelBuilder compressorRegistry (io.grpc.CompressorRegistry)
public abstract io.grpc.ManagedChannelBuilder idleTimeout (long, java.util.concurrent.TimeUnit)
public abstract io.grpc.ManagedChannel build ()
}
io/grpc/HandlerRegistry.classHandlerRegistry.java
package io.grpc
public abstract io.grpc.HandlerRegistry extends java.lang.Object {
public void ()
public abstract io.grpc.ServerMethodDefinition lookupMethod (java.lang.String, java.lang.String)
public final io.grpc.ServerMethodDefinition lookupMethod (java.lang.String)
String methodName
}
io/grpc/DecompressorRegistry$DecompressorInfo.classDecompressorRegistry.java
package io.grpc
final io.grpc.DecompressorRegistry$DecompressorInfo extends java.lang.Object {
final io.grpc.Decompressor decompressor
final boolean advertised
void (io.grpc.Decompressor, boolean)
io.grpc.Decompressor decompressor
boolean advertised
}
io/grpc/DecompressorRegistry.classDecompressorRegistry.java
package io.grpc
public final io.grpc.DecompressorRegistry extends java.lang.Object {
static final com.google.common.base.Joiner ACCEPT_ENCODING_JOINER
private static final io.grpc.DecompressorRegistry DEFAULT_INSTANCE
private final java.util.Map decompressors
private final String advertisedDecompressors
public static io.grpc.DecompressorRegistry emptyInstance ()
public static io.grpc.DecompressorRegistry getDefaultInstance ()
public io.grpc.DecompressorRegistry with (io.grpc.Decompressor, boolean)
io.grpc.Decompressor d
boolean advertised
private void (io.grpc.Decompressor, boolean, io.grpc.DecompressorRegistry)
String previousEncoding
io.grpc.DecompressorRegistry$DecompressorInfo di
io.grpc.Decompressor d
boolean advertised
io.grpc.DecompressorRegistry parent
String encoding
int newSize
java.util.Map newDecompressors
private void ()
public java.util.Set getKnownMessageEncodings ()
public java.lang.String getRawAdvertisedMessageEncodings ()
public java.util.Set getAdvertisedMessageEncodings ()
java.util.Map$Entry entry
java.util.Set advertisedDecompressors
public io.grpc.Decompressor lookupDecompressor (java.lang.String)
String messageEncoding
io.grpc.DecompressorRegistry$DecompressorInfo info
static void ()
}
io/grpc/Server.classServer.java
package io.grpc
public abstract io.grpc.Server extends java.lang.Object {
public void ()
public abstract io.grpc.Server start () throws java.io.IOException
public int getPort ()
public abstract io.grpc.Server shutdown ()
public abstract io.grpc.Server shutdownNow ()
public abstract boolean isShutdown ()
public abstract boolean isTerminated ()
public abstract boolean awaitTermination (long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
public abstract void awaitTermination () throws java.lang.InterruptedException
}
io/grpc/NameResolver$Factory.classNameResolver.java
package io.grpc
public abstract io.grpc.NameResolver$Factory extends java.lang.Object {
public static final io.grpc.Attributes$Key PARAMS_DEFAULT_PORT
public void ()
public abstract io.grpc.NameResolver newNameResolver (java.net.URI, io.grpc.Attributes)
public abstract java.lang.String getDefaultScheme ()
static void ()
}
io/grpc/NameResolver$Listener.classNameResolver.java
package io.grpc
public abstract io.grpc.NameResolver$Listener extends java.lang.Object {
public abstract void onUpdate (java.util.List, io.grpc.Attributes)
public abstract void onError (io.grpc.Status)
}
io/grpc/NameResolver.classNameResolver.java
package io.grpc
public abstract io.grpc.NameResolver extends java.lang.Object {
public void ()
public abstract java.lang.String getServiceAuthority ()
public abstract void start (io.grpc.NameResolver$Listener)
public abstract void shutdown ()
public void refresh ()
}
io/grpc/LoadBalancer$Factory.classLoadBalancer.java
package io.grpc
public abstract io.grpc.LoadBalancer$Factory extends java.lang.Object {
public void ()
public abstract io.grpc.LoadBalancer newLoadBalancer (java.lang.String, io.grpc.TransportManager)
}
io/grpc/LoadBalancer.classLoadBalancer.java
package io.grpc
public abstract io.grpc.LoadBalancer extends java.lang.Object {
public void ()
public abstract java.lang.Object pickTransport (io.grpc.Attributes)
public void shutdown ()
public void handleResolvedAddresses (java.util.List, io.grpc.Attributes)
java.util.List servers
io.grpc.Attributes config
public void handleNameResolutionError (io.grpc.Status)
io.grpc.Status error
public void handleTransportReady (io.grpc.EquivalentAddressGroup)
io.grpc.EquivalentAddressGroup addressGroup
public void handleTransportShutdown (io.grpc.EquivalentAddressGroup, io.grpc.Status)
io.grpc.EquivalentAddressGroup addressGroup
io.grpc.Status s
}
io/grpc/ManagedChannel.classManagedChannel.java
package io.grpc
public abstract io.grpc.ManagedChannel extends io.grpc.Channel {
public void ()
public abstract io.grpc.ManagedChannel shutdown ()
public abstract boolean isShutdown ()
public abstract boolean isTerminated ()
public abstract io.grpc.ManagedChannel shutdownNow ()
public abstract boolean awaitTermination (long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
}
io/grpc/ResolvedServerInfo.classResolvedServerInfo.java
package io.grpc
public final io.grpc.ResolvedServerInfo extends java.lang.Object {
private final java.net.SocketAddress address
private final io.grpc.Attributes attributes
public void (java.net.SocketAddress, io.grpc.Attributes)
java.net.SocketAddress address
io.grpc.Attributes attributes
public java.net.SocketAddress getAddress ()
public io.grpc.Attributes getAttributes ()
public java.lang.String toString ()
}
io/grpc/EquivalentAddressGroup.classEquivalentAddressGroup.java
package io.grpc
public final io.grpc.EquivalentAddressGroup extends java.lang.Object {
private final java.util.List addrs
public void (java.util.List)
java.util.List addrs
public void (java.net.SocketAddress)
java.net.SocketAddress addr
public java.util.List getAddresses ()
public java.lang.String toString ()
public int hashCode ()
public boolean equals (java.lang.Object)
Object other
}
io/grpc/TransportManager$InterimTransport.classTransportManager.java
package io.grpc
public abstract io.grpc.TransportManager$InterimTransport extends java.lang.Object {
public abstract java.lang.Object transport ()
public abstract void closeWithRealTransports (com.google.common.base.Supplier)
public abstract void closeWithError (io.grpc.Status)
}
io/grpc/TransportManager$OobTransportProvider.classTransportManager.java
package io.grpc
public abstract io.grpc.TransportManager$OobTransportProvider extends java.lang.Object {
public abstract java.lang.Object get ()
public abstract void close ()
}
io/grpc/TransportManager.classTransportManager.java
package io.grpc
public abstract io.grpc.TransportManager extends java.lang.Object {
public void ()
public abstract void updateRetainedTransports (java.util.Collection)
public abstract java.lang.Object getTransport (io.grpc.EquivalentAddressGroup)
public abstract java.lang.Object createFailingTransport (io.grpc.Status)
public abstract io.grpc.TransportManager$InterimTransport createInterimTransport ()
public abstract io.grpc.TransportManager$OobTransportProvider createOobTransportProvider (io.grpc.EquivalentAddressGroup, java.lang.String)
public abstract io.grpc.Channel makeChannel (java.lang.Object)
}
io/grpc/inprocess/
io/grpc/inprocess/InProcessServer.classInProcessServer.java
package io.grpc.inprocess
io.grpc.inprocess.InProcessServer extends java.lang.Object implements io.grpc.internal.InternalServer {
private static final java.util.concurrent.ConcurrentMap registry
private final String name
private io.grpc.internal.ServerListener listener
private boolean shutdown
static io.grpc.inprocess.InProcessServer findServer (java.lang.String)
String name
void (java.lang.String)
String name
public void start (io.grpc.internal.ServerListener) throws java.io.IOException
io.grpc.internal.ServerListener serverListener
public int getPort ()
public void shutdown ()
synchronized io.grpc.internal.ServerTransportListener register (io.grpc.inprocess.InProcessTransport)
io.grpc.inprocess.InProcessTransport transport
static void ()
}
io/grpc/inprocess/InProcessTransport$1.classInProcessTransport.java
package io.grpc.inprocess
io.grpc.inprocess.InProcessTransport$1 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.Status val$localShutdownStatus
final io.grpc.inprocess.InProcessTransport this$0
void (io.grpc.inprocess.InProcessTransport, io.grpc.Status)
io.grpc.inprocess.InProcessTransport this$0
public void run ()
}
io/grpc/inprocess/InProcessTransport$2.classInProcessTransport.java
package io.grpc.inprocess
io.grpc.inprocess.InProcessTransport$2 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.inprocess.InProcessTransport this$0
void (io.grpc.inprocess.InProcessTransport)
io.grpc.inprocess.InProcessTransport this$0
public void run ()
}
io/grpc/inprocess/InProcessTransport$3.classInProcessTransport.java
package io.grpc.inprocess
io.grpc.inprocess.InProcessTransport$3 extends io.grpc.internal.NoopClientStream {
final io.grpc.Status val$capturedStatus
final io.grpc.inprocess.InProcessTransport this$0
void (io.grpc.inprocess.InProcessTransport, io.grpc.Status)
io.grpc.inprocess.InProcessTransport this$0
public void start (io.grpc.internal.ClientStreamListener)
io.grpc.internal.ClientStreamListener listener
}
io/grpc/inprocess/InProcessTransport$4.classInProcessTransport.java
package io.grpc.inprocess
io.grpc.inprocess.InProcessTransport$4 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.ClientTransport$PingCallback val$callback
final io.grpc.Status val$shutdownStatus
final io.grpc.inprocess.InProcessTransport this$0
void (io.grpc.inprocess.InProcessTransport, io.grpc.internal.ClientTransport$PingCallback, io.grpc.Status)
io.grpc.inprocess.InProcessTransport this$0
public void run ()
}
io/grpc/inprocess/InProcessTransport$5.classInProcessTransport.java
package io.grpc.inprocess
io.grpc.inprocess.InProcessTransport$5 extends java.lang.Object implements java.lang.Runnable {
final io.grpc.internal.ClientTransport$PingCallback val$callback
final io.grpc.inprocess.InProcessTransport this$0
void (io.grpc.inprocess.InProcessTransport, io.grpc.internal.ClientTransport$PingCallback)
io.grpc.inprocess.InProcessTransport this$0
public void run ()
}
io/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream.classInProcessTransport.java
package io.grpc.inprocess
io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessServerStream extends java.lang.Object implements io.grpc.internal.ServerStream {
private io.grpc.internal.ClientStreamListener clientStreamListener
private int clientRequested
private java.util.ArrayDeque clientReceiveQueue
private io.grpc.Status clientNotifyStatus
private io.grpc.Metadata clientNotifyTrailers
private boolean closed
final io.grpc.inprocess.InProcessTransport$InProcessStream this$1
private void (io.grpc.inprocess.InProcessTransport$InProcessStream)
private synchronized void setListener (io.grpc.internal.ClientStreamListener)
io.grpc.internal.ClientStreamListener listener
public void setListener (io.grpc.internal.ServerStreamListener)
io.grpc.internal.ServerStreamListener serverStreamListener
public void request (int)
int numMessages
boolean onReady
private synchronized boolean clientRequested (int)
int numMessages
boolean previouslyReady
boolean nowReady
private void clientCancelled (io.grpc.Status)
io.grpc.Status status
public synchronized void writeMessage (java.io.InputStream)
java.io.InputStream message
public void flush ()
public synchronized boolean isReady ()
public synchronized void writeHeaders (io.grpc.Metadata)
io.grpc.Metadata headers
public void close (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
public void cancel (io.grpc.Status)
io.grpc.Status status
private synchronized boolean internalCancel (io.grpc.Status)
Throwable t
io.grpc.Status status
java.io.InputStream stream
public void setMessageCompression (boolean)
boolean enable
public void setCompressor (io.grpc.Compressor)
io.grpc.Compressor compressor
public void setDecompressor (io.grpc.Decompressor)
io.grpc.Decompressor decompressor
public io.grpc.Attributes attributes ()
void (io.grpc.inprocess.InProcessTransport$InProcessStream, io.grpc.inprocess.InProcessTransport$1)
io.grpc.inprocess.InProcessTransport$InProcessStream x0
io.grpc.inprocess.InProcessTransport$1 x1
static boolean access$1700 (io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessServerStream, int)
io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessServerStream x0
int x1
static void access$1800 (io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessServerStream, io.grpc.Status)
io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessServerStream x0
io.grpc.Status x1
static void access$1900 (io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessServerStream, io.grpc.internal.ClientStreamListener)
io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessServerStream x0
io.grpc.internal.ClientStreamListener x1
}
io/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream.classInProcessTransport.java
package io.grpc.inprocess
io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessClientStream extends java.lang.Object implements io.grpc.internal.ClientStream {
private io.grpc.internal.ServerStreamListener serverStreamListener
private int serverRequested
private java.util.ArrayDeque serverReceiveQueue
private boolean serverNotifyHalfClose
private boolean closed
final io.grpc.inprocess.InProcessTransport$InProcessStream this$1
private void (io.grpc.inprocess.InProcessTransport$InProcessStream)
private synchronized void setListener (io.grpc.internal.ServerStreamListener)
io.grpc.internal.ServerStreamListener listener
public void request (int)
int numMessages
boolean onReady
private synchronized boolean serverRequested (int)
int numMessages
boolean previouslyReady
boolean nowReady
private void serverClosed (io.grpc.Status)
io.grpc.Status status
public synchronized void writeMessage (java.io.InputStream)
java.io.InputStream message
public void flush ()
public synchronized boolean isReady ()
public void cancel (io.grpc.Status)
io.grpc.Status reason
private synchronized boolean internalCancel (io.grpc.Status)
Throwable t
io.grpc.Status reason
java.io.InputStream stream
public synchronized void halfClose ()
public void setMessageCompression (boolean)
boolean enable
public void setAuthority (java.lang.String)
String string
public void start (io.grpc.internal.ClientStreamListener)
io.grpc.internal.ClientStreamListener listener
public void setCompressor (io.grpc.Compressor)
io.grpc.Compressor compressor
public void setDecompressor (io.grpc.Decompressor)
io.grpc.Decompressor decompressor
void (io.grpc.inprocess.InProcessTransport$InProcessStream, io.grpc.inprocess.InProcessTransport$1)
io.grpc.inprocess.InProcessTransport$InProcessStream x0
io.grpc.inprocess.InProcessTransport$1 x1
static void access$900 (io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessClientStream, io.grpc.internal.ServerStreamListener)
io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessClientStream x0
io.grpc.internal.ServerStreamListener x1
static boolean access$1000 (io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessClientStream, int)
io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessClientStream x0
int x1
static void access$1200 (io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessClientStream, io.grpc.Status)
io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessClientStream x0
io.grpc.Status x1
}
io/grpc/inprocess/InProcessTransport$InProcessStream.classInProcessTransport.java
package io.grpc.inprocess
io.grpc.inprocess.InProcessTransport$InProcessStream extends java.lang.Object {
private final io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessServerStream serverStream
private final io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessClientStream clientStream
private final io.grpc.Metadata headers
private io.grpc.MethodDescriptor method
final io.grpc.inprocess.InProcessTransport this$0
private void (io.grpc.inprocess.InProcessTransport, io.grpc.MethodDescriptor, io.grpc.Metadata)
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
private void streamClosed ()
boolean justRemovedAnElement
void (io.grpc.inprocess.InProcessTransport, io.grpc.MethodDescriptor, io.grpc.Metadata, io.grpc.inprocess.InProcessTransport$1)
io.grpc.inprocess.InProcessTransport x0
io.grpc.MethodDescriptor x1
io.grpc.Metadata x2
io.grpc.inprocess.InProcessTransport$1 x3
static io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessClientStream access$400 (io.grpc.inprocess.InProcessTransport$InProcessStream)
io.grpc.inprocess.InProcessTransport$InProcessStream x0
static void access$1300 (io.grpc.inprocess.InProcessTransport$InProcessStream)
io.grpc.inprocess.InProcessTransport$InProcessStream x0
static io.grpc.inprocess.InProcessTransport$InProcessStream$InProcessServerStream access$1600 (io.grpc.inprocess.InProcessTransport$InProcessStream)
io.grpc.inprocess.InProcessTransport$InProcessStream x0
static io.grpc.MethodDescriptor access$2000 (io.grpc.inprocess.InProcessTransport$InProcessStream)
io.grpc.inprocess.InProcessTransport$InProcessStream x0
static io.grpc.Metadata access$2100 (io.grpc.inprocess.InProcessTransport$InProcessStream)
io.grpc.inprocess.InProcessTransport$InProcessStream x0
}
io/grpc/inprocess/InProcessTransport.classInProcessTransport.java
package io.grpc.inprocess
io.grpc.inprocess.InProcessTransport extends java.lang.Object implements io.grpc.internal.ServerTransport io.grpc.internal.ConnectionClientTransport {
private static final java.util.logging.Logger log
private final String name
private io.grpc.internal.ServerTransportListener serverTransportListener
private final io.grpc.Attributes serverStreamAttributes
private io.grpc.internal.ManagedClientTransport$Listener clientTransportListener
private boolean shutdown
private boolean terminated
private io.grpc.Status shutdownStatus
private java.util.Set streams
public void (java.lang.String)
String name
public synchronized java.lang.Runnable start (io.grpc.internal.ManagedClientTransport$Listener)
io.grpc.Status localShutdownStatus
io.grpc.internal.ManagedClientTransport$Listener listener
io.grpc.inprocess.InProcessServer server
public synchronized io.grpc.internal.ClientStream newStream (io.grpc.MethodDescriptor, io.grpc.Metadata, io.grpc.CallOptions)
io.grpc.Status capturedStatus
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
io.grpc.CallOptions callOptions
public synchronized io.grpc.internal.ClientStream newStream (io.grpc.MethodDescriptor, io.grpc.Metadata)
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
public synchronized void ping (io.grpc.internal.ClientTransport$PingCallback, java.util.concurrent.Executor)
io.grpc.Status shutdownStatus
io.grpc.internal.ClientTransport$PingCallback callback
java.util.concurrent.Executor executor
public synchronized void shutdown ()
public void shutdownNow (io.grpc.Status)
io.grpc.inprocess.InProcessTransport$InProcessStream stream
io.grpc.Status reason
java.util.List streamsCopy
public java.lang.String toString ()
public java.lang.String getLogId ()
public io.grpc.Attributes getAttrs ()
private synchronized void notifyShutdown (io.grpc.Status)
io.grpc.Status s
private synchronized void notifyTerminated ()
private static io.grpc.Status stripCause (io.grpc.Status)
io.grpc.Status status
static void access$000 (io.grpc.inprocess.InProcessTransport, io.grpc.Status)
io.grpc.inprocess.InProcessTransport x0
io.grpc.Status x1
static void access$100 (io.grpc.inprocess.InProcessTransport)
io.grpc.inprocess.InProcessTransport x0
static io.grpc.internal.ManagedClientTransport$Listener access$200 (io.grpc.inprocess.InProcessTransport)
io.grpc.inprocess.InProcessTransport x0
static java.util.Set access$700 (io.grpc.inprocess.InProcessTransport)
io.grpc.inprocess.InProcessTransport x0
static boolean access$800 (io.grpc.inprocess.InProcessTransport)
io.grpc.inprocess.InProcessTransport x0
static io.grpc.Status access$1100 (io.grpc.Status)
io.grpc.Status x0
static java.util.logging.Logger access$1400 ()
static io.grpc.Attributes access$1500 (io.grpc.inprocess.InProcessTransport)
io.grpc.inprocess.InProcessTransport x0
static io.grpc.internal.ServerTransportListener access$2200 (io.grpc.inprocess.InProcessTransport)
io.grpc.inprocess.InProcessTransport x0
static void ()
}
io/grpc/inprocess/InProcessSocketAddress.classInProcessSocketAddress.java
package io.grpc.inprocess
public io.grpc.inprocess.InProcessSocketAddress extends java.net.SocketAddress {
private static final long serialVersionUID
private final String name
public void (java.lang.String)
String name
public java.lang.String getName ()
}
io/grpc/inprocess/InProcessChannelBuilder$InProcessClientTransportFactory.classInProcessChannelBuilder.java
package io.grpc.inprocess
final io.grpc.inprocess.InProcessChannelBuilder$InProcessClientTransportFactory extends java.lang.Object implements io.grpc.internal.ClientTransportFactory {
private final String name
private boolean closed
private void (java.lang.String)
String name
public io.grpc.internal.ConnectionClientTransport newClientTransport (java.net.SocketAddress, java.lang.String, java.lang.String)
java.net.SocketAddress addr
String authority
String userAgent
public void close ()
void (java.lang.String, io.grpc.inprocess.InProcessChannelBuilder$1)
String x0
io.grpc.inprocess.InProcessChannelBuilder$1 x1
}
io/grpc/inprocess/InProcessChannelBuilder$1.classInProcessChannelBuilder.java
package io.grpc.inprocess
io.grpc.inprocess.InProcessChannelBuilder$1 extends java.lang.Object {
}
io/grpc/inprocess/InProcessChannelBuilder.classInProcessChannelBuilder.java
package io.grpc.inprocess
public io.grpc.inprocess.InProcessChannelBuilder extends io.grpc.internal.AbstractManagedChannelImplBuilder {
private final String name
public static io.grpc.inprocess.InProcessChannelBuilder forName (java.lang.String)
String name
private void (java.lang.String)
String name
public io.grpc.inprocess.InProcessChannelBuilder usePlaintext (boolean)
boolean skipNegotiation
protected io.grpc.internal.ClientTransportFactory buildTransportFactory ()
public volatile io.grpc.ManagedChannelBuilder usePlaintext (boolean)
}
io/grpc/inprocess/InProcessServerBuilder.classInProcessServerBuilder.java
package io.grpc.inprocess
public final io.grpc.inprocess.InProcessServerBuilder extends io.grpc.internal.AbstractServerImplBuilder {
private final String name
public static io.grpc.inprocess.InProcessServerBuilder forName (java.lang.String)
String name
private void (java.lang.String)
String name
protected io.grpc.inprocess.InProcessServer buildTransportServer ()
public io.grpc.inprocess.InProcessServerBuilder useTransportSecurity (java.io.File, java.io.File)
java.io.File certChain
java.io.File privateKey
protected volatile io.grpc.internal.InternalServer buildTransportServer ()
public volatile io.grpc.ServerBuilder useTransportSecurity (java.io.File, java.io.File)
}
io/grpc/NameResolverProvider$1.classNameResolverProvider.java
package io.grpc
final io.grpc.NameResolverProvider$1 extends java.lang.Object implements java.util.Comparator {
void ()
public int compare (io.grpc.NameResolverProvider, io.grpc.NameResolverProvider)
io.grpc.NameResolverProvider f1
io.grpc.NameResolverProvider f2
public volatile int compare (java.lang.Object, java.lang.Object)
}
io/grpc/NameResolverProvider$NameResolverFactory.classNameResolverProvider.java
package io.grpc
io.grpc.NameResolverProvider$NameResolverFactory extends io.grpc.NameResolver$Factory {
private final java.util.List providers
public void (java.util.List)
java.util.List providers
public io.grpc.NameResolver newNameResolver (java.net.URI, io.grpc.Attributes)
io.grpc.NameResolver resolver
io.grpc.NameResolverProvider provider
java.net.URI targetUri
io.grpc.Attributes params
public java.lang.String getDefaultScheme ()
private void checkForProviders ()
}
io/grpc/NameResolverProvider.classNameResolverProvider.java
package io.grpc
public abstract io.grpc.NameResolverProvider extends io.grpc.NameResolver$Factory {
public static final io.grpc.Attributes$Key PARAMS_DEFAULT_PORT
private static final java.util.List providers
private static final io.grpc.NameResolver$Factory factory
public void ()
static java.util.List load (java.lang.ClassLoader)
Iterable candidates
io.grpc.NameResolverProvider current
ClassLoader classLoader
Iterable candidates
java.util.List list
public static java.lang.Iterable getCandidatesViaServiceLoader (java.lang.ClassLoader)
ClassLoader classLoader
public static java.lang.Iterable getCandidatesViaHardCoded (java.lang.ClassLoader)
ClassLoader classLoader
java.util.List list
static io.grpc.NameResolverProvider create (java.lang.Class)
Throwable t
Class rawClass
public static java.util.List providers ()
public static io.grpc.NameResolver$Factory asFactory ()
static io.grpc.NameResolver$Factory asFactory (java.util.List)
java.util.List providers
private static java.lang.ClassLoader getCorrectClassLoader ()
private static boolean isAndroid ()
Exception e
protected abstract boolean isAvailable ()
protected abstract int priority ()
static void ()
}
io/grpc/util/
io/grpc/util/MutableHandlerRegistry.classMutableHandlerRegistry.java
package io.grpc.util
public final io.grpc.util.MutableHandlerRegistry extends io.grpc.HandlerRegistry {
private final java.util.concurrent.ConcurrentMap services
public void ()
public io.grpc.ServerServiceDefinition addService (io.grpc.ServerServiceDefinition)
io.grpc.ServerServiceDefinition service
public boolean removeService (io.grpc.ServerServiceDefinition)
io.grpc.ServerServiceDefinition service
public io.grpc.ServerMethodDefinition lookupMethod (java.lang.String, java.lang.String)
String methodName
String authority
String serviceName
io.grpc.ServerServiceDefinition service
}
io/grpc/util/RoundRobinLoadBalancerFactory$RoundRobinLoadBalancer$1.classRoundRobinLoadBalancerFactory.java
package io.grpc.util
io.grpc.util.RoundRobinLoadBalancerFactory$RoundRobinLoadBalancer$1 extends java.lang.Object implements com.google.common.base.Supplier {
final io.grpc.internal.RoundRobinServerList val$addressesCopy
final io.grpc.util.RoundRobinLoadBalancerFactory$RoundRobinLoadBalancer this$0
void (io.grpc.util.RoundRobinLoadBalancerFactory$RoundRobinLoadBalancer, io.grpc.internal.RoundRobinServerList)
io.grpc.util.RoundRobinLoadBalancerFactory$RoundRobinLoadBalancer this$0
public java.lang.Object get ()
}
io/grpc/util/RoundRobinLoadBalancerFactory$RoundRobinLoadBalancer.classRoundRobinLoadBalancerFactory.java
package io.grpc.util
io.grpc.util.RoundRobinLoadBalancerFactory$RoundRobinLoadBalancer extends io.grpc.LoadBalancer {
private static final io.grpc.Status SHUTDOWN_STATUS
private final Object lock
private io.grpc.internal.RoundRobinServerList addresses
private io.grpc.TransportManager$InterimTransport interimTransport
private io.grpc.Status nameResolutionError
private boolean closed
private final io.grpc.TransportManager tm
private void (io.grpc.TransportManager)
io.grpc.TransportManager tm
public java.lang.Object pickTransport (io.grpc.Attributes)
io.grpc.Attributes affinity
io.grpc.internal.RoundRobinServerList addressesCopy
public void handleResolvedAddresses (java.util.List, io.grpc.Attributes)
io.grpc.ResolvedServerInfo server
java.util.List socketAddresses
java.util.List servers
io.grpc.internal.RoundRobinServerList$Builder listBuilder
java.util.List updatedServers
io.grpc.Attributes config
io.grpc.TransportManager$InterimTransport savedInterimTransport
io.grpc.internal.RoundRobinServerList addressesCopy
public void handleNameResolutionError (io.grpc.Status)
io.grpc.Status error
io.grpc.TransportManager$InterimTransport savedInterimTransport
public void shutdown ()
io.grpc.TransportManager$InterimTransport savedInterimTransport
void (io.grpc.TransportManager, io.grpc.util.RoundRobinLoadBalancerFactory$1)
io.grpc.TransportManager x0
io.grpc.util.RoundRobinLoadBalancerFactory$1 x1
static void ()
}
io/grpc/util/RoundRobinLoadBalancerFactory$1.classRoundRobinLoadBalancerFactory.java
package io.grpc.util
io.grpc.util.RoundRobinLoadBalancerFactory$1 extends java.lang.Object {
}
io/grpc/util/RoundRobinLoadBalancerFactory.classRoundRobinLoadBalancerFactory.java
package io.grpc.util
public final io.grpc.util.RoundRobinLoadBalancerFactory extends io.grpc.LoadBalancer$Factory {
private static final io.grpc.util.RoundRobinLoadBalancerFactory instance
private void ()
public static io.grpc.util.RoundRobinLoadBalancerFactory getInstance ()
public io.grpc.LoadBalancer newLoadBalancer (java.lang.String, io.grpc.TransportManager)
String serviceName
io.grpc.TransportManager tm
static void ()
}
io/grpc/ClientInterceptors$InterceptorChannel.classClientInterceptors.java
package io.grpc
io.grpc.ClientInterceptors$InterceptorChannel extends io.grpc.Channel {
private final io.grpc.Channel channel
private final io.grpc.ClientInterceptor interceptor
private void (io.grpc.Channel, io.grpc.ClientInterceptor)
io.grpc.Channel channel
io.grpc.ClientInterceptor interceptor
public io.grpc.ClientCall newCall (io.grpc.MethodDescriptor, io.grpc.CallOptions)
io.grpc.MethodDescriptor method
io.grpc.CallOptions callOptions
public java.lang.String authority ()
void (io.grpc.Channel, io.grpc.ClientInterceptor, io.grpc.ClientInterceptors$1)
io.grpc.Channel x0
io.grpc.ClientInterceptor x1
io.grpc.ClientInterceptors$1 x2
}
io/grpc/ClientInterceptors$1.classClientInterceptors.java
package io.grpc
final io.grpc.ClientInterceptors$1 extends io.grpc.ClientCall {
void ()
public void start (io.grpc.ClientCall$Listener, io.grpc.Metadata)
io.grpc.ClientCall$Listener responseListener
io.grpc.Metadata headers
public void request (int)
int numMessages
public void cancel (java.lang.String, java.lang.Throwable)
String message
Throwable cause
public void halfClose ()
public void sendMessage (java.lang.Object)
Object message
public boolean isReady ()
}
io/grpc/ClientInterceptors$CheckedForwardingClientCall.classClientInterceptors.java
package io.grpc
public abstract io.grpc.ClientInterceptors$CheckedForwardingClientCall extends io.grpc.ForwardingClientCall {
private io.grpc.ClientCall delegate
protected abstract void checkedStart (io.grpc.ClientCall$Listener, io.grpc.Metadata) throws java.lang.Exception
protected void (io.grpc.ClientCall)
io.grpc.ClientCall delegate
protected final io.grpc.ClientCall delegate ()
public final void start (io.grpc.ClientCall$Listener, io.grpc.Metadata)
Exception e
io.grpc.ClientCall$Listener responseListener
io.grpc.Metadata headers
}
io/grpc/ClientInterceptors.classClientInterceptors.java
package io.grpc
public io.grpc.ClientInterceptors extends java.lang.Object {
private static final io.grpc.ClientCall NOOP_CALL
private void ()
public static transient io.grpc.Channel interceptForward (io.grpc.Channel, io.grpc.ClientInterceptor[])
io.grpc.Channel channel
io.grpc.ClientInterceptor[] interceptors
public static io.grpc.Channel interceptForward (io.grpc.Channel, java.util.List)
io.grpc.Channel channel
java.util.List interceptors
java.util.List copy
public static transient io.grpc.Channel intercept (io.grpc.Channel, io.grpc.ClientInterceptor[])
io.grpc.Channel channel
io.grpc.ClientInterceptor[] interceptors
public static io.grpc.Channel intercept (io.grpc.Channel, java.util.List)
io.grpc.ClientInterceptor interceptor
io.grpc.Channel channel
java.util.List interceptors
static io.grpc.ClientCall access$100 ()
static void ()
}
io/grpc/DummyLoadBalancerFactory$DummyLoadBalancer$1.classDummyLoadBalancerFactory.java
package io.grpc
io.grpc.DummyLoadBalancerFactory$DummyLoadBalancer$1 extends java.lang.Object implements com.google.common.base.Supplier {
final io.grpc.EquivalentAddressGroup val$newAddresses
final io.grpc.DummyLoadBalancerFactory$DummyLoadBalancer this$0
void (io.grpc.DummyLoadBalancerFactory$DummyLoadBalancer, io.grpc.EquivalentAddressGroup)
io.grpc.DummyLoadBalancerFactory$DummyLoadBalancer this$0
public java.lang.Object get ()
}
io/grpc/DummyLoadBalancerFactory$DummyLoadBalancer.classDummyLoadBalancerFactory.java
package io.grpc
io.grpc.DummyLoadBalancerFactory$DummyLoadBalancer extends io.grpc.LoadBalancer {
private static final io.grpc.Status SHUTDOWN_STATUS
private final Object lock
private io.grpc.EquivalentAddressGroup addresses
private io.grpc.TransportManager$InterimTransport interimTransport
private io.grpc.Status nameResolutionError
private boolean closed
private final io.grpc.TransportManager tm
private void (io.grpc.TransportManager)
io.grpc.TransportManager tm
public java.lang.Object pickTransport (io.grpc.Attributes)
io.grpc.Attributes affinity
io.grpc.EquivalentAddressGroup addressesCopy
public void handleResolvedAddresses (java.util.List, io.grpc.Attributes)
io.grpc.ResolvedServerInfo server
java.util.List servers
java.util.ArrayList newAddressList
java.util.List updatedServers
io.grpc.Attributes config
io.grpc.TransportManager$InterimTransport savedInterimTransport
io.grpc.EquivalentAddressGroup newAddresses
public void handleNameResolutionError (io.grpc.Status)
io.grpc.Status error
io.grpc.TransportManager$InterimTransport savedInterimTransport
public void shutdown ()
io.grpc.TransportManager$InterimTransport savedInterimTransport
void (io.grpc.TransportManager, io.grpc.DummyLoadBalancerFactory$1)
io.grpc.TransportManager x0
io.grpc.DummyLoadBalancerFactory$1 x1
static io.grpc.TransportManager access$100 (io.grpc.DummyLoadBalancerFactory$DummyLoadBalancer)
io.grpc.DummyLoadBalancerFactory$DummyLoadBalancer x0
static void ()
}
io/grpc/DummyLoadBalancerFactory$1.classDummyLoadBalancerFactory.java
package io.grpc
io.grpc.DummyLoadBalancerFactory$1 extends java.lang.Object {
}
io/grpc/DummyLoadBalancerFactory.classDummyLoadBalancerFactory.java
package io.grpc
public final io.grpc.DummyLoadBalancerFactory extends io.grpc.LoadBalancer$Factory {
private static final io.grpc.DummyLoadBalancerFactory instance
private void ()
public static io.grpc.DummyLoadBalancerFactory getInstance ()
public io.grpc.LoadBalancer newLoadBalancer (java.lang.String, io.grpc.TransportManager)
String serviceName
io.grpc.TransportManager tm
static void ()
}
io/grpc/ServerInterceptors$1.classServerInterceptors.java
package io.grpc
final io.grpc.ServerInterceptors$1 extends java.lang.Object implements io.grpc.MethodDescriptor$Marshaller {
void ()
public java.io.InputStream stream (java.io.InputStream)
java.io.InputStream value
public java.io.InputStream parse (java.io.InputStream)
java.io.InputStream stream
public volatile java.lang.Object parse (java.io.InputStream)
public volatile java.io.InputStream stream (java.lang.Object)
}
io/grpc/ServerInterceptors$InterceptCallHandler.classServerInterceptors.java
package io.grpc
io.grpc.ServerInterceptors$InterceptCallHandler extends java.lang.Object implements io.grpc.ServerCallHandler {
private final io.grpc.ServerInterceptor interceptor
private final io.grpc.ServerCallHandler callHandler
public static io.grpc.ServerInterceptors$InterceptCallHandler create (io.grpc.ServerInterceptor, io.grpc.ServerCallHandler)
io.grpc.ServerInterceptor interceptor
io.grpc.ServerCallHandler callHandler
private void (io.grpc.ServerInterceptor, io.grpc.ServerCallHandler)
io.grpc.ServerInterceptor interceptor
io.grpc.ServerCallHandler callHandler
public io.grpc.ServerCall$Listener startCall (io.grpc.ServerCall, io.grpc.Metadata)
io.grpc.ServerCall call
io.grpc.Metadata headers
}
io/grpc/ServerInterceptors$2$1.classServerInterceptors.java
package io.grpc
io.grpc.ServerInterceptors$2$1 extends io.grpc.PartialForwardingServerCall {
final io.grpc.ServerCall val$call
final io.grpc.ServerInterceptors$2 this$0
void (io.grpc.ServerInterceptors$2, io.grpc.ServerCall)
io.grpc.ServerInterceptors$2 this$0
protected io.grpc.ServerCall delegate ()
public void sendMessage (java.lang.Object)
Object message
java.io.InputStream is
Object wrappedMessage
public io.grpc.MethodDescriptor getMethodDescriptor ()
}
io/grpc/ServerInterceptors$2$2.classServerInterceptors.java
package io.grpc
io.grpc.ServerInterceptors$2$2 extends io.grpc.PartialForwardingServerCallListener {
final io.grpc.ServerCall$Listener val$originalListener
final io.grpc.ServerInterceptors$2 this$0
void (io.grpc.ServerInterceptors$2, io.grpc.ServerCall$Listener)
io.grpc.ServerInterceptors$2 this$0
protected io.grpc.ServerCall$Listener delegate ()
public void onMessage (java.lang.Object)
Object message
java.io.InputStream is
Object originalMessage
}
io/grpc/ServerInterceptors$2.classServerInterceptors.java
package io.grpc
final io.grpc.ServerInterceptors$2 extends java.lang.Object implements io.grpc.ServerCallHandler {
final io.grpc.MethodDescriptor val$originalMethod
final io.grpc.MethodDescriptor val$wrappedMethod
final io.grpc.ServerCallHandler val$originalHandler
void (io.grpc.MethodDescriptor, io.grpc.MethodDescriptor, io.grpc.ServerCallHandler)
public io.grpc.ServerCall$Listener startCall (io.grpc.ServerCall, io.grpc.Metadata)
io.grpc.ServerCall call
io.grpc.Metadata headers
io.grpc.ServerCall unwrappedCall
io.grpc.ServerCall$Listener originalListener
}
io/grpc/ServerInterceptors.classServerInterceptors.java
package io.grpc
public io.grpc.ServerInterceptors extends java.lang.Object {
private void ()
public static transient io.grpc.ServerServiceDefinition interceptForward (io.grpc.ServerServiceDefinition, io.grpc.ServerInterceptor[])
io.grpc.ServerServiceDefinition serviceDef
io.grpc.ServerInterceptor[] interceptors
public static transient io.grpc.ServerServiceDefinition interceptForward (io.grpc.BindableService, io.grpc.ServerInterceptor[])
io.grpc.BindableService bindableService
io.grpc.ServerInterceptor[] interceptors
public static io.grpc.ServerServiceDefinition interceptForward (io.grpc.ServerServiceDefinition, java.util.List)
io.grpc.ServerServiceDefinition serviceDef
java.util.List interceptors
java.util.List copy
public static io.grpc.ServerServiceDefinition interceptForward (io.grpc.BindableService, java.util.List)
io.grpc.BindableService bindableService
java.util.List interceptors
public static transient io.grpc.ServerServiceDefinition intercept (io.grpc.ServerServiceDefinition, io.grpc.ServerInterceptor[])
io.grpc.ServerServiceDefinition serviceDef
io.grpc.ServerInterceptor[] interceptors
public static transient io.grpc.ServerServiceDefinition intercept (io.grpc.BindableService, io.grpc.ServerInterceptor[])
io.grpc.BindableService bindableService
io.grpc.ServerInterceptor[] interceptors
public static io.grpc.ServerServiceDefinition intercept (io.grpc.ServerServiceDefinition, java.util.List)
io.grpc.ServerMethodDefinition method
io.grpc.ServerServiceDefinition serviceDef
java.util.List interceptors
io.grpc.ServerServiceDefinition$Builder serviceDefBuilder
public static io.grpc.ServerServiceDefinition intercept (io.grpc.BindableService, java.util.List)
io.grpc.BindableService bindableService
java.util.List interceptors
public static io.grpc.ServerServiceDefinition useInputStreamMessages (io.grpc.ServerServiceDefinition)
io.grpc.ServerServiceDefinition serviceDef
io.grpc.MethodDescriptor$Marshaller marshaller
public static io.grpc.ServerServiceDefinition useMarshalledMessages (io.grpc.ServerServiceDefinition, io.grpc.MethodDescriptor$Marshaller)
io.grpc.MethodDescriptor originalMethodDescriptor
io.grpc.MethodDescriptor wrappedMethodDescriptor
io.grpc.ServerMethodDefinition definition
io.grpc.ServerMethodDefinition definition
io.grpc.ServerServiceDefinition serviceDef
io.grpc.MethodDescriptor$Marshaller marshaller
java.util.List wrappedMethods
java.util.List wrappedDescriptors
io.grpc.ServerServiceDefinition$Builder serviceBuilder
private static void wrapAndAddMethod (io.grpc.ServerServiceDefinition$Builder, io.grpc.ServerMethodDefinition, java.util.List)
io.grpc.ServerInterceptor interceptor
io.grpc.ServerServiceDefinition$Builder serviceDefBuilder
io.grpc.ServerMethodDefinition method
java.util.List interceptors
io.grpc.ServerCallHandler callHandler
private static io.grpc.ServerMethodDefinition wrapMethod (io.grpc.ServerMethodDefinition, io.grpc.MethodDescriptor)
io.grpc.ServerMethodDefinition definition
io.grpc.MethodDescriptor wrappedMethod
io.grpc.ServerCallHandler wrappedHandler
private static io.grpc.ServerCallHandler wrapHandler (io.grpc.ServerCallHandler, io.grpc.MethodDescriptor, io.grpc.MethodDescriptor)
io.grpc.ServerCallHandler originalHandler
io.grpc.MethodDescriptor originalMethod
io.grpc.MethodDescriptor wrappedMethod
}
META-INF/services/
META-INF/services/io.grpc.NameResolverProvider