Perform a grpcRunnable and return all the logs.

Called when {@link ServerCall} is created. This is for the tracer to access information about the {@code ServerCall}. Called after {@link #filterCon

Returns the server stream associated to the given HTTP/2 stream object.

Update the CPU utilization metrics data in the range [0, inf). Values outside the valid range are ignored.

Marks the stream state as if it had never existed. This can happen if the stream is cancelled after it is created, but before it has been started.

See {@link Args#getOffloadExecutor}. This is an optional field. @since 1.25.0

Specifies the fragment component of the new URI, already percent-encoded, exactly as it will appear after the '#' delimiter in the string form of the

Set the "user info" component of the new URI, e.g. "username:password", not including the trailing '@' character. <p>User info can contain any string

Returns true if an RPC with the given properties should be counted when calculating the in-use state of a transport.

Initiates an orderly shutdown in which preexisting calls continue but new calls are immediately cancelled. @return this @since 1.0.0

This method is called in tests only.

Sets the TLS context to use for encryption. Providing a context enables encryption. It must have been configured with {@link GrpcSslContexts}, but opt

If {@code statusCode} is non-null, it will be used instead of the http2 error code mapping.

The HTTP/2 stream id, or {@code -1} if not supported.

Returns the byte array.

Returns a Grpc status corresponding to the given ErrorCode.

Convert a {@link com.google.rpc.Status} instance to a {@link StatusRuntimeException}. <p>The returned {@link StatusRuntimeException} will wrap a {@li

Note that the current callsite has access to this buffer, or do nothing. This is only useful when the buffer has leak detection and intrumentation to

{@inheritDoc}

Helper method to unpack serialized {@link com.google.protobuf.Any} message, while replacing Type URL {@code compatibleTypeUrl} with {@code typeUrl}.

Updates balancing state from one or more subchannels tracked in the {@link SubchannelStateManager}. The passed picker will be ignored, instead the pic

Sets the negotiation type for the HTTP/2 connection to plaintext.

Verifies the EDS update against the golden Cluster with load assignment {@link #testClusterLoadAssignment}.

Verifies the LDS update against the golden Listener with RDS name {@link #testListenerRds}.

Sets the maximum allowed message size acceptable from the remote peer. If unset, this will default to the value set on the {@link ManagedChannelBuild

Sets the maximum allowed message size acceptable sent to the remote peer.

Sets a custom option to be passed to client interceptors on the channel {@link io.grpc.ClientInterceptor} via the CallOptions parameter. @since 1.0.0

Returns the ChannelCredentials stripped of its CallCredentials. In the future, this may strip only some of the CallCredentials, preserving call creden

Wrap a {@link Runnable} so that it executes with this context as the {@link #current} context.

Ordered list of xDS servers to contact for this authority. <p>If the same server is listed in multiple authorities, the entries will be de-duped (i.e

Adds an additional address for this server to listen on. Callers must ensure that all socket addresses are compatible with the Netty channel type, an

Adds a MetricSink to the server.

Specifies which request headers are sent to the authorization service. If empty, all headers are sent. @see ExtAuthz#getAllowedHeaders()

Some tests run on memory constrained environments. Rather than OOM, just give up. 64 is chosen as a maximum amount of memory a large test would need