A C D F G I K M R S T U V
All Classes All Packages

A

accept() - Method in class io.factorhouse.kpow.MetricFilter

Accepts all metrics.

accept(Predicate<MetricName>) - Method in class io.factorhouse.kpow.MetricFilter

Accepts a metric based on the specified Predicate.

ACCEPT - io.factorhouse.kpow.MetricFilter.FilterType

Represents the acceptance of a metric.

acceptAllMetricFilter() - Static method in class io.factorhouse.kpow.MetricFilter

Returns a metrics filter that accepts all numeric metrics from the running Streams application.

acceptNameStartsWith(String) - Method in class io.factorhouse.kpow.MetricFilter

Accepts all metrics whose name start with the specified prefix.

C

ClientIdKeyStrategy - Class in io.factorhouse.kpow.key

A KeyStrategy implementation that derives the key for metrics data using the client ID and application ID of the active Kafka Streams instance.

ClientIdKeyStrategy() - Constructor for class io.factorhouse.kpow.key.ClientIdKeyStrategy

Constructs a new instance of the ClientIdKeyStrategy.

close() - Method in class io.factorhouse.kpow.StreamsRegistry

ClusterIdKeyStrategy - Class in io.factorhouse.kpow.key

A KeyStrategy implementation that uses the Kafka cluster ID as the primary identifier for keying metrics data in Kpow's internal Kafka topic.

ClusterIdKeyStrategy(Properties) - Constructor for class io.factorhouse.kpow.key.ClusterIdKeyStrategy

Creates an instance of ClusterIdKeyStrategy using properties for AdminClient configuration.

D

defaultMetricFilter() - Static method in class io.factorhouse.kpow.MetricFilter

Returns the default metricsFilter used by the streams agent.

deny() - Method in class io.factorhouse.kpow.MetricFilter

Denies all metrics.

deny(Predicate<MetricName>) - Method in class io.factorhouse.kpow.MetricFilter

Denies a metric based on the specified Predicate.

DENY - io.factorhouse.kpow.MetricFilter.FilterType

Represents the denial of a metric.

denyAllMetricFilter() - Static method in class io.factorhouse.kpow.MetricFilter

Returns a metrics filter that denies all metrics, only sending across the Kafka Streams topology + state on every observation.

denyNameStartsWith(String) - Method in class io.factorhouse.kpow.MetricFilter

Denies all metrics whose name start with the specified prefix.

F

filterProperties(Properties) - Static method in class io.factorhouse.kpow.StreamsRegistry

Filters a Properties object to retain only allowed Kafka properties.

G

getDomain() - Method in class io.factorhouse.kpow.key.Taxon

Returns the domain of the Taxon.

getDomainId() - Method in class io.factorhouse.kpow.key.Taxon

Returns the domain ID of the Taxon.

getFilterId() - Method in class io.factorhouse.kpow.MetricFilter

Returns a unique identifier used by Kpow's user interface to describe which MetricFilter has been configured.

getFilters() - Method in class io.factorhouse.kpow.MetricFilter

Returns an unmodifiable list of MetricFilter.FilterCriteria objects representing the current filter rules applied by this MetricFilter.

getFilterType() - Method in class io.factorhouse.kpow.MetricFilter.FilterCriteria

Returns the type of operation (ACCEPT or DENY) associated with this filter criteria.

getId() - Method in class io.factorhouse.kpow.StreamsRegistry.StreamsAgent

Returns the unique identifier of the registered Kafka Streams application.

getObject() - Method in class io.factorhouse.kpow.key.Taxon

Returns the object of the Taxon.

getObjectId() - Method in class io.factorhouse.kpow.key.Taxon

Returns the object ID of the Taxon.

getPredicate() - Method in class io.factorhouse.kpow.MetricFilter.FilterCriteria

Returns the predicate used in this filter criteria.

getTaxon(String, String) - Method in class io.factorhouse.kpow.key.ClientIdKeyStrategy

getTaxon(String, String) - Method in class io.factorhouse.kpow.key.ClusterIdKeyStrategy

getTaxon(String, String) - Method in interface io.factorhouse.kpow.key.KeyStrategy

Resolves the unique key for metric records based on the provided clientID and applicationID of the registered Kafka Streams application.

I

io.factorhouse.kpow - package io.factorhouse.kpow

io.factorhouse.kpow.key - package io.factorhouse.kpow.key

K

KeyStrategy - Interface in io.factorhouse.kpow.key

Defines the key strategy used by Kpow's streams agent.

M

MetricFilter - Class in io.factorhouse.kpow

Provides filtering functionality for metrics collected from Kafka Streams applications.

MetricFilter() - Constructor for class io.factorhouse.kpow.MetricFilter

Creates a new MetricFilter instance for custom-defined filters.

MetricFilter.FilterCriteria - Class in io.factorhouse.kpow

The FilterCriteria class encapsulates both the filtering type and the predicate used to define a MetricFilter.

MetricFilter.FilterType - Enum in io.factorhouse.kpow

Enum representing the type of filter operation.

R

register(KafkaStreams, Topology, KeyStrategy) - Method in class io.factorhouse.kpow.StreamsRegistry

Registers a Kafka Streams application with the registry for monitoring.

S

stateStoreMetricsOnlyFilter() - Static method in class io.factorhouse.kpow.MetricFilter

Returns a metrics filter that includes only state store metrics.

StreamsRegistry - Class in io.factorhouse.kpow

The StreamsRegistry class serves as a centralized registry for one or more Kafka Streams applications.

StreamsRegistry(Properties) - Constructor for class io.factorhouse.kpow.StreamsRegistry

Constructs a StreamsRegistry instance using the specified Kafka connection properties and the default MetricFilter.

StreamsRegistry(Properties, MetricFilter) - Constructor for class io.factorhouse.kpow.StreamsRegistry

Constructs a StreamsRegistry instance using the specified Kafka properties and metrics filter.

StreamsRegistry.StreamsAgent - Class in io.factorhouse.kpow

Represents an agent for a registered Kafka Streams application.

T

Taxon - Class in io.factorhouse.kpow.key

An internal class which represents a hierarchical identifier used by Kpow's KeyStrategy to key metrics data.

Taxon(String, String, String, String) - Constructor for class io.factorhouse.kpow.key.Taxon

Constructs a new Taxon instance.

U

unregister(StreamsRegistry.StreamsAgent) - Method in class io.factorhouse.kpow.StreamsRegistry

Unregisters a previously registered Kafka Streams application from the registry.

V

valueOf(String) - Static method in enum io.factorhouse.kpow.MetricFilter.FilterType

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.factorhouse.kpow.MetricFilter.FilterType

Returns an array containing the constants of this enum type, in the order they are declared.

A C D F G I K M R S T U V
All Classes All Packages