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 Details

    • 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 Details

    • LatencyMetric

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

  • Method Details

    • 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()