Package org.opennms.core.ipc.grpc.common
Class OpenNMSIpcGrpc.OpenNMSIpcStub
- java.lang.Object
-
- io.grpc.stub.AbstractStub<OpenNMSIpcGrpc.OpenNMSIpcStub>
-
- org.opennms.core.ipc.grpc.common.OpenNMSIpcGrpc.OpenNMSIpcStub
-
- Enclosing class:
- OpenNMSIpcGrpc
public static final class OpenNMSIpcGrpc.OpenNMSIpcStub extends io.grpc.stub.AbstractStub<OpenNMSIpcGrpc.OpenNMSIpcStub>
service definitions of IPC between Minion and OpenNMS
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected OpenNMSIpcGrpc.OpenNMSIpcStub
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
io.grpc.stub.StreamObserver<RpcResponseProto>
rpcStreaming(io.grpc.stub.StreamObserver<RpcRequestProto> responseObserver)
Streams RPC messages between OpenNMS and Minion.io.grpc.stub.StreamObserver<SinkMessage>
sinkStreaming(io.grpc.stub.StreamObserver<Empty> responseObserver)
Streams Sink messages from Minion to OpenNMS-
Methods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, newStub, newStub, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady
-
-
-
-
Method Detail
-
build
protected OpenNMSIpcGrpc.OpenNMSIpcStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
- Specified by:
build
in classio.grpc.stub.AbstractStub<OpenNMSIpcGrpc.OpenNMSIpcStub>
-
rpcStreaming
public io.grpc.stub.StreamObserver<RpcResponseProto> rpcStreaming(io.grpc.stub.StreamObserver<RpcRequestProto> responseObserver)
Streams RPC messages between OpenNMS and Minion.
-
sinkStreaming
public io.grpc.stub.StreamObserver<SinkMessage> sinkStreaming(io.grpc.stub.StreamObserver<Empty> responseObserver)
Streams Sink messages from Minion to OpenNMS
-
-