Reports number of valid and invalid resources. @param validResourceCount Number of resources that were valid. @param invalidResourceCount Number of r

Reports number of xDS servers going from healthy to unhealthy. @param serverFailure Number of xDS server failures. @param xdsServer Target URI of the

Reports that a stream closed with the specified Status.

For all logical dns clusters refresh their results.

Fetches details about the remote Service from PackageManager without binding to it. <p>Resolving an untrusted address before binding to it lets you s

Schedule a task to be run when the deadline expires. <p>Note if this deadline was created with a custom {@link Ticker}, the {@code scheduler}'s under

Either execute the write action directly, or buffer the action and let the container thread drain it. <p>Called from application thread.

Schedules the next response chunk to be dispatched. If all input has been received and there are no more chunks in the queue, the stream is closed.

Provides a custom security policy. <p>This is optional. If the user has not provided a security policy, the server will default to only accepting cal

Returns false if the needle was not found and the current index was left unchanged.

Send a handshaker request and return the handshaker response.

Sends a discovery request with the given {@code versionInfo}, {@code nonce} and {@code errorDetail}. Used for reacting to a specific discovery respons

Sends as many bytes as are available from the handshaker to the remote peer.

Serializes all metadata entries, leaving some values as {@link InputStream}s. <p>Produces serialized names and values interleaved. result[i 2] are na

Create a server plaintext handler factory for gRPC.

<pre> Simple server-to-client streaming RPC. </pre>

Only call this from this SerializingExecutor Runnable, so that the executor is immediately visible to this SerializingExecutor executor.

Sets the executor to be used for calling into the application. <p>Required.

Sets a global feature flag to 'value' using 'setter' and arranges for its previous value to be unconditionally restored when the test completes.

The interval between outlier detection sweeps.

Sets the "listen" address for this server. <p>This is somewhat of a grpc-java formality. Binder servers don't really listen, rather, Android creates

Sets the listener to receive notifications. Must be called in the context of the transport thread.

Sets the local identity of the client in the form of a UID. The client may set at most 1 local identity. If no local identity is specified, then the S

Sets a {@link Runnable} to be executed when the call is closed cleanly from the server's point of view: either {@link #onCompleted()} or {@link #onErr

See {@link Args#getOverrideAuthority()}. This is an optional field. @since 1.49.0

The failure percentage that will result in an address being considered an outlier.

Specifies which version of the client handshake to use.

Initiates an orderly shutdown in which preexisting calls continue but new calls are rejected. After this call returns, this server has released the li

Shuts down the Subchannel. After this method is called, this Subchannel should no longer be returned by the latest {@link SubchannelPicker picker}, a

Override the default {@link ServerSocketFactory} used to listen. If the socket factory is not set or set to null, a default one will be used.

Override the default {@link SSLSocketFactory} and enable TLS negotiation.

Start the initial scheduled shutdown given the transport status reaches max connection idle. @param closeJob Closes the connection by sending GO_AWAY

Establishes load reporting communication and negotiates with traffic director to report load stats periodically. Calling this method on an already sta