Checks whether the given item exists in the iterable. This is copied from Guava Collect's {@code Iterables.contains()} because Guava Collect is not A

Test JWT-based auth.

Sets a custom keepalive time, the delay time for sending next keepalive ping. An unreasonably small value might be increased, and {@code Long.MAX_VALU

{@inheritDoc} @since 1.3.0

Sets a custom keepalive timeout, the timeout for keepalive ping requests. An unreasonably small value might be increased. @since 1.3.0

Sets whether keepalive will be performed when there are no outstanding RPC on a connection. Defaults to {@code false}. <p>Clients must receive permis

Create server and start it

Blocking server-streaming example. Calls listFeatures with a rectangle of interest. Prints each response feature as it arrives.

Example for testing blocking server-streaming.

Blocking server-streaming example. Calls listFeatures with a rectangle of interest. Prints each response feature as it arrives.

Accessor for method.

Generates a string that represents the locality in the LB policy config. The string is unique across all localities in all clusters.

The main application allowing this server to be launched from the command line.

The main application allowing this client to be launched from the command line.

Decides in current situation whether or not the RPC should retry and if it should retry how long the backoff should be. The decision does not take the

Returns {@code true} iff {@code hostName} matches the domain name {@code pattern} with case-insensitive. <p>Wildcard pattern rules: <ol> <li>A single

The maximum number of concurrent calls permitted for each incoming connection. Defaults to no limit.

Sets the maximum connection age, connections lasting longer than which will be gracefully terminated. An unreasonably small value might be increased.

Sets a custom max connection age, connection lasting longer than which will be gracefully terminated. An unreasonably small value might be increased.

Sets the grace time for the graceful connection termination. Once the max connection age is reached, RPCs have the grace time to complete. RPCs that d

Sets a custom grace time for the graceful connection termination. Once the max connection age is reached, RPCs have the grace time to complete. RPCs t

Sets the maximum connection idle time, connections being idle for longer than which will be gracefully terminated. Idleness duration is defined since

Sets a custom max connection idle time, connection being idle for longer than which will be gracefully terminated. Idleness duration is defined since

Sets a custom max connection idle time, connection being idle for longer than which will be gracefully terminated. Idleness duration is defined since

Sets the maximum message size allowed to be received on the server. If not called, defaults to defaults to 4 MiB. The default provides protection to s

{@inheritDoc}

Sets the maximum size of metadata allowed to be received. Defaults to 8 KiB. <p>The implementation does not currently limit memory usage; this value

Sets the maximum size of metadata allowed to be received. This is cumulative size of the entries with some overhead, as defined for <a href="http://ht

Refreshes cache entry by creating {@link PendingCacheEntry}. When the {@code PendingCacheEntry} received data from RLS server, it will replace the dat

Throw exception if there is an outstanding exception.

At the end of a timer run we need to decrement the ejection time multiplier for trackers that don't have ejected subchannels and uneject ones that hav

Modify the given {@link OrcaLoadReport.Builder} containing metrics for {@link MetricRecorder} such that metrics from the given {@link MetricReport} fo

Create a {@link Metadata.Key} for passing a Parcelable object in the metadata of an RPC, treating instances as mutable. <p><b>Note:<b/>Parcelables ca

Creates a new blocking-style stub that supports unary and streaming output calls on the service

Creates a new blocking-style stub that supports unary and streaming output calls on the service

Creates a new blocking-style stub that supports unary and streaming output calls on the service

Creates a new blocking-style stub that supports unary and streaming output calls on the service

Creates a new blocking-style stub that supports all types of calls on the service

Returns a new instance of {@link Builder}. @since 1.43.0