Package com.devebot.opflow

Class OpflowPromExporter

java.lang.Object

com.devebot.opflow.OpflowPromMeasurer

com.devebot.opflow.OpflowPromExporter

public class OpflowPromExporter
extends OpflowPromMeasurer

Author:

topops

Nested Class Summary

Nested classes/interfaces inherited from class com.devebot.opflow.OpflowPromMeasurer

OpflowPromMeasurer.GaugeAction, OpflowPromMeasurer.RpcInvocationCounter

Field Summary

Fields inherited from class com.devebot.opflow.OpflowPromMeasurer

NULL

Constructor Summary

Constructors

Constructor	Description
OpflowPromExporter(Map<String,Object> kwargs)

Method Summary

Modifier and Type	Method	Description
void	countRpcInvocation(String moduleName, String eventName, String routineId, String status)
OpflowPromMeasurer.RpcInvocationCounter	getRpcInvocationCounter(String moduleName)
void	removeComponentInstance(String instanceType, String instanceId)
Map<String,Object>	resetRpcInvocationCounter()
void	updateActiveChannel(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action)
void	updateComponentInstance(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action)
void	updateEngineConnection(com.rabbitmq.client.ConnectionFactory factory, String connectionType, OpflowPromMeasurer.GaugeAction action)

Methods inherited from class com.devebot.opflow.OpflowPromMeasurer

getInstance, getInstance

Methods inherited from class java.lang.Object

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

Constructor Details

OpflowPromExporter

public OpflowPromExporter(Map<String,Object> kwargs) throws OpflowOperationException

Throws:

OpflowOperationException

Method Details

updateComponentInstance

public void updateComponentInstance(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action)

Specified by:

updateComponentInstance in class OpflowPromMeasurer

removeComponentInstance

public void removeComponentInstance(String instanceType, String instanceId)

Specified by:

removeComponentInstance in class OpflowPromMeasurer

updateEngineConnection

public void updateEngineConnection(com.rabbitmq.client.ConnectionFactory factory, String connectionType, OpflowPromMeasurer.GaugeAction action)

Specified by:

updateEngineConnection in class OpflowPromMeasurer

updateActiveChannel

public void updateActiveChannel(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action)

Specified by:

updateActiveChannel in class OpflowPromMeasurer

countRpcInvocation

public void countRpcInvocation(String moduleName, String eventName, String routineId, String status)

Specified by:

countRpcInvocation in class OpflowPromMeasurer

getRpcInvocationCounter

public OpflowPromMeasurer.RpcInvocationCounter getRpcInvocationCounter(String moduleName)

Specified by:

getRpcInvocationCounter in class OpflowPromMeasurer

resetRpcInvocationCounter

public Map<String,Object> resetRpcInvocationCounter()

Specified by:

resetRpcInvocationCounter in class OpflowPromMeasurer