<pre> This is a gRPC-only API. </pre>

<pre> Main communication channel: the data plane sends usage reports to the RLQS server, and the server asynchronously responding with the assignments

<pre> Two-sided unbounded streaming between server to client Both sides send the content of their own choice to the other </pre>

<pre> Repeated sequence of one request followed by one response. Should be called streaming ping-pong The server returns the client payload as-is on e

<pre> Single-sided unbounded streaming from client to server The server returns the client payload as-is once the client does WritesDone </pre>

Disables the channel idle timeout and prevents it from being enabled. This allows a centralized application method to configure the channel builder an

The given substream is closed.

Returns a copy of this that omits cipher suites and TLS versions not enabled by {@code sslSocket}.

Sets an optional filter to control recording of the {@code grpc.target} metric attribute. <p>If the predicate returns {@code true}, the original targ

Stop the running calls then stop the server and client channels.

Stop the running calls then stop the server and client channels.

Returns the authority string used by a client to connect to {@code server}.

Test backend metrics OOB reporting: expect the test client LB policy to receive load reports.

Test backend metrics per query reporting: expect the test client LB policy to receive load reports.

Creates a new list of {@link InetSocketAddress} on localhost that overrides the host with {@link #TEST_SERVER_HOST}.

Percent encode bytes to make them ASCII. @param valueBytes the UTF-8 bytes @param ri The reader index, pointed at the first byte that needs escaping.

Converts this StreamInfo into a new Builder. @since 1.21.0

Converts these results back to a builder. @since 1.21.0

Returns a builder with the same initial values as this object.

Returns the string representation suitable for use as an error tag. @return The formatted error tag string.

Creates a frame of length dataSize + FRAME_HEADER_SIZE using the input bytes, if dataSize <= input.remaining(). Otherwise, a frame of length input.rem

Converts generic Map of headers to Netty's HttpHeaders. Returns null if the map is null or empty.

Converts a {@link ChannelCredentials} to a negotiator, in similar fashion as for a new channel. @throws IllegalArgumentException if unable to convert

Convert this chunk into a streaming response proto.

Wraps the given {@link Throwable} in a {@link StatusRuntimeException}. If it contains an embedded {@link StatusException} or {@link StatusRuntimeExcep