Builds the {@link Configuration} from the given command-line arguments. @throws IllegalArgumentException if unable to build the configuration for any

Assert that two messages are equal, producing a useful message if not.

Creates a key for a binary header. @param name Must contain only the valid key characters as defined in the class comment. Must end with {@link #

Adds the delta to this counter.

Starts stream. This method may only be called once. It is safe to do latent initialization of the stream up until {@link #start} is called. <p>This

Returns the value if set or throws exception if there is no value set. This method is meant to be called after checking the return value of hasValue()

Returns a mutable list view of the query parameters. @return the mutable list of entries

Sets a flag for testing and returns its previous value.

The canonical status code.

Creates a new {@link Builder} with all fields uninitialized or set to their default values.

Create a derived instance of {@link Status} with the given description. Leading and trailing whitespace may be removed; this may change in the future

Returns true iff this container no longer owns a {@link Parcel}. <p>{@link #isEmpty()} is true after all call to {@link #close()} or {@link #release(

Returns the default instance used by gRPC when the registry is not specified. Currently the registry just contains support for gzip.

Returns the name of the metric. @return the name of the metric.

Returns an instance for a state that is not {@code TRANSIENT_FAILURE}. @throws IllegalArgumentException if {@code state} is {@code TRANSIENT_FAILURE}

Creates a channel credentials builder for establishing an S2A-secured connection. @param s2aAddress the address of the S2A server used to secure the

Receives a value from the stream. <p>Can be called many times but is never called after {@link #onError(Throwable)} or {@link #onCompleted()} are cal

Initiates an orderly shutdown of the server. Existing transports continue, but new transports will not be created (once {@link ServerListener#serverSh

Returns the status passed to {@link StreamTracer#streamClosed}.

Handles a state change on a Subchannel. <p>The initial state of a Subchannel is IDLE. You won't get a notification for the initial IDLE state. <p>If

Sets the name. This should be non-{@code null}. @param name The name of the service. @return this builder. @since 1.1.0

Appends a piece of information which is a plain string. The given object is immediately converted to string and recorded.

<pre> Returns a single Channel, or else a NOT_FOUND code. </pre>

Sets the addresses resolved by name resolution. This field is required. @since 1.21.0 @deprecated Will be superseded by setAddressesOrError

Create a new instance of the resource.

Tears down the stream, typically in the event of a timeout. This method may be called multiple times and from any thread. <p>This is a clone of {@lin

Called to deliver a resource update or an error. If an error is passed after a valid resource has been delivered, the watcher should stop using the pr

Sets the method type. @param type the type of the method. @since 1.1.0

Adds the {@code key, value} pair. If {@code key} already has values, {@code value} is added to the end. Duplicate values for the same key are permitte

Adds a method to this service. This should be non-{@code null}. @param method the method to add to the descriptor. @return this builder. @since 1.1.

Requests up to the given number of messages from the call to be delivered via {@link StreamListener#messagesAvailable(StreamListener.MessageProducer)}

Returns a description of the metric. @return a description of the metric.

Receives a notification of successful stream completion. <p>May only be called once and if called it must be the last method called. In particular if

Forward the time by the given duration and run all due tasks. @return the number of tasks run by this call

Returns the next gRPC message, if the data has been received by the deframer and the application has requested another message. <p>The provided {@cod

Attributes describing stream. This is inherited from the transport attributes, and used as the basis of {@link io.grpc.ServerCall#getAttributes}. @r

Return the number of queued tasks.

Factory for constructing a new Builder. @since 1.21.0

The {@code CallOptions} of the stub. @since 1.0.0

Returns current subchannel state for given subchannel name if exists, otherwise returns {@code null}.

Sets the fully qualified (service and method) method name. @see MethodDescriptor#generateFullMethodName @since 1.1.0

Adds a service implementation to the handler registry. @param service ServerServiceDefinition object @return this @since 1.0.0

Retrieves the specified test certificate or key resource in src/main/resources/certs/ as an {@code InputStream}. @param name name of a file in src/ma

Called when the stream is fully closed. A status code of {@link io.grpc.Status.Code#OK} implies normal termination of the stream. Any other value impl

Is this status OK, i.e., not an error.

Releases filter resources like shared resources and remote connections. <p>See {@link Provider#newInstance()} for details on filter instance creation

Returns whether there is a value.

Returns an executor for scheduling provided by the transport. The service should be configured to allow cancelled scheduled runnables to be GCed. <p>

Return the context associated with the current scope, will never return {@code null}. <p>Will never return {@link CancellableContext} even if one is

Called when there has been an error when preparing the headers. This will fail the RPC.

Sets the attributes for the addresses resolved by name resolution. If unset, {@link Attributes#EMPTY} will be used as a default. @since 1.21.0

Execute application code directly in the transport thread. <p>Depending on the underlying transport, using a direct executor may lead to substantial

Returns shallow copied values in the cache.

Create a {@link Marshaller} for protos of the same type as {@code defaultInstance}. @since 1.0.0

Returns true if a value is defined for the given key. <p>This is done by linear search, so if it is followed by {@link #get} or {@link #getAll}, pref

The fully qualified name of the method. @since 1.0.0

Create a new builder that is pre-populated with the content from a given container. @deprecated Use {@link Attributes#toBuilder()} on the {@link Attri

Initiates a forceful shutdown in which preexisting and new calls are closed. Existing calls should be closed with the provided {@code reason}.

Logs a message.

Sets the request marshaller. @param requestMarshaller the marshaller to use. @since 1.1.0

Sets the response marshaller. @param responseMarshaller the marshaller to use. @since 1.1.0

Forward the time by the given nanoseconds and run all due tasks. @return the number of tasks run by this call

Sets the load balancing policy config. This field is optional. @return this.

Appends {@code length} bytes to the buffer from the source array starting at {@code srcIndex}. @throws IndexOutOfBoundsException if the speci

If {@code true}, indicates that the transport is capable of sending additional messages without requiring excessive buffering internally. Otherwise, {

The underlying cause of an error. Note that the cause is not transmitted from server to client.

Flushes any internally buffered messages to the remote end-point.

Returns the addresses that this Subchannel is bound to. This can be called only if the Subchannel has only one {@link EquivalentAddressGroup}. Under

Gets the current number of readable bytes remaining in this buffer.

Run all due tasks. Immediately due tasks that are queued during the process also get executed. @return the number of tasks run by this call

Writes a message payload to the remote end-point. The bytes from the stream are immediately read by the Transport. Where possible callers should use s

Waits for the server to become terminated, giving up if the timeout is reached. <p>Calling this method before {@code start()} or {@code shutdown()} i