Executes a unary call and blocks on the response. The {@code call} should not be already started. After calling this method, {@code call} should no

Resets the scheduler, effectively cancelling any future retry operation.

Create a server builder that will bind with the given name. @param name the identity of the server for clients to connect to @return a new builder

Create a derived instance of {@link Status} with the given cause. However, the cause is not transmitted from server to client.

Returns an instance for {@code TRANSIENT_FAILURE}, associated with an error status.

Verify the resource to be acked.

Closes, with flush.

Return all unrun tasks.

Returns cached value for given key if exists, otherwise {@code null}. This operation doesn't return already expired cache entry.

Starts asynchronous processing of an incoming call. <p>Callers of this method transfer their ownership of the non-thread-safe {@link ServerCall} and

The status associated with this result. Non-{@code OK} if created with {@link #withError withError}, or {@code OK} otherwise. @since 1.2.0

The call options used to call this RPC.

Executes a unary call with a response {@link StreamObserver}. The {@code call} should not be already started. After calling this method, {@code call

Create a {@link ClientCall} to the remote operation specified by the given {@link MethodDescriptor}. The returned {@link ClientCall} does not trigger

A request to schedule a future retry (or retries) for a failed operation. Noop if an operation has already been scheduled.

Shortcut for {@code wrap(bytes, 0, bytes.length}.

Waits for the stream to be done.

Return an instance of the given class to be used as an argument passed to one method call. If one method has multiple arguments with the same type, ea

A description of this status for human consumption.

Make a balancing decision for a new RPC. @param args the pick arguments @since 1.3.0

Shuts down all subchannels in the pool immediately.

Sends a message on the stream. Only one message will be in flight at a time; subsequent messages will not be sent until this one is done.

Returns config if exists, otherwise null.

Returns a new Builder initialized with the fields of this URI.

The transport is ready to accept traffic, because the connection is established. This is called at most once. <p>Streams created before this milesto

Sets this parameter on the given configuration instance.

Handles an error from the resolver. The listener is responsible for eventually invoking {@link #refresh()} to re-attempt resolution. @param error a n

SPDY/3 only.

Sets whether RPCs for this method may be sampled into the local tracing store. If true, sampled traces of this method may be kept in memory by tracin

Generate the fully qualified method name. This matches the name @param fullServiceName the fully qualified service name that is prefixed with the pa

Used for verify/inspect message received from server.

Given a message, produce an {@link InputStream} for it so that it can be written to the wire. Where possible implementations should produce streams th

Returns the unique name of the {@link CertificateProvider} plugin.

The transport is shutting down. This transport will stop owning new streams, but existing streams may continue, and the transport may still be able to

Returns the authority component of this URI, e.g. "google.com", "127.0.0.1:8080", or null if not present.

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

Releases the buffer, indicating to the {@link WritableBufferAllocator} that this buffer is no longer used and its resources can be reused.

Creates an unstarted transport for exclusive use. Ownership of {@code options} is passed to the callee; the caller should not reuse or read from the o

Returns error status if exists, otherwise null.

Closes the local side of this stream and flushes any remaining messages. After this is called, no further messages may be sent on this stream, but add

The transport completed shutting down. All resources have been released. All streams have either been closed or transferred off this transport. This t

Create a deadline that will expire at the specified offset based on the {@link #getSystemTicker system ticker}. <p>If the given offset is extraordina

Creates a new method descriptor that always creates zero length messages, and always parses to null objects. @since 1.1.0

Convert this {@link Status} to an {@link Exception}. Use {@link #fromThrowable} to recover this {@link Status} instance when the returned exception is

Sets the schema descriptor for this builder. A schema descriptor is an object that is not used by gRPC core but includes information related to the m

No decision could be made. The RPC will stay buffered. @since 1.2.0

Base case for accepting new resolved addresses.

Returns the last metadata entry added with the name 'name' parsed as T. @return the parsed metadata entry or null if there are none.

Extract an error {@link Status} from the causal chain of a {@link Throwable}. If no status can be found, a status is created with {@link Code#UNKNOWN}

checks when {@link #namesAndValues} is null or has no elements.

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

Returns the normalized name for this key.

Returns the byte array.

Use the provided root certificates to verify the client's identity instead of the system's default. Generally they should be PEM-encoded with all the

Sends the request headers to the remote end point. @param metadata the metadata to be sent @param payload the payload needs to be sent in the headers

Returns struct if exists, otherwise null.

The Subchannel if this result was created by {@link #withSubchannel withSubchannel()}, or null otherwise. @since 1.2.0

Convert this {@link Status} to a {@link RuntimeException}. Use {@link #fromThrowable} to recover this {@link Status} instance when the returned except

Returns the "port" component of this URI, or -1 if empty or not present.

Verify the resource requested, but not updated.

Convenience that constructs a {@link ServiceDescriptor} simultaneously.

Construct from a value.

This indicates that the transport is now capable of sending additional messages without requiring excessive buffering internally. This event is just a

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