org.apache.nifi.reporting.datadog.metrics

Class MetricsService

java.lang.Object

org.apache.nifi.reporting.datadog.metrics.MetricsService

public class MetricsService
extends Object

A service used to produce key/value metrics based on a given input.

Constructor Summary

Constructors

Constructor and Description
MetricsService()

Method Summary

Modifier and Type	Method and Description
protected long	calculateProcessingNanos(ProcessGroupStatus status)
Map<String,Double>	getConnectionStatusMetrics(ConnectionStatus status)
Map<String,Double>	getDataFlowMetrics(ProcessGroupStatus status)
Map<String,Double>	getJVMMetrics(JmxJvmMetrics virtualMachineMetrics)
Map<String,Double>	getPortStatusMetrics(PortStatus status)
Map<String,Double>	getProcessorMetrics(ProcessorStatus status)
Map<String,String>	getProcessorTags(ProcessorStatus status)

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricsService

public MetricsService()

Method Detail

getProcessorMetrics

public Map<String,Double> getProcessorMetrics(ProcessorStatus status)

getProcessorTags

public Map<String,String> getProcessorTags(ProcessorStatus status)

getPortStatusMetrics

public Map<String,Double> getPortStatusMetrics(PortStatus status)

getConnectionStatusMetrics

public Map<String,Double> getConnectionStatusMetrics(ConnectionStatus status)

getDataFlowMetrics

public Map<String,Double> getDataFlowMetrics(ProcessGroupStatus status)

getJVMMetrics

public Map<String,Double> getJVMMetrics(JmxJvmMetrics virtualMachineMetrics)

calculateProcessingNanos

protected long calculateProcessingNanos(ProcessGroupStatus status)