Package io.dapr.v1

Class DaprClientGrpc.DaprClientFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<DaprClientGrpc.DaprClientFutureStub>

io.dapr.v1.DaprClientGrpc.DaprClientFutureStub

Enclosing class:

DaprClientGrpc

public static final class DaprClientGrpc.DaprClientFutureStub
extends io.grpc.stub.AbstractStub<DaprClientGrpc.DaprClientFutureStub>

 DaprClient service allows user application to interact with Dapr runtime.
 User application needs to implement DaprClient service if it needs to
 receive message from dapr runtime.
 

Method Summary

Modifier and Type	Method	Description
protected DaprClientGrpc.DaprClientFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<DaprClientProtos.GetBindingsSubscriptionsEnvelope>	getBindingsSubscriptions(com.google.protobuf.Empty request)
com.google.common.util.concurrent.ListenableFuture<DaprClientProtos.GetTopicSubscriptionsEnvelope>	getTopicSubscriptions(com.google.protobuf.Empty request)
com.google.common.util.concurrent.ListenableFuture<DaprClientProtos.BindingResponseEnvelope>	onBindingEvent(DaprClientProtos.BindingEventEnvelope request)
com.google.common.util.concurrent.ListenableFuture<CommonProtos.InvokeResponse>	onInvoke(CommonProtos.InvokeRequest request)
com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>	onTopicEvent(DaprClientProtos.CloudEventEnvelope request)

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

build

protected DaprClientGrpc.DaprClientFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<DaprClientGrpc.DaprClientFutureStub>

onInvoke

public com.google.common.util.concurrent.ListenableFuture<CommonProtos.InvokeResponse> onInvoke(CommonProtos.InvokeRequest request)

getTopicSubscriptions

public com.google.common.util.concurrent.ListenableFuture<DaprClientProtos.GetTopicSubscriptionsEnvelope> getTopicSubscriptions(com.google.protobuf.Empty request)

getBindingsSubscriptions

public com.google.common.util.concurrent.ListenableFuture<DaprClientProtos.GetBindingsSubscriptionsEnvelope> getBindingsSubscriptions(com.google.protobuf.Empty request)

onBindingEvent

public com.google.common.util.concurrent.ListenableFuture<DaprClientProtos.BindingResponseEnvelope> onBindingEvent(DaprClientProtos.BindingEventEnvelope request)

onTopicEvent

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> onTopicEvent(DaprClientProtos.CloudEventEnvelope request)