Package io.dapr.v1

Class DaprClientGrpc.DaprClientImplBase

java.lang.Object

io.dapr.v1.DaprClientGrpc.DaprClientImplBase

All Implemented Interfaces:

io.grpc.BindableService

Enclosing class:

DaprClientGrpc

public abstract static class DaprClientGrpc.DaprClientImplBase
extends java.lang.Object
implements io.grpc.BindableService

 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.
 

Constructor Summary

Constructors

Constructor	Description
DaprClientImplBase()

Method Summary

Modifier and Type	Method	Description
io.grpc.ServerServiceDefinition	bindService()
void	getBindingsSubscriptions(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<DaprClientProtos.GetBindingsSubscriptionsEnvelope> responseObserver)
void	getTopicSubscriptions(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<DaprClientProtos.GetTopicSubscriptionsEnvelope> responseObserver)
void	onBindingEvent(DaprClientProtos.BindingEventEnvelope request, io.grpc.stub.StreamObserver<DaprClientProtos.BindingResponseEnvelope> responseObserver)
void	onInvoke(CommonProtos.InvokeRequest request, io.grpc.stub.StreamObserver<CommonProtos.InvokeResponse> responseObserver)
void	onTopicEvent(DaprClientProtos.CloudEventEnvelope request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

Methods inherited from class java.lang.Object

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

Constructor Details

DaprClientImplBase

public DaprClientImplBase()

Method Details

onInvoke

public void onInvoke(CommonProtos.InvokeRequest request, io.grpc.stub.StreamObserver<CommonProtos.InvokeResponse> responseObserver)

getTopicSubscriptions

public void getTopicSubscriptions(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<DaprClientProtos.GetTopicSubscriptionsEnvelope> responseObserver)

getBindingsSubscriptions

public void getBindingsSubscriptions(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<DaprClientProtos.GetBindingsSubscriptionsEnvelope> responseObserver)

onBindingEvent

public void onBindingEvent(DaprClientProtos.BindingEventEnvelope request, io.grpc.stub.StreamObserver<DaprClientProtos.BindingResponseEnvelope> responseObserver)

onTopicEvent

public void onTopicEvent(DaprClientProtos.CloudEventEnvelope request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService