Indicates whether or not this deframer has been closed.

Return true if the cpu utilization or application specific utilization value is in the range [0, inf) and false otherwise. Occasionally users have ove

Used for identifying whether or not when getting a control plane for authority that this control plane should be skipped over if there is a fallback.

Indicates whether or not the Jetty ALPN jar is installed in the boot classloader.

Indicates whether or not the Jetty NPN jar is installed in the boot classloader.

Returns {@code true} if currently running on Google Cloud Platform (GCP).

Creates {@link SecurityPolicy} which checks if the app is a profile owner app. See {@link DevicePolicyManager}.

Creates {@link SecurityPolicy} which checks if the app is a profile owner app on an organization-owned device. See {@link DevicePolicyManager}.

Return true if a rate value (such as qps or eps) is in the range [0, inf) and false otherwise.

Whether the stream is a transparent retry. @since 1.40.0

Return true if the utilization value is in the range [0, 1] and false otherwise.

Logs cancellation.

Logs the cancellation.

Logs half close.

Logs the RPC message.

Logs the message message. The number of bytes logged is determined by the binary logging configuration.

Returns a decompressor for the given message encoding, or {@code null} if none has been registered. <p>This ignores whether the compressor is adverti

Construct a {@link SimpleResponse} for the given request.

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

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

Returns TCP_USER_TIMEOUT channel option for Epoll channel if Epoll is available, otherwise null.

Check if all resources have results, and if so, generate a new XdsConfig and send it to all the watchers.

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

Returns a new test-specific {@link NameResolver.Args} instance.

Returns a new server that when started will be able to be connected to from the client. Each returned instance should be new and yet be accessible by

Creates a new async stub that supports all call types for the service

Registers a one-off callback that will be run if the connectivity state of the channel diverges from the given {@code source}, which is typically what

The ClientCall has been closed. Any additional calls to the {@code ClientCall} will not be processed by the server. No further receiving will occur an

Handles a state change on a Subchannel. The behavior is similar to {@link io.grpc.LoadBalancer.SubchannelStateListener}. <p>When a subchannel is reus

Creates a {@link SecurityPolicy} which checks if the package signature matches any of {@code requiredSignatures}. @param packageName the package name

Parses the optional int of the form "" (max int) or ":123" (123).

Allows providing bootstrap override, useful for testing.

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