Sets the {@link io.opentelemetry.api.OpenTelemetry} entrypoint to use. This can be used to configure OpenTelemetry by returning the instance created b

Sets the {@link io.opentelemetry.api.OpenTelemetry} entrypoint to use. This can be used to configure OpenTelemetry by returning the instance created b

Only eject this percentage of outliers.

Sets whether the method is idempotent. If true, calling this method more than once doesn't have additional side effects. If {@code false}, method is

Waits for the next "check authorization" request to be made and returns it, throwing in case no request arrives in time.

Called by subclasses for the terminal trailer metadata on a stream. @param trailers the received terminal trailer metadata

Returns a new stub with a deadline that is after the given {@code duration} from now. @since 1.0.0 @see CallOptions#withDeadlineAfter

Provides the worker EventGroupLoop to the server. <p>It's an optional parameter. If the user has not provided one when the server is built, the build

HTTP/2 only.

Creates a {@link ServerCallHandler} for a server streaming method of the service. @param method an adaptor to the actual method on the service implem

Initiates a client streaming call over the specified channel. It returns an object which can be used in a blocking manner to retrieve responses.. <p

Uses the FilterConfigs produced above to produce an HTTP filter interceptor for the server.

Casts a list of unchecked JSON values to a list of checked objects in Java type. If the given list contains a value that is not a Map, throws an excep

Returns the cipher suites to use for a connection. This method can return {@code null} if the cipher suites enabled by default should be used.

A template for the name of the Listener resource to subscribe to for a gRPC client channel. Used only when the channel is created with an "xds:" URI w

Close when any messages currently queued have been requested and delivered.

Returns the default target to use if needed. If nonempty (implies request processing strategy SYNC_LOOKUP_DEFAULT_TARGET_ON_ERROR is set), it will be

Called when a {@link #deframe(ReadableBuffer)} operation failed. @param cause the actual failure

Perform some simple checks on sslContext.

Returns the SPIFFE ID from the leaf certificate, if present. @param certChain certificate chain to extract SPIFFE ID from

Creates a SslContextProvider. Used for retrieving a client-side SslContext.

Called when a stream is closed. We do things like: <ul> <li>Removing the stream from the map. <li>Optionally reporting the status. <li>Starting pendin

The request header value should exist.

Try to get an existing instance of the given resource. If an instance does not exist, create a new one with the given factory. @param resource the si

Returns the attributes.

Get filters for client logging.

Returns the {@link ComponentName} of this binding {@link Intent}, or null if one isn't set.

Deadline ticker of the FakeClock.

Gets the User-Agent string for the gRPC transport.

Gets an {@code OrcaPerRequestUtil} instance that provides actual implementation of {@link #newOrcaClientStreamTracerFactory}.

Returns to the default number of bytes that must be queued before the call will leave the <a href="https://github.com/grpc/grpc/blob/master/doc/wait-f

Returns the port number the server is listening on. This can return -1 if there is no actual port or the result otherwise does not make sense. Resul

A priority, from 0 to 10 that this provider should be used, taking the current environment into consideration. 5 should be considered the default, and

Returns the address to the proxy, which is already resolved.

Returns the host component of this URI in its originally parsed, possibly percent-encoded form.

Get filters for server logging.

Returns {@code true} if the pick was not created with {@link #withNoResult()}.