public static final class DaprClientGrpc.DaprClientStub extends io.grpc.stub.AbstractStub<DaprClientGrpc.DaprClientStub>
User Code definitions
Modifier and Type | Method and 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) |
protected DaprClientGrpc.DaprClientStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<DaprClientGrpc.DaprClientStub>
public void onInvoke(DaprClientProtos.InvokeEnvelope request, io.grpc.stub.StreamObserver<com.google.protobuf.Any> responseObserver)
public void getTopicSubscriptions(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<DaprClientProtos.GetTopicSubscriptionsEnvelope> responseObserver)
public void getBindingsSubscriptions(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<DaprClientProtos.GetBindingsSubscriptionsEnvelope> responseObserver)
public void onBindingEvent(DaprClientProtos.BindingEventEnvelope request, io.grpc.stub.StreamObserver<DaprClientProtos.BindingResponseEnvelope> responseObserver)
public void onTopicEvent(DaprClientProtos.CloudEventEnvelope request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
Copyright © 2020. All rights reserved.