Package org.opennms.core.ipc.grpc.client

Class MinionGrpcClient

java.lang.Object

org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory<String>

org.opennms.core.ipc.grpc.client.MinionGrpcClient

All Implemented Interfaces:

MessageDispatcherFactory

public class MinionGrpcClient
extends AbstractMessageDispatcherFactory<String>

Minion GRPC client runs both RPC/Sink together. gRPC runs in a typical web server/client mode, so gRPC client runs on each minion and gRPC server runs on OpenNMS. Minion GRPC Client tries to get two stubs/streams (RPC/Sink) from OpenNMS server when it is in active state. It also initializes RPC observer/handler to receive requests from OpenNMS.

RPC : RPC runs in bi-directional streaming mode. Minion gets each request and it handles each request in a separate thread. Once the request is executed, the response sender call is synchronized as writing to observer is not thread-safe. Minion also sends it's headers (SystemId/location) to OpenNMS whenever the stub is initialized.

Sink: Sink runs in uni-directional streaming mode. If the sink module is async and OpenNMS Server is not active, the messages are buffered and blocked till minion is able to connect to OpenNMS.

Constructor Summary

Constructors

Constructor	Description
MinionGrpcClient(MinionIdentity identity, org.osgi.service.cm.ConfigurationAdmin configAdmin)

Method Summary

Modifier and Type	Method	Description
void	bind(RpcModule module)
<S extends Message,T extends Message> void	dispatch(SinkModule<S,T> module, String metadata, T message)
org.osgi.framework.BundleContext	getBundleContext()
String	getMetricDomain()
com.codahale.metrics.MetricRegistry	getMetrics()
io.opentracing.Tracer	getTracer()
TracerRegistry	getTracerRegistry()
void	setBundleContext(org.osgi.framework.BundleContext bundleContext)
void	setMetrics(com.codahale.metrics.MetricRegistry metrics)
void	setTracerRegistry(TracerRegistry tracerRegistry)
void	shutdown()
void	start()
void	unbind(RpcModule module)

Methods inherited from class org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory

createAsyncDispatcher, createSyncDispatcher, createSyncDispatcher, getModuleMetadata, onDestroy, onInit

Methods inherited from class java.lang.Object

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

Constructor Detail

MinionGrpcClient

public MinionGrpcClient(MinionIdentity identity,
                        org.osgi.service.cm.ConfigurationAdmin configAdmin)

Method Detail

start

public void start()
           throws IOException

Throws:

IOException

bind

public void bind(RpcModule module)
          throws Exception

Throws:

Exception

unbind

public void unbind(RpcModule module)
            throws Exception

Throws:

Exception

shutdown

public void shutdown()

setBundleContext

public void setBundleContext(org.osgi.framework.BundleContext bundleContext)

getMetricDomain

public String getMetricDomain()

Specified by:

getMetricDomain in class AbstractMessageDispatcherFactory<String>

getBundleContext

public org.osgi.framework.BundleContext getBundleContext()

Specified by:

getBundleContext in class AbstractMessageDispatcherFactory<String>

getTracer

public io.opentracing.Tracer getTracer()

Specified by:

getTracer in class AbstractMessageDispatcherFactory<String>

getMetrics

public com.codahale.metrics.MetricRegistry getMetrics()

Specified by:

getMetrics in class AbstractMessageDispatcherFactory<String>

setMetrics

public void setMetrics(com.codahale.metrics.MetricRegistry metrics)

getTracerRegistry

public TracerRegistry getTracerRegistry()

setTracerRegistry

public void setTracerRegistry(TracerRegistry tracerRegistry)

dispatch

public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module,
                                                                 String metadata,
                                                                 T message)

Specified by:

dispatch in class AbstractMessageDispatcherFactory<String>