Package org.opennms.core.ipc.grpc.common

Class OpenNMSIpcGrpc.OpenNMSIpcImplBase

java.lang.Object

org.opennms.core.ipc.grpc.common.OpenNMSIpcGrpc.OpenNMSIpcImplBase

All Implemented Interfaces:

io.grpc.BindableService

Enclosing class:

OpenNMSIpcGrpc

public abstract static class OpenNMSIpcGrpc.OpenNMSIpcImplBase
extends Object
implements io.grpc.BindableService

 service definitions of IPC between Minion and OpenNMS
 

Constructor Summary

Constructors

Constructor	Description
OpenNMSIpcImplBase()

Method Summary

Modifier and Type	Method	Description
io.grpc.ServerServiceDefinition	bindService()
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 java.lang.Object

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

Constructor Detail

OpenNMSIpcImplBase

public OpenNMSIpcImplBase()

Method Detail

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
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService