Module source

“Base” metrics used by all dataflow sources.

We label metrics by the concrete source that they get emitted from (which makes these metrics in-eligible for ingestion by third parties), so that means we have to register the metric vectors to the registry once, and then generate concrete instantiations of them for the appropriate source.

Modules

kafka

Metrics for Kafka consumption.

mysql

Metrics for MySQL.

postgres

Metrics for Postgres.

Structs

GeneralSourceMetricDefs 🔒

Definitions for general metrics about sources that are not specific to the source type.

OffsetCommitMetrics 🔒

Metrics about committing offsets.

SourceMetricDefs 🔒

A set of base metrics that hang off a central metrics registry, labeled by the source they belong to.

SourceMetrics 🔒

General metrics about sources that are not specific to the source type

SourcePersistSinkMetrics 🔒

Source-specific metrics used by the persist_sink