org.apache.storm.metrics2

Class StormMetricRegistry

java.lang.Object

org.apache.storm.metrics2.StormMetricRegistry

public class StormMetricRegistry
extends Object

Constructor Summary

Constructors

Constructor and Description
StormMetricRegistry()

Method Summary

Modifier and Type	Method and Description
static com.codahale.metrics.Counter	counter(String name, String topologyId, String componentId, Integer taskId, Integer workerPort, String streamId)
static com.codahale.metrics.Counter	counter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId)
static DisruptorMetrics	disruptorMetrics(String name, String topologyId, String componentId, Integer taskId, Integer port)
static <T> SimpleGauge<T>	gauge(T initialValue, String name, String topologyId, String componentId, Integer taskId, Integer port)
static com.codahale.metrics.Meter	meter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId)
static String	metricName(String name, String stormId, String componentId, Integer taskId, Integer workerPort)
static String	metricName(String name, String stormId, String componentId, String streamId, Integer taskId, Integer workerPort)
static String	metricName(String name, TopologyContext context)
static com.codahale.metrics.MetricRegistry	registry()
static void	start(Map<String,Object> stormConfig, DaemonType type)
static void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

StormMetricRegistry

public StormMetricRegistry()

Method Detail

gauge

public static <T> SimpleGauge<T> gauge(T initialValue,
                                       String name,
                                       String topologyId,
                                       String componentId,
                                       Integer taskId,
                                       Integer port)

disruptorMetrics

public static DisruptorMetrics disruptorMetrics(String name,
                                                String topologyId,
                                                String componentId,
                                                Integer taskId,
                                                Integer port)

meter

public static com.codahale.metrics.Meter meter(String name,
                                               WorkerTopologyContext context,
                                               String componentId,
                                               Integer taskId,
                                               String streamId)

counter

public static com.codahale.metrics.Counter counter(String name,
                                                   WorkerTopologyContext context,
                                                   String componentId,
                                                   Integer taskId,
                                                   String streamId)

counter

public static com.codahale.metrics.Counter counter(String name,
                                                   String topologyId,
                                                   String componentId,
                                                   Integer taskId,
                                                   Integer workerPort,
                                                   String streamId)

start

public static void start(Map<String,Object> stormConfig,
                         DaemonType type)

registry

public static com.codahale.metrics.MetricRegistry registry()

stop

public static void stop()

metricName

public static String metricName(String name,
                                String stormId,
                                String componentId,
                                String streamId,
                                Integer taskId,
                                Integer workerPort)

metricName

public static String metricName(String name,
                                String stormId,
                                String componentId,
                                Integer taskId,
                                Integer workerPort)

metricName

public static String metricName(String name,
                                TopologyContext context)