Module goodmetrics::pipeline

Types for wiring to downstream collectors

Structs

• Aggregator
  Aggregates metrics and presents a pollable interface for creating batches of metrics.
• LoggingSink
  A metrics sink that just logs metrics and drops them
• SerializingSink
  A metrics sink that provides external synchronization for a downstream sink.
• StreamSink
  A metrics sink that queues metrics in an mpsc for a downstream

Enums

• DistributionMode
  Strategies for recording the distribution of observations within each reporting window.
• TimeSource
  Primarily for testing and getting really deep into some stuff, here’s a way to customize how you group aggregates over time.

Traits

• AggregationBatcher
  A batcher for aggregated metrics.
• Sink
  A drain that accepts Sunk

Functions

• stream_batches
  Creates size-limited batches of metrics with a batch timeout

Type Aliases

• AggregatedMetricsMap
  User-named metrics
• DimensionPosition
  A dimension position is a unique set of dimensions. If a measurement has (1) the same metric name, (2) the same dimensions and (3) the same measurement name as another measurement, it is the same measurement and they should be aggregated together.
• DimensionedMeasurementsMap
  A metrics measurement family is grouped first by its dimension position
• MeasurementAggregationMap
  Within the dimension position there is a collection of named measurements; we’ll store the aggregated view of these