A B C D F G I M N O R S W
All Classes All Packages

A

AbstractAsyncStub<S extends AbstractAsyncStub<S>> - Class in io.grpc.stub

Stub implementations for async stubs.

AbstractAsyncStub(Channel, CallOptions) - Constructor for class io.grpc.stub.AbstractAsyncStub

AbstractBlockingStub<S extends AbstractBlockingStub<S>> - Class in io.grpc.stub

Stub implementations for blocking stubs.

AbstractBlockingStub(Channel, CallOptions) - Constructor for class io.grpc.stub.AbstractBlockingStub

AbstractFutureStub<S extends AbstractFutureStub<S>> - Class in io.grpc.stub

Stub implementations for future stubs.

AbstractFutureStub(Channel, CallOptions) - Constructor for class io.grpc.stub.AbstractFutureStub

AbstractStub<S extends AbstractStub<S>> - Class in io.grpc.stub

Common base type for stub implementations.

AbstractStub(Channel) - Constructor for class io.grpc.stub.AbstractStub

Constructor for use by subclasses, with the default CallOptions.

AbstractStub(Channel, CallOptions) - Constructor for class io.grpc.stub.AbstractStub

Constructor for use by subclasses.

AbstractStub.StubFactory<T extends AbstractStub<T>> - Interface in io.grpc.stub

A factory class for stub.

asyncBidiStreamingCall(ClientCall<ReqT, RespT>, StreamObserver<RespT>) - Static method in class io.grpc.stub.ClientCalls

Executes a bidirectional-streaming call.

asyncBidiStreamingCall(ServerCalls.BidiStreamingMethod<ReqT, RespT>) - Static method in class io.grpc.stub.ServerCalls

Creates a ServerCallHandler for a bidi streaming method of the service.

asyncClientStreamingCall(ClientCall<ReqT, RespT>, StreamObserver<RespT>) - Static method in class io.grpc.stub.ClientCalls

Executes a client-streaming call returning a StreamObserver for the request messages.

asyncClientStreamingCall(ServerCalls.ClientStreamingMethod<ReqT, RespT>) - Static method in class io.grpc.stub.ServerCalls

Creates a ServerCallHandler for a client streaming method of the service.

asyncServerStreamingCall(ClientCall<ReqT, RespT>, ReqT, StreamObserver<RespT>) - Static method in class io.grpc.stub.ClientCalls

Executes a server-streaming call with a response StreamObserver.

asyncServerStreamingCall(ServerCalls.ServerStreamingMethod<ReqT, RespT>) - Static method in class io.grpc.stub.ServerCalls

Creates a ServerCallHandler for a server streaming method of the service.

asyncUnaryCall(ClientCall<ReqT, RespT>, ReqT, StreamObserver<RespT>) - Static method in class io.grpc.stub.ClientCalls

Executes a unary call with a response StreamObserver.

asyncUnaryCall(ServerCalls.UnaryMethod<ReqT, RespT>) - Static method in class io.grpc.stub.ServerCalls

Creates a ServerCallHandler for a unary call method of the service.

asyncUnimplementedStreamingCall(MethodDescriptor<?, ?>, StreamObserver<?>) - Static method in class io.grpc.stub.ServerCalls

Sets unimplemented status for streaming call.

asyncUnimplementedUnaryCall(MethodDescriptor<?, ?>, StreamObserver<?>) - Static method in class io.grpc.stub.ServerCalls

Sets unimplemented status for method on given response stream for unary call.

B

beforeStart(ClientCallStreamObserver<ReqT>) - Method in interface io.grpc.stub.ClientResponseObserver

Called by the runtime prior to the start of a call to provide a reference to the ClientCallStreamObserver for the outbound stream.

blockingServerStreamingCall(Channel, MethodDescriptor<ReqT, RespT>, CallOptions, ReqT) - Static method in class io.grpc.stub.ClientCalls

Executes a server-streaming call returning a blocking Iterator over the response stream.

blockingServerStreamingCall(ClientCall<ReqT, RespT>, ReqT) - Static method in class io.grpc.stub.ClientCalls

Executes a server-streaming call returning a blocking Iterator over the response stream.

blockingUnaryCall(Channel, MethodDescriptor<ReqT, RespT>, CallOptions, ReqT) - Static method in class io.grpc.stub.ClientCalls

Executes a unary call and blocks on the response.

blockingUnaryCall(ClientCall<ReqT, RespT>, ReqT) - Static method in class io.grpc.stub.ClientCalls

Executes a unary call and blocks on the response.

build(Channel, CallOptions) - Method in class io.grpc.stub.AbstractStub

Returns a new stub with the given channel for the provided method configurations.

C

CallStreamObserver<V> - Class in io.grpc.stub

A refinement of StreamObserver provided by the GRPC runtime to the application (the client or the server) that allows for more complex interactions with call behavior.

CallStreamObserver() - Constructor for class io.grpc.stub.CallStreamObserver

cancel(String, Throwable) - Method in class io.grpc.stub.ClientCallStreamObserver

Prevent any further processing for this ClientCallStreamObserver.

ClientCalls - Class in io.grpc.stub

Utility functions for processing different call idioms.

ClientCallStreamObserver<ReqT> - Class in io.grpc.stub

A refinement of CallStreamObserver that allows for lower-level interaction with client calls.

ClientCallStreamObserver() - Constructor for class io.grpc.stub.ClientCallStreamObserver

ClientResponseObserver<ReqT,RespT> - Interface in io.grpc.stub

Specialization of StreamObserver implemented by clients in order to interact with the advanced features of a call such as flow-control.

copyWithFlowControl(Iterable<V>, CallStreamObserver<V>) - Static method in class io.grpc.stub.StreamObservers

Deprecated.

Copy the values of an Iterable to the target CallStreamObserver while properly accounting for outbound flow-control.

copyWithFlowControl(Iterator<V>, CallStreamObserver<V>) - Static method in class io.grpc.stub.StreamObservers

Deprecated.

Copy the values of an Iterator to the target CallStreamObserver while properly accounting for outbound flow-control.

D

disableAutoInboundFlowControl() - Method in class io.grpc.stub.CallStreamObserver

Disables automatic flow control where a token is returned to the peer after a call to the 'inbound' StreamObserver.onNext(Object) has completed.

disableAutoRequest() - Method in class io.grpc.stub.ServerCallStreamObserver

Swaps to manual flow control where no message will be delivered to StreamObserver.onNext(Object) unless it is request()ed.

disableAutoRequestWithInitial(int) - Method in class io.grpc.stub.ClientCallStreamObserver

Swaps to manual flow control where no message will be delivered to StreamObserver.onNext(Object) unless it is request()ed.

F

fullMethodName() - Method in annotation type io.grpc.stub.annotations.RpcMethod

The fully qualified method name.

futureUnaryCall(ClientCall<ReqT, RespT>, ReqT) - Static method in class io.grpc.stub.ClientCalls

Executes a unary call and returns a ListenableFuture to the response.

G

getCallOptions() - Method in class io.grpc.stub.AbstractStub

The CallOptions of the stub.

getChannel() - Method in class io.grpc.stub.AbstractStub

The underlying channel of the stub.

GrpcGenerated - Annotation Type in io.grpc.stub.annotations

Annotates that the class is gRPC-generated code to assist Java Annotation Processors.

I

invoke(StreamObserver<RespT>) - Method in interface io.grpc.stub.ServerCalls.BidiStreamingMethod

invoke(StreamObserver<RespT>) - Method in interface io.grpc.stub.ServerCalls.ClientStreamingMethod

invoke(ReqT, StreamObserver<RespT>) - Method in interface io.grpc.stub.ServerCalls.ServerStreamingMethod

invoke(ReqT, StreamObserver<RespT>) - Method in interface io.grpc.stub.ServerCalls.UnaryMethod

io.grpc.stub - package io.grpc.stub

API for the Stub layer.

io.grpc.stub.annotations - package io.grpc.stub.annotations

isCancelled() - Method in class io.grpc.stub.ServerCallStreamObserver

Returns true when the call is cancelled and the server is encouraged to abort processing to save resources, since the client will not be processing any further methods.

isReady() - Method in class io.grpc.stub.CallStreamObserver

If true, indicates that the observer is capable of sending additional messages without requiring excessive buffering internally.

isReady() - Method in class io.grpc.stub.ClientCallStreamObserver

If true, indicates that the observer is capable of sending additional messages without requiring excessive buffering internally.

isReady() - Method in class io.grpc.stub.ServerCallStreamObserver

If true, indicates that the observer is capable of sending additional messages without requiring excessive buffering internally.

M

MetadataUtils - Class in io.grpc.stub

Utility functions for binding and receiving headers.

methodType() - Method in annotation type io.grpc.stub.annotations.RpcMethod

The call type of the method.

N

newAttachHeadersInterceptor(Metadata) - Static method in class io.grpc.stub.MetadataUtils

Returns a client interceptor that attaches a set of headers to requests.

newCaptureMetadataInterceptor(AtomicReference<Metadata>, AtomicReference<Metadata>) - Static method in class io.grpc.stub.MetadataUtils

Captures the last received metadata on a channel.

newStub(Channel, CallOptions) - Method in interface io.grpc.stub.AbstractStub.StubFactory

newStub(AbstractStub.StubFactory<T>, Channel) - Static method in class io.grpc.stub.AbstractAsyncStub

Returns a new async stub with the given channel for the provided method configurations.

newStub(AbstractStub.StubFactory<T>, Channel) - Static method in class io.grpc.stub.AbstractBlockingStub

Returns a new blocking stub with the given channel for the provided method configurations.

newStub(AbstractStub.StubFactory<T>, Channel) - Static method in class io.grpc.stub.AbstractFutureStub

Returns a new future stub with the given channel for the provided method configurations.

newStub(AbstractStub.StubFactory<T>, Channel) - Static method in class io.grpc.stub.AbstractStub

Returns a new stub with the given channel for the provided method configurations.

newStub(AbstractStub.StubFactory<T>, Channel, CallOptions) - Static method in class io.grpc.stub.AbstractAsyncStub

Returns a new async stub with the given channel for the provided method configurations.

newStub(AbstractStub.StubFactory<T>, Channel, CallOptions) - Static method in class io.grpc.stub.AbstractBlockingStub

Returns a new blocking stub with the given channel for the provided method configurations.

newStub(AbstractStub.StubFactory<T>, Channel, CallOptions) - Static method in class io.grpc.stub.AbstractFutureStub

Returns a new future stub with the given channel for the provided method configurations.

newStub(AbstractStub.StubFactory<T>, Channel, CallOptions) - Static method in class io.grpc.stub.AbstractStub

Returns a new stub with the given channel for the provided method configurations.

O

onCompleted() - Method in interface io.grpc.stub.StreamObserver

Receives a notification of successful stream completion.

onError(Throwable) - Method in interface io.grpc.stub.StreamObserver

Receives a terminating error from the stream.

onNext(V) - Method in interface io.grpc.stub.StreamObserver

Receives a value from the stream.

R

request(int) - Method in class io.grpc.stub.CallStreamObserver

Requests the peer to produce count more messages to be delivered to the 'inbound' StreamObserver.

request(int) - Method in class io.grpc.stub.ClientCallStreamObserver

Requests the peer to produce count more messages to be delivered to the 'inbound' StreamObserver.

request(int) - Method in class io.grpc.stub.ServerCallStreamObserver

Requests the peer to produce count more messages to be delivered to the 'inbound' StreamObserver.

requestType() - Method in annotation type io.grpc.stub.annotations.RpcMethod

The request type of the method.

responseType() - Method in annotation type io.grpc.stub.annotations.RpcMethod

The response type of the method.

RpcMethod - Annotation Type in io.grpc.stub.annotations

RpcMethod contains a limited subset of information about the RPC to assist Java Annotation Processors.

S

ServerCalls - Class in io.grpc.stub

Utility functions for adapting ServerCallHandlers to application service implementation, meant to be used by the generated code.

ServerCalls.BidiStreamingMethod<ReqT,RespT> - Interface in io.grpc.stub

Adaptor to a bidirectional streaming method.

ServerCalls.ClientStreamingMethod<ReqT,RespT> - Interface in io.grpc.stub

Adaptor to a client streaming method.

ServerCalls.ServerStreamingMethod<ReqT,RespT> - Interface in io.grpc.stub

Adaptor to a server streaming method.

ServerCalls.UnaryMethod<ReqT,RespT> - Interface in io.grpc.stub

Adaptor to a unary call method.

ServerCallStreamObserver<RespT> - Class in io.grpc.stub

A refinement of CallStreamObserver to allows for interaction with call cancellation events on the server side.

ServerCallStreamObserver() - Constructor for class io.grpc.stub.ServerCallStreamObserver

setCompression(String) - Method in class io.grpc.stub.ServerCallStreamObserver

Sets the compression algorithm to use for the call.

setMessageCompression(boolean) - Method in class io.grpc.stub.CallStreamObserver

Sets message compression for subsequent calls to StreamObserver.onNext(V).

setMessageCompression(boolean) - Method in class io.grpc.stub.ClientCallStreamObserver

Sets message compression for subsequent calls to StreamObserver.onNext(V).

setMessageCompression(boolean) - Method in class io.grpc.stub.ServerCallStreamObserver

Sets message compression for subsequent calls to StreamObserver.onNext(V).

setOnCancelHandler(Runnable) - Method in class io.grpc.stub.ServerCallStreamObserver

Sets a Runnable to be called if the call is cancelled and the server is encouraged to abort processing to save resources, since the client will not process any further messages.

setOnCloseHandler(Runnable) - Method in class io.grpc.stub.ServerCallStreamObserver

Sets a Runnable to be executed when the call is closed cleanly from the server's point of view: either StreamObserver.onCompleted() or StreamObserver.onError(Throwable) has been called, all the messages and trailing metadata have been sent and the stream has been closed.

setOnReadyHandler(Runnable) - Method in class io.grpc.stub.CallStreamObserver

Set a Runnable that will be executed every time the stream CallStreamObserver.isReady() state changes from false to true.

setOnReadyHandler(Runnable) - Method in class io.grpc.stub.ClientCallStreamObserver

Set a Runnable that will be executed every time the stream ClientCallStreamObserver.isReady() state changes from false to true.

setOnReadyHandler(Runnable) - Method in class io.grpc.stub.ServerCallStreamObserver

Set a Runnable that will be executed every time the stream ServerCallStreamObserver.isReady() state changes from false to true.

StreamObserver<V> - Interface in io.grpc.stub

Receives notifications from an observable stream of messages.

StreamObservers - Class in io.grpc.stub

Deprecated.

Of questionable utility and generally not used.

StreamObservers() - Constructor for class io.grpc.stub.StreamObservers

Deprecated.

W

withCallCredentials(CallCredentials) - Method in class io.grpc.stub.AbstractStub

Returns a new stub that uses the given call credentials.

withChannel(Channel) - Method in class io.grpc.stub.AbstractStub

Deprecated.

withCompression(String) - Method in class io.grpc.stub.AbstractStub

Set's the compressor name to use for the call.

withDeadline(Deadline) - Method in class io.grpc.stub.AbstractStub

Returns a new stub with an absolute deadline.

withDeadlineAfter(long, TimeUnit) - Method in class io.grpc.stub.AbstractStub

Returns a new stub with a deadline that is after the given duration from now.

withExecutor(Executor) - Method in class io.grpc.stub.AbstractStub

Returns a new stub with the given executor that is to be used instead of the default one specified with ManagedChannelBuilder.executor(java.util.concurrent.Executor).

withInterceptors(ClientInterceptor...) - Method in class io.grpc.stub.AbstractStub

Returns a new stub that has the given interceptors attached to the underlying channel.

withMaxInboundMessageSize(int) - Method in class io.grpc.stub.AbstractStub

Returns a new stub that limits the maximum acceptable message size from a remote peer.

withMaxOutboundMessageSize(int) - Method in class io.grpc.stub.AbstractStub

Returns a new stub that limits the maximum acceptable message size to send a remote peer.

withOption(CallOptions.Key<T>, T) - Method in class io.grpc.stub.AbstractStub

Sets a custom option to be passed to client interceptors on the channel ClientInterceptor via the CallOptions parameter.

withWaitForReady() - Method in class io.grpc.stub.AbstractStub

Returns a new stub that uses 'wait for ready' for the call.

A B C D F G I M N O R S W
All Classes All Packages