Called by transport implementations when they receive headers. @param headers the parsed headers

Trailing metadata has been received from the server. This method does not pass ownership to {@code trailers}, so implementations must not access the m

Returns {@code true} if this result was created by {@link #withDrop withDrop()}. @since 1.8.0

Whether the filter can be installed into xDS-enabled servers. <p>Returns true if the filter implements {@link Filter#buildServerInterceptor}.

Check that write hasn't been marked complete and stream is ready to receive a write (so will not block). @return true if legal to write and write wil

Returns the maximum age the result will be cached.

Provided a JSON list of LoadBalancingConfigs, parse it into a config to pass to GracefulSwitch.

Protects the buffers by performing framing and encrypting/appending MACs. @param unprotectedBufs contain the payload that will be protected @param ct

Returns a new trie where the key is set to the specified value.

Releases an instance of the given resource. <p>The instance must have been obtained from {@link #get(Resource)}. Otherwise will throw IllegalArgument

Policy is reloaded periodically as per the provided refresh interval. Unlike the constructor, exception thrown during reload will be caught and logged

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

Throws IllegalStateException when no exact one match, and we should close the connection.

Update the memory utilization metrics data in the range [0, 1]. Values outside the valid range are ignored.

Returns the time when an entry will be in a staled status. When cache is accessed whgen the entry is in staled status, it will

Returns the {@link Status} of a cancelled context or {@code null} if the context is not cancelled.

<pre> Advanced API to allow for multi-dimensional load balancing by remote server. For receiving LB assignments, the steps are: 1, The management serv

<pre> A sequence of requests followed by one response (streamed upload). The server returns the aggregated size of client payload as the result. </pre

Get the resulting string.

A string representation of the status useful for debugging.

Unprotects the buffers by removing the framing and decrypting/checking MACs. @param in contains (partial) protected frames @param out is only used to

Returns a new {@code CallOptions} with {@code executor} to be used instead of the default executor specified with {@link ManagedChannelBuilder#executo

Writes logs to GCP Cloud Logging. @param logProto gRPC logging proto containing the message to be logged

Sends an outbound frame to the remote end point. @param frame a buffer containing the chunk of data to be sent, or {@code null} if {@code endOfSt

Information providing context to the call became available.

Applies the given header mutations to the provided metadata headers. @param mutations The header mutations to apply. @param headers The metadata head

Helper method to build DownstreamTlsContext for multiple test classes.

Helper method to build UpstreamTlsContext for CertProvider tests.

Returns a rough indicator of amount of memory to use for the client cache. Some of the data structure overhead is not accounted for, so actual memory

Completes this operation successfully. The stopwatch given during construction is used to measure the elapsed time. Registered callbacks are invoked a

Creates Google default credentials uses a secure channel with ALTS if applicable and uses TLS as fallback.

Creates {@link SslContext} objects for client with TLS configurations from S2A server. @param stub the {@link S2AStub} to talk to the S2A server. @pa