A decision to fail an RPC immediately. This is a final decision and will ignore retry policy. @param status the status with which the RPC will fail.

Create a new context with the given key value set. The new context will cascade cancellation from its parent.

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

Closes underlying resources.

Allows implementations to modify the channel builder. @param channelBuilder the channel builder being constructed

Allows implementations to modify the server builder. @param serverBuilder the server builder being constructed

Converts the signature algorithm to an enum understood by S2A. @param signatureAlgorithm the int representation of the signature algorithm define by

Server routing configuration.

Constructs a CidrMatcher with this prefix and prefix length. Do not provide string addressPrefix constructor to avoid IO exception handling.

Creates a {@link CertificateProvider} plugin. @param config configuration needed by the Provider to create the CertificateProvider. A form of JSO

Provides a service config to the channel. The channel will use the default service config when the name resolver provides no service config or if the

Returns the underlying Subchannel.

Provides an EventGroupLoop to be used by the netty transport. <p>It's an optional parameter. If the user has not provided an EventGroupLoop when the

Creates a new builder for the given target that will be resolved by {@link io.grpc.NameResolver}.

The same attributes passed to {@link Helper#createSubchannel Helper.createSubchannel()}. LoadBalancer can use it to attach additional information here

Returns a list of required label keys for this metric instrument. @return a list of required label keys.

<pre> Gets all server sockets that exist in the process. </pre>

Returns the server tracer factory.

Delivers a binder transaction to this handler. <p>Implementations need not be thread-safe. Each invocation "happens-before" the next in the same orde

Does additional setup jobs. Call it manually when necessary.

Creates a {@link Marshaller} for protos of the same type as {@code defaultInstance}. @since 1.0.0

Return true if exact metric values should be checked.

Returns a client interceptor that attaches a set of headers to requests. @param extraHeaders the headers to be passed by each call that is processed

Returns a Builder for {@link CachingRlsLbClient}.

Notifies the listener when any cache entry is evicted. Implementation can assume that this method is called serially. Implementation should be non blo

Provides a hint that directExecutor is being used by the listener for callbacks to the application. No action is required. There is no requirement tha

Headers has been sent to the socket.

Parses the {@link io.envoyproxy.envoy.extensions.filters.http.ext_authz.v3.ExtAuthz} proto to create an {@link ExtAuthzConfig} instance. @param extAu

Parses the top-level filter config from raw proto message. The message may be either a {@link com.google.protobuf.Any} or a {@link com.google.protobuf

Translate StringMatcher envoy proto to internal StringMatcher.

Given a target address, returns a proxied address if a proxy should be used. If no proxy should be used, then return value will be {@code null}. <p>I

Records a request finished with the given status.

Records a request being issued.

Records a call metric measurement for request cost. If RPC has already finished, this method is no-op. <p>A latter record will overwrite its former n

Records a call metric measurement for utilization in the range [0, 1]. Values outside the valid range are ignored. If RPC has already finished, this m

Reports whether xDS client has a "working" ADS stream to xDS server. The definition of a working stream is defined in gRFC A78. @see <a href="htt

Will shutdown existing server if needed. Then creates a new server in the same way as {@link #starting(Description)} and starts it.