Returns the state.

Calculates throttleProbability. <pre> throttleProbability = (requests - ratio_for_accepts accepts) / (requests + requests_padding) </pre>

Returns the TLS extension type available (ALPN and NPN, NPN, or None).

Returns the received trailers. @since 1.0.0

Counts how many addresses are in a given address group.

Returns a {@link ProtocolNegotiator} that does HTTP CONNECT proxy negotiation.

Returns true iff this URI has a scheme and an authority/path hierarchy, but no fragment. <p>All instances of {@link Uri} are RFC 3986 URIs, not "rela

Indicates whether or not the given value is a valid gRPC content-type.

Returns whether the channel is shutdown. Shutdown channels immediately cancel any new calls, but may still have some calls being processed. @see #shu

Logs the response header. Binary logging equivalent of logServerHeader.

Captures the last received metadata on a channel. Useful for testing. @param headersCapture to record the last received headers @param trailersCaptur

Factory method for the client-side.

Creates a new ListenableFuture-style stub that supports unary calls on the service

Creates a new handshaker.

Event handler to be called by the subclass when the stream's headers have passed any connection flow control (i.e., MAX_CONCURRENT_STREAMS). It may ca

There are outstanding RPCs on the transport.

Returns effective providers, in priority order.

Registers a new Double Histogram metric instrument. @param name the name of the metric @param description a description of the metric @param unit the

Registers a new Long Gauge metric instrument. @param name the name of the metric @param description a description of the metric @param unit the unit

Remove the metrics data entry corresponding to the specified key.

Runs the given listener when this promise is fulfilled, or immediately if already fulfilled. @throws RuntimeException if already fulfilled and 'liste

Serialize all the metadata entries. <p>It produces serialized names and values interleaved. result[i 2] are names, while result[i 2+1] are values. <

A template for the name of the Listener resource to subscribe to for a gRPC server. <p>If starts with "xdstp:", will be interpreted as a new-style na

Create a server plaintext handler for gRPC.

Create a server TLS handler for HTTP/2 capable of using ALPN/NPN. @param executorPool a dedicated {@link Executor} pool for time-consuming TLS tasks

Sets the parsed config. This field is required. @return this

Disable or enable stats features. Enabled by default.

Sets the subchannels.

Sets java system property 'key' to 'value' and arranges for its previous value to be unconditionally restored when the test completes.

Disable or enable tracing features. Enabled by default.

{@code maxQueuedControlFrames} is only effective for frames written with {@link #limitControlFramesWriter(FrameWriter)}.

Swaps to a new ChannelCredentials with all other settings unchanged. Returns null if the ChannelCredentials is not supported by the current ClientTran

Returns the next {@link OneWayBinderProxy} that needs decorating, blocking if it hasn't yet been provided to {@link #decorate}. <p>Follow this with a

Returns a {@link ProtocolNegotiator} that ensures the pipeline is set up so that TLS will be negotiated, the {@code handler} is added and writes to th

Convert a {@link com.google.rpc.Status} instance to a {@link StatusException}. <p>The returned {@link StatusException} will wrap a {@link Status} who

Called by subclasses whenever a data frame is received from the transport. @param frame the received data frame @param endOfStream {@code true} if th

Override the default executor necessary for internal transport use. <p>The channel does not take ownership of the given executor. It is the caller' r

The proto message types supported by this filter. A filter will be registered by each of its supported message types.

Unbind from the remote service if connected. <p>Observers will be notified with reason code {@code CANCELLED}. <p>Subsequent calls to {@link #bind()

Verifies the RDS update against the golden route config {@link #testRouteConfig}.

Adds a socket.