Class DCBGrpc.DCBFutureStub
java.lang.Object
io.grpc.stub.AbstractStub<DCBGrpc.DCBFutureStub>
io.grpc.stub.AbstractFutureStub<DCBGrpc.DCBFutureStub>
umadb.v1.DCBGrpc.DCBFutureStub
- Enclosing class:
DCBGrpc
public static final class DCBGrpc.DCBFutureStub
extends io.grpc.stub.AbstractFutureStub<DCBGrpc.DCBFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service DCB.
Service providing Event Store RPCs supporting DCB.
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub
io.grpc.stub.AbstractStub.StubFactory<T> -
Method Summary
Modifier and TypeMethodDescriptioncom.google.common.util.concurrent.ListenableFuture<Umadb.AppendResponse> append(Umadb.AppendRequest request) Appends new events to the store.protected DCBGrpc.DCBFutureStubbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions) com.google.common.util.concurrent.ListenableFuture<Umadb.TrackingResponse> getTrackingInfo(Umadb.TrackingRequest request) Gets the last record position for a named source.com.google.common.util.concurrent.ListenableFuture<Umadb.HeadResponse> head(Umadb.HeadRequest request) Gets the position of the last recorded event in the store.Methods inherited from class io.grpc.stub.AbstractFutureStub
newStub, newStubMethods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Method Details
-
build
- Specified by:
buildin classio.grpc.stub.AbstractStub<DCBGrpc.DCBFutureStub>
-
append
public com.google.common.util.concurrent.ListenableFuture<Umadb.AppendResponse> append(Umadb.AppendRequest request) Appends new events to the store.
-
head
public com.google.common.util.concurrent.ListenableFuture<Umadb.HeadResponse> head(Umadb.HeadRequest request) Gets the position of the last recorded event in the store.
-
getTrackingInfo
public com.google.common.util.concurrent.ListenableFuture<Umadb.TrackingResponse> getTrackingInfo(Umadb.TrackingRequest request) Gets the last record position for a named source.
-