Package com.devebot.opflow
Class OpflowPromMeasurer
java.lang.Object
com.devebot.opflow.OpflowPromMeasurer
- Direct Known Subclasses:
OpflowPromExporter
public abstract class OpflowPromMeasurer extends Object
- Author:
- acegik
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classOpflowPromMeasurer.GaugeActionstatic classOpflowPromMeasurer.RpcInvocationCounter -
Field Summary
Fields Modifier and Type Field Description static OpflowPromMeasurerNULL -
Constructor Summary
Constructors Constructor Description OpflowPromMeasurer() -
Method Summary
Modifier and Type Method Description abstract voidcountRpcInvocation(String moduleName, String eventName, String routineId, String status)static OpflowPromMeasurergetInstance()static OpflowPromMeasurergetInstance(Map<String,Object> kwargs)abstract OpflowPromMeasurer.RpcInvocationCountergetRpcInvocationCounter(String moduleName)abstract voidremoveComponentInstance(String instanceType, String instanceId)abstract Map<String,Object>resetRpcInvocationCounter()abstract voidupdateActiveChannel(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action)abstract voidupdateComponentInstance(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action)abstract voidupdateEngineConnection(com.rabbitmq.client.ConnectionFactory factory, String connectionType, OpflowPromMeasurer.GaugeAction action)
-
Field Details
-
Constructor Details
-
OpflowPromMeasurer
public OpflowPromMeasurer()
-
-
Method Details
-
updateComponentInstance
public abstract void updateComponentInstance(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action) -
removeComponentInstance
-
updateEngineConnection
public abstract void updateEngineConnection(com.rabbitmq.client.ConnectionFactory factory, String connectionType, OpflowPromMeasurer.GaugeAction action) -
updateActiveChannel
public abstract void updateActiveChannel(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action) -
countRpcInvocation
-
getRpcInvocationCounter
-
resetRpcInvocationCounter
-
getInstance
- Throws:
OpflowOperationException
-
getInstance
public static OpflowPromMeasurer getInstance(Map<String,Object> kwargs) throws OpflowOperationException- Throws:
OpflowOperationException
-