Package io.dapr

Class DaprClientGrpc.DaprClientFutureStub

java.lang.Object

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

io.dapr.DaprClientGrpc.DaprClientFutureStub

Enclosing class:

DaprClientGrpc

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

 User Code definitions
 

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<com.google.protobuf.Any>	onInvoke(DaprClientProtos.InvokeEnvelope 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<com.google.protobuf.Any> onInvoke(DaprClientProtos.InvokeEnvelope 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)