OpflowPromMeasurer (opflow-core 0.1.27 API)

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

static class OpflowPromMeasurer.RpcInvocationCounter
Field Summary

Fields

Modifier and Type Field Description

static OpflowPromMeasurer NULL
Constructor Summary

Constructors

Constructor Description

OpflowPromMeasurer()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details
- NULL
  
  public static final OpflowPromMeasurer NULL
Constructor Details
- OpflowPromMeasurer
  
  public OpflowPromMeasurer()
Method Details
- updateComponentInstance
  
  public abstract void updateComponentInstance(String instanceType, String instanceId, OpflowPromMeasurer.GaugeAction action)
- removeComponentInstance
  
  public abstract void removeComponentInstance(String instanceType, String instanceId)
- 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
  
  public abstract void countRpcInvocation(String moduleName, String eventName, String routineId, String status)
- getRpcInvocationCounter
  
  public abstract OpflowPromMeasurer.RpcInvocationCounter getRpcInvocationCounter(String moduleName)
- resetRpcInvocationCounter
  
  public abstract Map<String,Object> resetRpcInvocationCounter()
- getInstance
  
  public static OpflowPromMeasurer getInstance() throws OpflowOperationException
  
  Throws:
  
  OpflowOperationException
- getInstance
  
  public static OpflowPromMeasurer getInstance(Map<String,Object> kwargs) throws OpflowOperationException
  
  Throws:
  
  OpflowOperationException