Uses of Package
io.grpc.internal
Packages that use io.grpc.internal
Package
Description
The in-process transport which is for when a server is in the same process as the client.
Interfaces and implementations that are internal to gRPC.
The main transport implementation based on Netty,
for both the client and the server.
Service definitions and utilities with protobuf dependency for the pre-defined gRPC services.
API that implements gRPC server as a servlet.
API that implements gRPC server as a servlet.
Utilities with advanced features in the core layer that user can optionally use.
-
Classes in io.grpc.internal used by io.grpc.grpclbClassDescriptionDetermines how long to wait before doing some action (typically a retry, or a reconnect).A DNS-based
NameResolver
.AddressResolver resolves a hostname into a list of addresses.Used as a DNS-based name resolver's internal representation of resolution result.DnsNameResolver.ResourceResolver
is a Dns ResourceRecord resolver.Defines a resource, and the way to create and destroy instances of it.Time source representing the current system time in nanos. -
Classes in io.grpc.internal used by io.grpc.inprocessClassDescriptionExtension of
Stream
to support client-side termination semantics.An observer of client-side stream events.The client-side transport typically encapsulating a single connection to a remote server.A callback that is invoked when the acknowledgement to aClientTransport.ping(io.grpc.internal.ClientTransport.PingCallback, java.util.concurrent.Executor)
is received.Pre-configured factory for creatingConnectionClientTransport
instances.AManagedClientTransport
that is based on a connection.Builds a concise and readable string that gives insight of the concerned part of the system.An object that accepts new incoming connections on one or more listening socket addresses.Aggregates the in-use state of a set of objects.Default managed channel builder, for usage in Transport implementations.AClientTransport
that has life-cycle management.Receives notifications for the transport life-cycle events.An object pool.Default builder forServer
instances, for usage in Transport implementations.A listener to a server for transport creation events.Extension ofStream
to support server-side termination semantics.An observer of server-side stream events.An inbound connection.A observer of a server-side transport for stream creation events.The stats and tracing information for a stream.A single stream of communication between two end-points within a transport.A producer for deframed gRPC messages. -
Classes in io.grpc.internal used by io.grpc.internalClassDescriptionA sink for outbound operations, separated from the stream simply to avoid name collisions/confusion.This should only be called from the transport thread.Abstract base class for
ReadableBuffer
implementations.A sink for outbound operations, separated from the stream simply to avoid name collisions/confusion.This should only be called from the transport thread (except for private interactions withAbstractServerStream
).The stream and stream state as used by the application.Stream state as used by the transport.The base interface of the Subchannels returned byLoadBalancer.Helper.createSubchannel(io.grpc.LoadBalancer.CreateSubchannelArgs)
.Listener for when deframing on the application thread, which calls the real listener on the transport thread.Determines how long to wait before doing some action (typically a retry, or a reconnect).A collection of call stats for channelz.Tracks a collections of channel tracing events for a channel/subchannel.Implementation ofClientCall
.Provider ofClientStream
s.Extension ofStream
to support client-side termination semantics.An observer of client-side stream events.The progress of the RPC when client stream listener is closed.The client-side transport typically encapsulating a single connection to a remote server.A callback that is invoked when the acknowledgement to aClientTransport.ping(io.grpc.internal.ClientTransport.PingCallback, java.util.concurrent.Executor)
is received.Pre-configured factory for creatingConnectionClientTransport
instances.AReadableBuffer
that is composed of 0 or moreReadableBuffer
s.A simple read operation to perform on a singleReadableBuffer
.AManagedClientTransport
that is based on a connection.Manages connectivity states of the channel.Utility base implementation ofRunnable
that performs the same function asContext.wrap(Runnable)
without requiring the construction of an additional object.Interface for deframing gRPC messages.A call that queues requests before a real call is ready to be delegated to.A client transport that queues requests before a real transport is available.A stream that queues requests before the transport is available, and delegates to a real stream implementation when the transport is available.AddressResolver resolves a hostname into a list of addresses.Used as a DNS-based name resolver's internal representation of resolution result.DnsNameResolver.ResourceResolver
is a Dns ResourceRecord resolver.DnsNameResolver.ResourceResolverFactory
is a factory for making resource resolvers.Describes a parsed SRV record.Retry Policy for Transport reconnection.A client transport that creates streams that will immediately fail when started.Forwards listener callbacks to a delegate.A forwarding class to ensure non overridden methods are forwarded to the delegate.Interface for framing gRPC messages.All error codes identified by the HTTP/2 spec.Processes gzip streams, delegating toInflater
to perform on-demand inflation of the deflated blocks.Reads gzip header and trailer bytes from the inflater's buffer (if bytes beyond the inflate block were given to the inflater) and then fromgzippedData
, and handles updating the CRC and the count of gzipped bytes consumed.Hedging policy data object.Builds a concise and readable string that gives insight of the concerned part of the system.An object that accepts new incoming connections on one or more listening socket addresses.Transports for a singleSocketAddress
.Index as in 'i', the pointer to an entry.Aggregates the in-use state of a set of objects.An interface for a long base counter.A communication channel for making outgoing RPCs.Lazily request for Executor from an executor pool.A ResolutionState indicates the status of last name resolution.A registry that prevents channel shutdown from killing existing retry attempts that are in backoff.Default managed channel builder, for usage in Transport implementations.An interface for Transport implementors to provide a default port toNameResolver
for use in cases where the target string doesn't include a port.An interface for Transport implementors to provide theClientTransportFactory
appropriate for the channel.Best effort detecting channels that has not been properly cleaned up.ManagedChannelServiceConfig
is a fully parsed and validated representation of service configuration data.Equivalent of MethodConfig from a ServiceConfig with restrictions from Channel setting.AClientTransport
that has life-cycle management.Receives notifications for the transport life-cycle events.Deframer for GRPC frames.A listener of deframing events.Encodes gRPC messages to be delivered via the transport layer which implementsMessageFramer.Sink
.Produce a collection ofWritableBuffer
instances from the data written to anOutputStream
.OutputStream whose write()s are passed to the framer.Sink implemented by the transport layer to receive frames and forward them to their destination.An implementation ofClientStream
that silently does nothing for the operations.An object pool.A ManagedChannel backed by a singleInternalSubchannel
and used forLoadBalancer
to its own RPC needs.ALoadBalancer
that provides no load-balancing over the addresses from theNameResolver
.Index as in 'i', the pointer to an entry.This interface makes unit testing easier by avoiding direct calls to static methods.Interface for an abstract byte buffer.AReadableBuffer
that is backed by a byte array.AReadableBuffer
that is backed by aByteBuffer
.Reschedules a runnable lazily.A logicalClientStream
that is retriable.Used to keep track of the total amount of memory used to buffer retryable or hedged RPCs for the Channel.Allows cancelling a Future without racing with setting the future.A wrapper of a physical stream of a retry/hedging attempt, that comes with some useful attributes.Used for retry throttling.Simple callback class to store inNameResolver.ResolutionResult
attributes so that ManagedChannel can indicate if the resolved addresses were accepted.Retry policy data object.This interface is used to schedule future retry attempts for a failed operation.Default implementation ofServer
, for creation by transports.Default builder forServer
instances, for usage in Transport implementations.An interface to provide to provide transport specific information for the server.A listener to a server for transport creation events.Extension ofStream
to support server-side termination semantics.An observer of server-side stream events.An inbound connection.A observer of a server-side transport for stream creation events.A LoadBalancingConfig that includes the policy name (the key) and its raw config value (parsed JSON).A holder for shared resource singletons.Defines a resource, and the way to create and destroy instances of it.An ObjectPool backed by aSharedResourceHolder.Resource
.Represents a SPIFFE trust bundle; that is, a map from trust domain to set of trusted certificates.Represents a SPIFFE ID as defined in the SPIFFE standard.The stats and tracing information for a stream.A single stream of communication between two end-points within a transport.An observer ofStream
events.A producer for deframed gRPC messages.ADeframer
that optimizations by taking over part of the thread safety.Time source representing the current system time in nanos.Provides transports for sending RPCs.A class for gathering statistics about a transport.An interface for reading the local and remote flow control windows of the transport.A container that holds the local and remote flow control window sizes.An interface for a byte buffer that can only be written to.An allocator of buffers provided by the transport implementation toMessageFramer
so it can send chunks of data to the transport in a form that the transport can directly serialize. -
Classes in io.grpc.internal used by io.grpc.nettyClassDescriptionThe abstract base class for
ClientStream
implementations.A sink for outbound operations, separated from the stream simply to avoid name collisions/confusion.This should only be called from the transport thread.Abstract base class forReadableBuffer
implementations.Abstract base class forServerStream
implementations.A sink for outbound operations, separated from the stream simply to avoid name collisions/confusion.This should only be called from the transport thread (except for private interactions withAbstractServerStream
).The stream and stream state as used by the application.Stream state as used by the transport.Along
atomically updated due to errors caused by the value being too small.Extension ofStream
to support client-side termination semantics.The client-side transport typically encapsulating a single connection to a remote server.A callback that is invoked when the acknowledgement to aClientTransport.ping(io.grpc.internal.ClientTransport.PingCallback, java.util.concurrent.Executor)
is received.Pre-configured factory for creatingConnectionClientTransport
instances.AManagedClientTransport
that is based on a connection.Base implementation for client streams using HTTP2 as the transport.Represents an outstanding PING operation on an HTTP/2 channel.An object that accepts new incoming connections on one or more listening socket addresses.Aggregates the in-use state of a set of objects.Monitors the client's PING usage to make sure the rate is permitted.Manages keepalive pings.Default managed channel builder, for usage in Transport implementations.An interface for Transport implementors to provide a default port toNameResolver
for use in cases where the target string doesn't include a port.An interface for Transport implementors to provide theClientTransportFactory
appropriate for the channel.AClientTransport
that has life-cycle management.Receives notifications for the transport life-cycle events.Monitors connection idle time; shutdowns the connection if the max connection idle is reached.A listener of deframing events.Sink implemented by the transport layer to receive frames and forward them to their destination.An object pool.Interface for an abstract byte buffer.Default builder forServer
instances, for usage in Transport implementations.An interface to provide to provide transport specific information for the server.A listener to a server for transport creation events.Extension ofStream
to support server-side termination semantics.An inbound connection.A observer of a server-side transport for stream creation events.Defines a resource, and the way to create and destroy instances of it.The stats and tracing information for a stream.A single stream of communication between two end-points within a transport.A class for gathering statistics about a transport.An interface for reading the local and remote flow control windows of the transport.A container that holds the local and remote flow control window sizes.An interface for a byte buffer that can only be written to.An allocator of buffers provided by the transport implementation toMessageFramer
so it can send chunks of data to the transport in a form that the transport can directly serialize. -
Classes in io.grpc.internal used by io.grpc.protobuf.servicesClassDescriptionDetermines how long to wait before doing some action (typically a retry, or a reconnect).
-
Classes in io.grpc.internal used by io.grpc.rlsClassDescriptionDetermines how long to wait before doing some action (typically a retry, or a reconnect).An object pool.
-
Classes in io.grpc.internal used by io.grpc.servletClassDescriptionAbstract base class for
ServerStream
implementations.A sink for outbound operations, separated from the stream simply to avoid name collisions/confusion.This should only be called from the transport thread (except for private interactions withAbstractServerStream
).The stream and stream state as used by the application.Stream state as used by the transport.An object that accepts new incoming connections on one or more listening socket addresses.A listener of deframing events.Sink implemented by the transport layer to receive frames and forward them to their destination.Default builder forServer
instances, for usage in Transport implementations.A listener to a server for transport creation events.Extension ofStream
to support server-side termination semantics.An inbound connection.A observer of a server-side transport for stream creation events.The stats and tracing information for a stream.A single stream of communication between two end-points within a transport.A class for gathering statistics about a transport.An interface for a byte buffer that can only be written to. -
Classes in io.grpc.internal used by io.grpc.servlet.jakartaClassDescriptionAbstract base class for
ServerStream
implementations.A sink for outbound operations, separated from the stream simply to avoid name collisions/confusion.This should only be called from the transport thread (except for private interactions withAbstractServerStream
).The stream and stream state as used by the application.Stream state as used by the transport.An object that accepts new incoming connections on one or more listening socket addresses.A listener of deframing events.Sink implemented by the transport layer to receive frames and forward them to their destination.Default builder forServer
instances, for usage in Transport implementations.A listener to a server for transport creation events.Extension ofStream
to support server-side termination semantics.An inbound connection.A observer of a server-side transport for stream creation events.The stats and tracing information for a stream.A single stream of communication between two end-points within a transport.A class for gathering statistics about a transport.An interface for a byte buffer that can only be written to. -
Classes in io.grpc.internal used by io.grpc.utilClassDescriptionTime source representing the current system time in nanos.