Module metrics 

Utilities related to metrics.

Structs

BackpressureMetrics

Metrics for the persist_source backpressure operator, summed over every instance of the operator in the process. Like SinkMetrics, these belong to a dataflow operator rather than the client, but the client owns the only registry the operator can reach.

Metrics

Prometheus monitoring metrics.

SinkMetrics

Metrics for the persist sink. (While this lies slightly outside the usual abstraction boundary of the client, it’s convenient to manage them together.

SinkWorkerMetrics

Metrics for the persist sink that are labeled per-worker.

Enums

UpdateDelta

Represents a change in a number of updates kept in a data structure (e.g., a buffer length or capacity change).

Functions

encode_ts_metric

Encode a frontier into an i64 acceptable for use in metrics.