Package org.nuxeo.runtime.stream

Class StreamMetricsComputation.LatencyMetric

java.lang.Object

org.nuxeo.runtime.stream.StreamMetricsComputation.LatencyMetric

Enclosing class:

StreamMetricsComputation

public static class StreamMetricsComputation.LatencyMetric
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected LogPartitionGroup	consumer
protected io.dropwizard.metrics5.MetricName	endMetric
protected io.dropwizard.metrics5.MetricName	lagMetric
protected Latency	latency
protected io.dropwizard.metrics5.MetricName	latMetric
protected io.dropwizard.metrics5.MetricName	posMetric
static Object	PREFIX
protected boolean	registered
protected io.dropwizard.metrics5.MetricRegistry	registry

Constructor Summary

Constructors

Constructor	Description
LatencyMetric(LogPartitionGroup consumer, io.dropwizard.metrics5.MetricRegistry registry)

Method Summary

Modifier and Type	Method	Description
void	destroy()
protected io.dropwizard.metrics5.MetricName	getMetricName(String name)
Name	getStream()
protected void	registerMetrics()
protected void	unregisterMetrics()
boolean	update(LogManager manager, Codec<Record> codec)

Methods inherited from class java.lang.Object

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

Field Detail

PREFIX

public static final Object PREFIX

consumer

protected final LogPartitionGroup consumer

registry

protected final io.dropwizard.metrics5.MetricRegistry registry

endMetric

protected final io.dropwizard.metrics5.MetricName endMetric

posMetric

protected final io.dropwizard.metrics5.MetricName posMetric

lagMetric

protected final io.dropwizard.metrics5.MetricName lagMetric

latMetric

protected final io.dropwizard.metrics5.MetricName latMetric

latency

protected Latency latency

registered

protected boolean registered

Constructor Detail

LatencyMetric

public LatencyMetric(LogPartitionGroup consumer,
                     io.dropwizard.metrics5.MetricRegistry registry)

Method Detail

getMetricName

protected io.dropwizard.metrics5.MetricName getMetricName(String name)

registerMetrics

protected void registerMetrics()

unregisterMetrics

protected void unregisterMetrics()

update

public boolean update(LogManager manager,
                      Codec<Record> codec)

destroy

public void destroy()

getStream

public Name getStream()