Returns the unit of measurement for the metric. @return the unit of measurement.

Processes an acknowledgement from our peer. @param numBytesAcked the total number of bytes ever received over this connection modulo 2^64, with t

Indicates whether or not this buffer exposes a backing array.

Increments {@code counter}, store the unincremented value in {@code oldCounter}.

Make the provided {@link Context} {@link Context#current()} for the creation of a listener to a received call and for all events received by that list

Invokes the method on {@code target}. Throws an error if the method is not supported. Any RuntimeException thrown by the method is thrown, checked exc

Returns whether the framer is closed.

Check for whether some action is ready. @return True if legal to write and writeOrRead can run without blocking

Indicates whether this metric instrument is enabled by default. @return {@code true} if this metric instrument is enabled by default, {@code

Returns true if env var is set.

Returns true iff this URI's path component starts with a path segment (rather than the '/' segment delimiter). <p>The path of an RFC 3986 URI is eith

Check whether there are any values waiting to be read. @return true if read will not block

If this is not Android, returns all available implementations discovered via {@link ServiceLoader}. If this is Android, returns all available implemen

Create a locality-labeled address.

Creates a {@link Marshaller} for protos of the same type as {@code defaultInstance} and a custom limit for the recursion depth. Any negative number wi

Runs any enqueued step in this ServerCall listener as long as the authorization check is complete. Otherwise, no-op and returns immediately.

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

Returns the header names and values as bytes. An even numbered index contains the {@code byte[]} representation of a header name (in insertion order),

Start and wait until the negotiation is done, returns the negotiated protocol. @throws IOException if an IO error was encountered during the handshak

Returns a new instance of {@link Builder} with no flags set. <p>Callers should start with {@code DEFAULTS.toBuilder()} instead.

Called when the stream is ready to send additional messages. If called the library use this handler to trigger resource arrival timeout, also see {@li

There are no outstanding RPCs on the transport.

Translates envoy proto FractionalPercent to internal FractionMatcher.

Parse an incoming request message. @param input the serialized message as a byte stream. @return a parsed instance of the message. @since 1.0.0

Specify the most aggressive keep-alive time clients are permitted to configure. The server will try to detect clients exceeding this rate and when det

Sets whether to allow clients to send keep-alive HTTP/2 PINGs even if there are no outstanding RPCs on the connection. Defaults to {@code false}. @se

Returns effective providers map from scheme to the highest priority NameResolverProvider of that scheme.

HTTP/2 only. Receive a push promise header block. <p> A push promise contains all the headers that pertain to a server-initiated request, and a {@code

Records a call metric measurement for application specific utilization in the range [0, inf). Values outside the valid range are ignored. If RPC has a

Records a call metric measurement for CPU utilization in the range [0, inf). Values outside the valid range are ignored. If RPC has already finished,

Records a call metric measurement for errors per second (eps) in the range [0, inf). Values outside the valid range are ignored. If RPC has already fi

Records a call metric measurement for queries per second (qps) in the range [0, inf). Values outside the valid range are ignored. If RPC has already f

Register a provider. <p>If the provider's {@link LoadBalancerProvider#isAvailable isAvailable()} returns {@code false}, this method will throw {@link

Registers a new Double Counter metric instrument. @param name the name of the metric @param description a description of the metric @param unit the u

Registers GrpcOpenTelemetry globally, applying its configuration to all subsequently created gRPC channels and servers.

Remove a {@link CancellationListener}.

Requests a connection to the next applicable address' subchannel, creating one if necessary. Schedules a connection to next address in list as well. I