Sends a request and returns the response. Caller must wait until this method executes prior to calling it again. If this method throws {@code Connecti

Sets the effective deadline of the RPC.

Set to enable failure percentage ejection.

See {@link Args#getScheduledExecutorService}.

Sets {@link Verification}, mode when authenticating the peer certificate. By default, {@link Verification#CERTIFICATE_AND_HOST_NAME_VERIFICATION} valu

The stream is being created on a ready transport. @param headers the mutable initial metadata. Modifications to it will be sent to the socket but

Serialize a metadata value to bytes. @param value to serialize @return serialized version of value

Translates a gRPC authorization policy in JSON string to Envoy RBAC policies. On success, will return one of the following - 1. One allow RBAC policy

Given a JSON list of LoadBalancingConfigs, and convert it into a list of LbConfig.

Returns a new {@code CallOptions} with a {@code ClientStreamTracerFactory} in addition to the existing factories. <p>This method doesn't replace exis

Enables <a href="https://github.com/grpc/grpc/blob/master/doc/wait-for-ready.md"> 'wait for ready'</a> for the call. Wait-for-ready queues the RPC unt

Registers a callback that is invoked when the ping operation completes. If this ping operation is already completed, the callback is invoked immediate

Poll the next metrics record and check it against the provided information, including the message sizes.

Creates a new builder for creating {@link HeaderMutationRulesConfig} instances.

<pre> Performs authorization check based on the attributes associated with the incoming request, and returns status `OK` or not `OK`. </pre>

Returns whether the given Android UID is authorized to access a particular service. <p><b>IMPORTANT</b>: This method may block for extended periods o

Verify stats were published through the tracer. @param sizes in the format {wire0, uncompressed0, wire1, uncompressed1, ...}

Set ciphers and APN appropriate for gRPC. Precisely what is set is permitted to change, so if an application requires particular settings it should ov

Copies the data from input stream to output stream.

Record the event elapsed time to the histogram and delay initiation of the next event based on the load distribution.

Returns the estimated number of entry of the cache. Note that the size can be larger than its true size, because there might be already expired cache.

Returns the percent-decoded "Authority" component of this URI, or null if not present. <p>NB: This method's decoding is lossy -- It only exists for c

Returns the percent-decoded "fragment" component of this URI, or null if not present. <p>NB: This method assumes the fragment was encoded as UTF-8, a

Returns the unique index of this metric instrument. @return the index of the metric instrument.

A collection of {@link MethodDescriptor} instances describing the methods exposed by the service. @since 1.0.0

Gets a number from an object for the given key. If the key is not present, this returns null. If the value does not represent a double, throws an exc

Gets a number from an object for the given key, casted to an long. If the key is not present, this returns null. If the value does not represent a l

Provides a partially implemented instance of {@link ScheduledExecutorService} that uses the fake clock ticker for testing.

Gets a string from an object for the given key, parsed as a duration (defined by protobuf). If the key is not present, this returns null. If the val

Must be holding 'lock' when calling.

Returns whether this method is safe. <p>A safe request does nothing except retrieval so it has no side effects on the server side. @since 1.1.0

Returns true iff the number of reported bytes sent but not yet acknowledged is greater than or equal to {@code maxUnackedBytes}.

Returns the name of the lookup service as a gRPC URI. Typically, this will be a subdomain of the target, such as "lookup.datastore.googleapis.com".

Creates a new negotiator.

Returns the next captured outbound message event.

Returns the next captured outbound message event.

Parses a URI string, applies validation rules described in SPIFFE standard, and, in case of success, returns parsed TrustDomain and Path. @param uri

Parse a serialized metadata value from bytes. @param serialized value of metadata to parse @return a parsed instance of type T

Sets the maximum expected interval of receiving out-of-band ORCA report. The actual reporting interval might be smaller if there are other load balanc

Starts the resolution. The method is not supposed to throw any exceptions. That might cause the Channel that the name resolver is serving to crash. Er

Use reflection to perform a basic sanity test. The forwarding class should forward all public methods to the delegate, except for those in skippedMeth

Update the in-use state of an object. Initially no object is in use. <p>This may call into {@link #handleInUse} or {@link #handleNotInUse} when appro

Verifies the LDS update against the golden Listener with vhosts {@link #testListenerVhosts}.

Adds a {@link ServerStreamTracer.Factory} to measure server-side traffic. The order of factories being added is the order they will be executed. @re

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

Executes a client-streaming call returning a {@link StreamObserver} for the request messages. The {@code call} should not be already started. After c

Causes future invocations of {@link AtomicBackoff#getState} to have a value at least double this state's value. Subsequent calls to this method will n