All Classes and Interfaces
Class
Description
Wraps an
Emitter with aggregation capability.This class was created to extract the interbroker client configs from the broker at runtime.
The
ClientExportableMetric class extends ContextExportableMetric to process client
metrics telemetry data.The
ClientLabels class provides functionality to extract and clean up metric labels.ClientMetricsTelemetryReceiver implements the ClientTelemetryReceiver interface
to receive client telemetry metrics, augment them with additional labels, and emit them using a provided
telemetry emitter.Translates map keys according to configured rules.
This class encapsulates Confluent naming and mapping conventions defined as part of
https://confluentinc.atlassian.net/wiki/spaces/OBSERVE/pages/890537142/Metrics+Conventions
Context for metrics collectors.
The
ExportableMetric interface represents a metric that can be exported.A
RemoteConfigurationSource that supports reading from a local file.A grouping of unique
NamedPredicates to be applied to an
ExporterProvides labels for host information.
Configuration for the HttpExporter.
Provides labels for Java runtime environment information.
Deprecated.
An object that supplies a MetricKey that we can use to uniquely identify a metric.
This RemoteConfigurationSource will continuously poll the Kubernetes API for ConfigMap and Secret
containing the RemoteConfiguration objects.
A LastValueTracker uses a ConcurrentMap to maintain historic values for a given key, and return
a previous value and an Instant for that value.
Value object that contains the name and labels for a Metric.
A metrics collector that emits a single metric representing that this node is up in this cluster.
OpenTelemetry implementation of TelemetryReporterSelfMetrics.
Implement this interface to collect metrics for your component.
A proxy class that wraps a closeable resource and keeps track of the number of references to it.
Wrapper class that encapsulates the result of requesting remote configuration.
A wrapper on the protobuf
Resource.Builder that enforces Confluent conventions.Provides labels from the runtime context (Cloud, Deployment, Host, JVM, etc) that can be set on
the
.
invalid reference
io.opencensus.proto.resource.v1.ResourceConfiguration for retry behavior with exponential backoff.
Handles retry logic with exponential backoff for remote configuration requests.
A sensor for recording self-metric values with optional tags.
An OpenTelemetry (unbuilt)
Metric and its associated MetricKey.A MetricsCollector that ensures exactly one metric will be exported per minute by oversampling the metric source
every 30 seconds.
Must construct after
1.
Simple metrics abstraction for Telemetry Reporter self-metrics.
Custom object for Kubernetes objects such as
V1Secret
or V1ConfigMap
We define the fields we need here instead of pulling all K8s APIs to keep the size of the `ce-metrics` jar small