com.wavefront.integrations.metrics

Class WavefrontYammerMetricsReporter

java.lang.Object

com.yammer.metrics.reporting.AbstractReporter

com.yammer.metrics.reporting.AbstractPollingReporter

com.wavefront.integrations.metrics.WavefrontYammerMetricsReporter

All Implemented Interfaces:

Runnable

public class WavefrontYammerMetricsReporter
extends com.yammer.metrics.reporting.AbstractPollingReporter

Author:

Mori Bellamy (mori@wavefront.com)

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	logger

Constructor Summary

Constructors

Constructor and Description
WavefrontYammerMetricsReporter(MetricsRegistry metricsRegistry, String name, String hostname, int port, int wavefrontHistogramPort, java.util.function.Supplier<Long> timeSupplier)
WavefrontYammerMetricsReporter(MetricsRegistry metricsRegistry, String name, String hostname, int port, int wavefrontHistogramPort, java.util.function.Supplier<Long> timeSupplier, boolean prependGroupName, java.util.function.Function<MetricName,MetricName> transformer) Reporter of a Yammer metrics registry to Wavefront

Method Summary

Modifier and Type	Method and Description
void	run()

Methods inherited from class com.yammer.metrics.reporting.AbstractPollingReporter

shutdown, shutdown, start

Methods inherited from class com.yammer.metrics.reporting.AbstractReporter

getMetricsRegistry

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static final Logger logger

Constructor Detail

WavefrontYammerMetricsReporter

public WavefrontYammerMetricsReporter(MetricsRegistry metricsRegistry,
                                      String name,
                                      String hostname,
                                      int port,
                                      int wavefrontHistogramPort,
                                      java.util.function.Supplier<Long> timeSupplier)
                               throws IOException

Throws:

IOException

WavefrontYammerMetricsReporter

public WavefrontYammerMetricsReporter(MetricsRegistry metricsRegistry,
                                      String name,
                                      String hostname,
                                      int port,
                                      int wavefrontHistogramPort,
                                      java.util.function.Supplier<Long> timeSupplier,
                                      boolean prependGroupName,
                                      @Nullable
                                      java.util.function.Function<MetricName,MetricName> transformer)
                               throws IOException

Reporter of a Yammer metrics registry to Wavefront

Parameters:

metricsRegistry - The registry to scan-and-report

name - A human readable name for this reporter

hostname - The remote host where the wavefront proxy resides

port - Listening port on Wavefront proxy of graphite-like telemetry data

wavefrontHistogramPort - Listening port for Wavefront histogram data

timeSupplier - Get current timestamp, stubbed for testing

prependGroupName - If true, outgoing telemetry is of the form "group.name" rather than "name".

transformer - If present, applied to each MetricName before flushing to Wavefront. This is useful for adding point tags. Warning: this is called once per metric per scan, so it should probably be performant.

Throws:

IOException - When we can't remotely connect to Wavefront.

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class com.yammer.metrics.reporting.AbstractPollingReporter