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 -
Field Summary
Fields inherited from class com.devebot.opflow.OpflowPromMeasurer
DEFAULT_PROM_EXPORTER_PORT_ENV, DEFAULT_PROM_EXPORTER_PORT_KEY, DEFAULT_PROM_EXPORTER_PORT_VAL, DEFAULT_PROM_PUSHGATEWAY_ADDR_ENV, DEFAULT_PROM_PUSHGATEWAY_ADDR_KEY, DEFAULT_PROM_PUSHGATEWAY_ADDR_VAL, DEFAULT_PROM_PUSHGATEWAY_JOBNAME, NULL -
Constructor Summary
Constructors Constructor Description OpflowPromExporter() -
Method Summary
Modifier and Type Method Description voidchangeActiveChannel(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action)voidchangeComponentInstance(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action)voiddecEngineConnectionGauge(com.rabbitmq.client.ConnectionFactory factory, String connectionType)voidincEngineConnectionGauge(com.rabbitmq.client.ConnectionFactory factory, String connectionType)voidincRpcInvocationEvent(String module_name, String engineId, String routineId, String status)voidremoveComponentInstance(String instanceType, String instanceId)
-
Constructor Details
-
Method Details
-
changeComponentInstance
public void changeComponentInstance(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action)- Specified by:
changeComponentInstancein classOpflowPromMeasurer
-
removeComponentInstance
- Specified by:
removeComponentInstancein classOpflowPromMeasurer
-
incEngineConnectionGauge
public void incEngineConnectionGauge(com.rabbitmq.client.ConnectionFactory factory, String connectionType)- Specified by:
incEngineConnectionGaugein classOpflowPromMeasurer
-
decEngineConnectionGauge
public void decEngineConnectionGauge(com.rabbitmq.client.ConnectionFactory factory, String connectionType)- Specified by:
decEngineConnectionGaugein classOpflowPromMeasurer
-
changeActiveChannel
public void changeActiveChannel(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action)- Specified by:
changeActiveChannelin classOpflowPromMeasurer
-
incRpcInvocationEvent
public void incRpcInvocationEvent(String module_name, String engineId, String routineId, String status)- Specified by:
incRpcInvocationEventin classOpflowPromMeasurer
-