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 class	OpflowPromMeasurer.GaugeAction

Field Summary

Fields

Modifier and Type	Field	Description
static String	DEFAULT_PROM_EXPORTER_PORT_ENV
static String	DEFAULT_PROM_EXPORTER_PORT_KEY
static String	DEFAULT_PROM_EXPORTER_PORT_VAL
static String	DEFAULT_PROM_PUSHGATEWAY_ADDR_ENV
static String	DEFAULT_PROM_PUSHGATEWAY_ADDR_KEY
static String	DEFAULT_PROM_PUSHGATEWAY_ADDR_VAL
static String	DEFAULT_PROM_PUSHGATEWAY_JOBNAME
static OpflowPromMeasurer	NULL

Constructor Summary

Constructors

Constructor	Description
OpflowPromMeasurer()

Method Summary

Modifier and Type	Method	Description
abstract void	changeActiveChannel(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action)
abstract void	changeComponentInstance(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action)
abstract void	decEngineConnectionGauge(com.rabbitmq.client.ConnectionFactory factory, String connectionType)
static OpflowPromMeasurer	getInstance()
abstract void	incEngineConnectionGauge(com.rabbitmq.client.ConnectionFactory factory, String connectionType)
abstract void	incRpcInvocationEvent(String module_name, String engineId, String routineId, String status)
abstract void	removeComponentInstance(String instanceType, String instanceId)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_PROM_EXPORTER_PORT_VAL

public static final String DEFAULT_PROM_EXPORTER_PORT_VAL

See Also:

Constant Field Values

DEFAULT_PROM_EXPORTER_PORT_KEY

public static final String DEFAULT_PROM_EXPORTER_PORT_KEY

See Also:

Constant Field Values

DEFAULT_PROM_EXPORTER_PORT_ENV

public static final String DEFAULT_PROM_EXPORTER_PORT_ENV

See Also:

Constant Field Values

DEFAULT_PROM_PUSHGATEWAY_ADDR_VAL

public static final String DEFAULT_PROM_PUSHGATEWAY_ADDR_VAL

See Also:

Constant Field Values

DEFAULT_PROM_PUSHGATEWAY_ADDR_KEY

public static final String DEFAULT_PROM_PUSHGATEWAY_ADDR_KEY

See Also:

Constant Field Values

DEFAULT_PROM_PUSHGATEWAY_ADDR_ENV

public static final String DEFAULT_PROM_PUSHGATEWAY_ADDR_ENV

See Also:

Constant Field Values

DEFAULT_PROM_PUSHGATEWAY_JOBNAME

public static final String DEFAULT_PROM_PUSHGATEWAY_JOBNAME

See Also:

Constant Field Values

NULL

public static final OpflowPromMeasurer NULL

Constructor Details

OpflowPromMeasurer

public OpflowPromMeasurer()

Method Details

changeComponentInstance

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

removeComponentInstance

public abstract void removeComponentInstance(String instanceType, String instanceId)

incEngineConnectionGauge

public abstract void incEngineConnectionGauge(com.rabbitmq.client.ConnectionFactory factory, String connectionType)

decEngineConnectionGauge

public abstract void decEngineConnectionGauge(com.rabbitmq.client.ConnectionFactory factory, String connectionType)

changeActiveChannel

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

incRpcInvocationEvent

public abstract void incRpcInvocationEvent(String module_name, String engineId, String routineId, String status)

getInstance

public static OpflowPromMeasurer getInstance() throws OpflowOperationException

Throws:

OpflowOperationException