Package com.devebot.opflow

Class OpflowPromMeasurer

java.lang.Object

com.devebot.opflow.OpflowPromMeasurer

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 OpflowPromMeasurer	NULL
static Class<? extends OpflowPromMeasurer>	PromExporter

Constructor Summary

Constructors

Constructor	Description
OpflowPromMeasurer()

Method Summary

Modifier and Type	Method	Description
abstract void	countRpcInvocation(String componentType, String eventName, String routineSignature, String status)
static OpflowPromMeasurer	getInstance()
static OpflowPromMeasurer	getInstance(Map<String,Object> kwargs)
abstract OpflowRpcInvocationCounter	getRpcInvocationCounter(String componentType)
abstract Map<String,Object>	getServiceInfo()
abstract Map<String,Object>	resetRpcInvocationCounter()
abstract void	updateComponentInstance(String componentType, String componentId, OpflowPromMeasurer.GaugeAction action)
abstract void	updateEngineConnection(String connectionOwner, 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

PromExporter

public static Class<? extends OpflowPromMeasurer> PromExporter

NULL

public static final OpflowPromMeasurer NULL

Constructor Details

OpflowPromMeasurer

public OpflowPromMeasurer()

Method Details

updateComponentInstance

public abstract void updateComponentInstance(String componentType, String componentId, OpflowPromMeasurer.GaugeAction action)

updateEngineConnection

public abstract void updateEngineConnection(String connectionOwner, String connectionType, OpflowPromMeasurer.GaugeAction action)

countRpcInvocation

public abstract void countRpcInvocation(String componentType, String eventName, String routineSignature, String status)

getRpcInvocationCounter

public abstract OpflowRpcInvocationCounter getRpcInvocationCounter(String componentType)

resetRpcInvocationCounter

public abstract Map<String,Object> resetRpcInvocationCounter()

getServiceInfo

public abstract Map<String,Object> getServiceInfo()

getInstance

public static OpflowPromMeasurer getInstance() throws OpflowOperationException

Throws:

OpflowOperationException

getInstance

public static OpflowPromMeasurer getInstance(Map<String,Object> kwargs) throws OpflowOperationException

Throws:

OpflowOperationException