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
com.codahale.metrics.Counter	counter(String name, String topologyId, String componentId, Integer taskId, Integer workerPort, String streamId)
com.codahale.metrics.Counter	counter(String name, TopologyContext context)
com.codahale.metrics.Counter	counter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId)
<T> com.codahale.metrics.Gauge<T>	gauge(String name, com.codahale.metrics.Gauge<T> gauge, TopologyContext context)
<T> SimpleGauge<T>	gauge(T initialValue, String name, String topologyId, String componentId, Integer taskId, Integer port)
Map<String,com.codahale.metrics.Counter>	getTaskCounters(int taskId)
Map<String,com.codahale.metrics.Gauge>	getTaskGauges(int taskId)
Map<String,com.codahale.metrics.Histogram>	getTaskHistograms(int taskId)
Map<String,com.codahale.metrics.Meter>	getTaskMeters(int taskId)
Map<String,com.codahale.metrics.Timer>	getTaskTimers(int taskId)
com.codahale.metrics.Histogram	histogram(String name, TopologyContext context)
JcMetrics	jcMetrics(String name, String topologyId, String componentId, Integer taskId, Integer port)
com.codahale.metrics.Meter	meter(String name, TopologyContext context)
com.codahale.metrics.Meter	meter(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId)
void	metricSet(String prefix, com.codahale.metrics.MetricSet set, TopologyContext context)
void	start(Map<String,Object> stormConfig, DaemonType type)
void	stop()
com.codahale.metrics.Timer	timer(String name, TopologyContext context)

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 <T> SimpleGauge<T> gauge(T initialValue,
                                String name,
                                String topologyId,
                                String componentId,
                                Integer taskId,
                                Integer port)

gauge

public <T> com.codahale.metrics.Gauge<T> gauge(String name,
                                               com.codahale.metrics.Gauge<T> gauge,
                                               TopologyContext context)

jcMetrics

public JcMetrics jcMetrics(String name,
                           String topologyId,
                           String componentId,
                           Integer taskId,
                           Integer port)

meter

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

meter

public com.codahale.metrics.Meter meter(String name,
                                        TopologyContext context)

counter

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

counter

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

counter

public com.codahale.metrics.Counter counter(String name,
                                            TopologyContext context)

metricSet

public void metricSet(String prefix,
                      com.codahale.metrics.MetricSet set,
                      TopologyContext context)

timer

public com.codahale.metrics.Timer timer(String name,
                                        TopologyContext context)

histogram

public com.codahale.metrics.Histogram histogram(String name,
                                                TopologyContext context)

getTaskGauges

public Map<String,com.codahale.metrics.Gauge> getTaskGauges(int taskId)

getTaskCounters

public Map<String,com.codahale.metrics.Counter> getTaskCounters(int taskId)

getTaskHistograms

public Map<String,com.codahale.metrics.Histogram> getTaskHistograms(int taskId)

getTaskMeters

public Map<String,com.codahale.metrics.Meter> getTaskMeters(int taskId)

getTaskTimers

public Map<String,com.codahale.metrics.Timer> getTaskTimers(int taskId)

start

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

stop

public void stop()