public class MetricsUtils extends Object
| Constructor and Description |
|---|
MetricsUtils() |
| Modifier and Type | Method and Description |
|---|---|
static long |
elapsedSeconds(org.apache.kafka.common.utils.Time time,
long timeMs) |
static com.yammer.metrics.core.MetricName |
metricName(String group,
String type,
String name,
Map<String,String> tags) |
static <T> com.yammer.metrics.core.MetricName |
newGauge(String group,
String type,
String name,
Map<String,String> tags,
Supplier<T> valueSupplier) |
static com.yammer.metrics.core.Meter |
newMeter(com.yammer.metrics.core.MetricName metricName,
String eventType) |
static void |
removeMetrics(Set<com.yammer.metrics.core.MetricName> metricNames) |
public static <T> com.yammer.metrics.core.MetricName newGauge(String group, String type, String name, Map<String,String> tags, Supplier<T> valueSupplier)
public static com.yammer.metrics.core.Meter newMeter(com.yammer.metrics.core.MetricName metricName,
String eventType)
public static void removeMetrics(Set<com.yammer.metrics.core.MetricName> metricNames)
public static long elapsedSeconds(org.apache.kafka.common.utils.Time time,
long timeMs)