Fetches the health-checked service name from health-checked service config. {@code null} if can't find one.

Returns an interceptor that will be applies to calls.

Gets the latitude for the given point.

Returns a list of listening socket addresses. May change after {@link #start(ServerListener)} is called.

Accepts a throwable and returns the appropriate logging level. Uninteresting exceptions should not clutter the log.

Gets the longitude for the given point.

Returns the {@link MetricRecorder} that the channel uses to record metrics.

Get the value for a custom option or its inherent default. @param key Key identifying option

Retrieves socket address.

Get peer service account. @return the context's peer service account.

Get random bytes.

Returns the fragment component of this URI in its original, possibly percent-encoded form, and without any leading '#' character. <p>NB: Choose caref

The last successfully updated xDS resource as it was returned by the server.

Returns default Rpc Protocol Versions.

Returns the randomly generated server name for this service.

Helper method to build CertProviderServerSslContextProvider.

Returns the status associated with the state. <p>If the state is {@code TRANSIENT_FAILURE}, the status is never {@code OK}. For other states, the st

Returns this peer's Android/Linux uid. <p>Intentionally non-public to prevent misuse.

Say hello to server.

When the returned socket is closed, {@code socket} must be closed.

Wait for a value to be available from the server. If there is an available value, return true immediately. If the stream was closed with Status.OK, r

Creates a {@link SecurityPolicy} which checks if the caller has all of the given permissions from {@code permissions}. <p>The gRPC framework assumes

Unwraps a {@link InternalLogId} to return a {@code long}.

Parsed configuration for implementation-specific extensions. Returns an opaque object containing the parsed configuration.

Increments the flow control window for this stream by the given delta and returns the new value.

Must be called by subclasses to initialize the handler and channel.

Tests if the future returned for this authorization request was cancelled by the caller.

Whether the filter can be installed on the client side. <p>Returns true if the filter implements {@link Filter#buildClientInterceptor}.

Indicates whether Java 9 ALPN is available.

Indicates whether call is capable of sending additional messages without requiring excessive buffering internally. Used for resource initial fetch tim

Returns true if the method exists on the supplied {@code target}.

Returns whether the server is terminated. Terminated servers have no running calls and relevant resources released (like TCP connections). @see #isSh

Append the given {@link ByteBuf} {@code in} to {@link CompositeByteBuf} {@code composite} by expanding or replacing the tail component of the {@link C

Produce a metadata marshaller for a protobuf type. @since 1.0.0

Creates a new builder for a {@link ServiceDescriptor}. @since 1.1.0

Creates a {@link CallAttemptsTracerFactory} for a new call.

Returns a new instance with no registered compressors.

Creates a new {@link io.grpc.LoadBalancer.Helper} with provided {@link OrcaOobReportListener} installed to receive callback when an out-of-band ORCA r

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

Returns the number of none-null headers in {@link #namesAndValues()}.

Callback when a ping response with the given ID is received.

There are no outstanding RPCs on the transport.

Start keepalive monitoring.

Creates {@link SecurityPolicy} which checks if the SHA-256 hash of the package signature matches any of {@code requiredSignatureSha256Hashes}. @param