Package io.dapr
Class DaprClientGrpc.DaprClientStub
java.lang.Object
io.grpc.stub.AbstractStub<DaprClientGrpc.DaprClientStub>
io.dapr.DaprClientGrpc.DaprClientStub
- Enclosing class:
- DaprClientGrpc
public static final class DaprClientGrpc.DaprClientStub extends io.grpc.stub.AbstractStub<DaprClientGrpc.DaprClientStub>
User Code definitions
-
Method Summary
Modifier and Type Method Description protected DaprClientGrpc.DaprClientStub
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
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(DaprClientProtos.InvokeEnvelope request, io.grpc.stub.StreamObserver<com.google.protobuf.Any> responseObserver)
void
onTopicEvent(DaprClientProtos.CloudEventEnvelope request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
-
Method Details
-
build
protected DaprClientGrpc.DaprClientStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)- Specified by:
build
in classio.grpc.stub.AbstractStub<DaprClientGrpc.DaprClientStub>
-
onInvoke
public void onInvoke(DaprClientProtos.InvokeEnvelope request, io.grpc.stub.StreamObserver<com.google.protobuf.Any> 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)
-