Package io.streamthoughts.azkarra.api.streams

Interface KafkaStreamsContainer.KafkaMetricFilter

All Superinterfaces:

Predicate<Tuple<String,Metric>>

Enclosing interface:

KafkaStreamsContainer

public static interface KafkaStreamsContainer.KafkaMetricFilter
extends Predicate<Tuple<String,Metric>>

A KafkaMetricFilter can be used to only get specific metrics.

Method Summary

Static Methods

Modifier and Type	Method	Description
static KafkaStreamsContainer.KafkaMetricFilter	all()
static KafkaStreamsContainer.KafkaMetricFilter	filterByGroup(String groupName)
static KafkaStreamsContainer.KafkaMetricFilter	filterByGroupAndMetricName(String groupName, String metricName)
static KafkaStreamsContainer.KafkaMetricFilter	of(Predicate<Tuple<String,Metric>> predicate)

Methods inherited from interface java.util.function.Predicate

and, negate, or, test

Method Detail

of

static KafkaStreamsContainer.KafkaMetricFilter of(Predicate<Tuple<String,Metric>> predicate)

all

static KafkaStreamsContainer.KafkaMetricFilter all()

filterByGroup

static KafkaStreamsContainer.KafkaMetricFilter filterByGroup(String groupName)

filterByGroupAndMetricName

static KafkaStreamsContainer.KafkaMetricFilter filterByGroupAndMetricName(String groupName,
                                                                          String metricName)