Interface | Description |
---|---|
AbstractClientStream.Sink |
A sink for outbound operations, separated from the stream simply to avoid name
collisions/confusion.
|
AbstractServerStream.Sink |
A sink for outbound operations, separated from the stream simply to avoid name
collisions/confusion.
|
BackoffPolicy |
Determines how long to wait before doing some action (typically a retry, or a reconnect).
|
BackoffPolicy.Provider | |
ClientStream |
Extension of
Stream to support client-side termination semantics. |
ClientStreamListener |
An observer of client-side stream events.
|
ClientTransport |
The client-side transport typically encapsulating a single connection to a remote
server.
|
ClientTransport.PingCallback |
A callback that is invoked when the acknowledgement to a
ClientTransport.ping(io.grpc.internal.ClientTransport.PingCallback, java.util.concurrent.Executor) is received. |
ClientTransportFactory |
Pre-configured factory for creating
ConnectionClientTransport instances. |
ConnectionClientTransport |
A
ManagedClientTransport that is based on a connection. |
Deframer |
Interface for deframing gRPC messages.
|
Framer |
Interface for framing gRPC messages.
|
InternalServer |
An object that accepts new incoming connections.
|
KeepAliveManager.KeepAlivePinger | |
LongCounter |
An interface for a long base counter.
|
ManagedClientTransport |
A
ClientTransport that has life-cycle management. |
ManagedClientTransport.Listener |
Receives notifications for the transport life-cycle events.
|
MessageDeframer.Listener |
A listener of deframing events.
|
MessageFramer.Sink |
Sink implemented by the transport layer to receive frames and forward them to their
destination.
|
ObjectPool<T> |
An object pool.
|
ReadableBuffer |
Interface for an abstract byte buffer.
|
ServerListener |
A listener to a server for transport creation events.
|
ServerStream |
Extension of
Stream to support server-side termination semantics. |
ServerStreamListener |
An observer of server-side stream events.
|
ServerTransport |
An inbound connection.
|
ServerTransportListener |
A observer of a server-side transport for stream creation events.
|
SharedResourceHolder.Resource<T> |
Defines a resource, and the way to create and destroy instances of it.
|
Stream |
A single stream of communication between two end-points within a transport.
|
StreamListener |
An observer of
Stream events. |
StreamListener.MessageProducer |
A producer for deframed gRPC messages.
|
TimeProvider |
Time source representing the current system time in nanos.
|
TransportTracer.FlowControlReader |
An interface for reading the local and remote flow control windows of the transport.
|
WritableBuffer |
An interface for a byte buffer that can only be written to.
|
WritableBufferAllocator |
An allocator of buffers provided by the transport implementation to
MessageFramer so
it can send chunks of data to the transport in a form that the transport can directly serialize. |
Class | Description |
---|---|
AbstractClientStream |
The abstract base class for
ClientStream implementations. |
AbstractClientStream.TransportState |
This should only called from the transport thread.
|
AbstractManagedChannelImplBuilder<T extends AbstractManagedChannelImplBuilder<T>> |
The base class for channel builders.
|
AbstractReadableBuffer |
Abstract base class for
ReadableBuffer implementations. |
AbstractServerImplBuilder<T extends AbstractServerImplBuilder<T>> |
The base class for server builders.
|
AbstractServerStream |
Abstract base class for
ServerStream implementations. |
AbstractServerStream.TransportState |
This should only called from the transport thread (except for private interactions with
AbstractServerStream ). |
AbstractStream |
The stream and stream state as used by the application.
|
AbstractStream.TransportState |
Stream state as used by the transport.
|
ApplicationThreadDeframer |
Sits between
AbstractStream.TransportState and MessageDeframer to deframe in the
client thread. |
AtomicBackoff |
A
long atomically updated due to errors caused by the value being too small. |
AutoConfiguredLoadBalancerFactory | |
CensusStatsModule |
Provides factories for
StreamTracer that records stats to Census. |
ClientTransportFactory.ClientTransportOptions |
Options passed to
#newClientTransport(SocketAddress, ClientTransportOptions) . |
CompositeReadableBuffer |
A
ReadableBuffer that is composed of 0 or more ReadableBuffer s. |
DeprecatedCensusConstants |
Holder class for the deprecated OpenCensus constants.
|
DnsNameResolverProvider |
A provider for
DnsNameResolver . |
ExponentialBackoffPolicy |
Retry Policy for Transport reconnection.
|
ExponentialBackoffPolicy.Provider | |
FailingClientStream |
An implementation of
ClientStream that fails (by calling ClientStreamListener.closed(io.grpc.Status, io.grpc.Metadata) ) when started, and silently does nothing for the other operations. |
FixedObjectPool<T> |
An object pool that always returns the same instance and does nothing when returning the object.
|
ForwardingReadableBuffer |
Base class for a wrapper around another
ReadableBuffer . |
GrpcAttributes |
Special attributes that are only useful to gRPC.
|
GrpcUtil |
Common utilities for GRPC.
|
Http2ClientStreamTransportState |
Base implementation for client streams using HTTP2 as the transport.
|
Http2Ping |
Represents an outstanding PING operation on an HTTP/2 channel.
|
InsightBuilder |
Builds a concise and readable string that gives insight of the concerned part of the system.
|
InUseStateAggregator<T> |
Aggregates the in-use state of a set of objects.
|
JsonParser |
Parses JSON with as few preconceived notions as possible.
|
KeepAliveManager |
Manages keepalive pings.
|
KeepAliveManager.ClientKeepAlivePinger |
Default client side
KeepAliveManager.KeepAlivePinger . |
LogExceptionRunnable |
A simple wrapper for a
Runnable that logs any exception thrown by it, before
re-throwing it. |
MessageDeframer |
Deframer for GRPC frames.
|
MessageFramer |
Encodes gRPC messages to be delivered via the transport layer which implements
MessageFramer.Sink . |
NoopClientStream |
An implementation of
ClientStream that silently does nothing for the operations. |
PickFirstLoadBalancerProvider |
Provider for the "pick_first" balancing policy.
|
ReadableBuffers |
Utility methods for creating
ReadableBuffer instances. |
ReflectionLongAdderCounter |
A
LongCounter that is implemented with a JDK8 LongAdder . |
SerializingExecutor | |
ServerImpl |
Default implementation of
Server , for creation by transports. |
ServiceConfigUtil |
Helper utility to work with service configs.
|
ServiceConfigUtil.LbConfig |
A LoadBalancingConfig that includes the policy name (the key) and its raw config value (parsed
JSON).
|
SharedResourceHolder |
A holder for shared resource singletons.
|
SharedResourcePool<T> |
An ObjectPool backed by a
SharedResourceHolder.Resource . |
StatsTraceContext |
The stats and tracing information for a stream.
|
TransportFrameUtil |
Utility functions for transport layer framing.
|
TransportTracer |
A class for gathering statistics about a transport.
|
TransportTracer.Factory | |
TransportTracer.FlowControlWindows |
A container that holds the local and remote flow control window sizes.
|
Enum | Description |
---|---|
ClientStreamListener.RpcProgress |
The progress of the RPC when client stream listener is closed.
|
GrpcUtil.Http2Error |
All error codes identified by the HTTP/2 spec.
|
All the content under this package and its subpackages are considered annotated with Internal
.
Copyright © 2019. All rights reserved.