public class MetricsUtils
extends java.lang.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(java.lang.String group,
java.lang.String type,
java.lang.String name,
java.util.Map<java.lang.String,java.lang.String> tags) |
static <T> com.yammer.metrics.core.MetricName |
newGauge(java.lang.String group,
java.lang.String type,
java.lang.String name,
java.util.Map<java.lang.String,java.lang.String> tags,
java.util.function.Supplier<T> valueSupplier) |
static com.yammer.metrics.core.Meter |
newMeter(com.yammer.metrics.core.MetricName metricName,
java.lang.String eventType) |
static void |
removeMetrics(java.util.Set<com.yammer.metrics.core.MetricName> metricNames) |
public static <T> com.yammer.metrics.core.MetricName newGauge(java.lang.String group, java.lang.String type, java.lang.String name, java.util.Map<java.lang.String,java.lang.String> tags, java.util.function.Supplier<T> valueSupplier)
public static com.yammer.metrics.core.Meter newMeter(com.yammer.metrics.core.MetricName metricName, java.lang.String eventType)
public static void removeMetrics(java.util.Set<com.yammer.metrics.core.MetricName> metricNames)
public static long elapsedSeconds(org.apache.kafka.common.utils.Time time, long timeMs)
public static com.yammer.metrics.core.MetricName metricName(java.lang.String group, java.lang.String type, java.lang.String name, java.util.Map<java.lang.String,java.lang.String> tags)