Package io.streamthoughts.azkarra.http.prometheus

Class KafkaStreamsMetricsCollector

java.lang.Object

io.prometheus.client.Collector

io.streamthoughts.azkarra.http.prometheus.KafkaStreamsMetricsCollector

public class KafkaStreamsMetricsCollector
extends io.prometheus.client.Collector

Simple Collector implementation for collecting metrics from KafkaStreams instance.

Nested Class Summary

Nested classes/interfaces inherited from class io.prometheus.client.Collector

io.prometheus.client.Collector.Describable, io.prometheus.client.Collector.MetricFamilySamples, io.prometheus.client.Collector.Type

Field Summary

Fields inherited from class io.prometheus.client.Collector

MILLISECONDS_PER_SECOND, NANOSECONDS_PER_SECOND

Constructor Summary

Constructors

Constructor	Description
KafkaStreamsMetricsCollector(AzkarraStreamsService service, Predicate<Tuple<String,Metric>> filter, String... applications)	Creates a new KafkaStreamsMetricsCollector instance.

Method Summary

Modifier and Type	Method	Description
List<io.prometheus.client.Collector.MetricFamilySamples>	collect()

Methods inherited from class io.prometheus.client.Collector

checkMetricLabelName, checkMetricName, doubleToGoString, register, register, sanitizeMetricName

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaStreamsMetricsCollector

public KafkaStreamsMetricsCollector(AzkarraStreamsService service,
                                    Predicate<Tuple<String,Metric>> filter,
                                    String... applications)

Creates a new KafkaStreamsMetricsCollector instance.

Parameters:

service - the AzkarraStreamsService instance.

Method Detail

collect

public List<io.prometheus.client.Collector.MetricFamilySamples> collect()

Specified by:

collect in class io.prometheus.client.Collector