A simple Entry for testing

Adapts a [`MetricRecorder`] to the [`FlushImmediatelyObserver`] trait by mapping each event to the built-in `metrique_*` counter/histogram on the reco

Adapter that captures a [`Value`]'s string representation into a buffer. Strings are appended directly. Metric observations are written as their numer

An [`EntrySink`] implementation for entries of type `T`. Entries are appended to a shared queue that's drained by a background thread. See [`Backgrou

If a `DropAll` is created, dropping the `DropAll` will effectively ignore the existence of all `Guards`. Dropping a `DropAll` will cause `value` to d

Adapter for writing individual elements inside a JSON array in EMF output. String values are JSON-escaped. Metric values write their observations as

`ValueWriter` is the second level of the visitor pattern. It's created per-field and consumed when the value writes to it. The `Sized` bound on `self`

Adapter for writing individual elements inside a JSON array. String values are JSON-escaped. Metric values write their observations as numeric scalar

A cheap, short-lived reference returned by [`State::latest`]. Always reads the latest value (bypasses the snapshot). This means that the guarded valu

A sink that captures rendered output for format-aware testing.

Embedded aggregator for collecting multiple observations within a single wide event Use this when a single operation fans out to multiple sub-operati

Trait for sinks that accept aggregated entries by value (takes `&mut self`) This is for single-threaded aggregation contexts where exclusive access i

Trait for sinks that accept aggregated entries by reference (takes `&mut self`) This enables aggregating the same input across multiple sinks without

Ties together source type, merge behavior, and key extraction. This trait combines all the pieces needed for aggregation into a single strategy type.

Defines how individual field values are aggregated. This trait operates at the field level, not the entry level. Each aggregation strategy (Counter,

Result of keyed aggregation combining key and aggregated value. Used by [`crate::aggregator::KeyedAggregator`] to emit aggregated entries with their

Strategy for aggregating observations in a histogram. Implementations determine how values are stored and converted to observations when the histogra

Single entry covering all four instrument kinds, so the dispatch inside `InstrumentCache::record` is exercised end-to-end.

Provides a more generic interface than [`EntrySink`] but may come at the cost of dynamic dispatch and heap allocation to store the in-memory buffer.

Key extraction for ApiCall

A wrapper that appends and closes an entry when dropped. This struct holds a metric entry and a sink. When the struct is dropped, it closes the entry

Handle to an [`AppendAndCloseOnDrop`], returned by [`AppendAndCloseOnDrop::handle`]. This is basically an `Arc<AppendAndCloseOnDrop>`, allowing share

Thread-safe exponential bucketing strategy using atomic counters. This uses 976 buckets and supports values from 0 to u64::MAX. Values greater than u

A [`GlobalEntrySink`] that can do nothing until it is attached to an output stream or sink.

Extension trait for `AttachGlobalEntrySink`, containing functions that use types that are not present in [`metrique_writer_core`].

Extension methods for subscribing system metrics to a global entry sink.

Extension methods for subscribing Tokio runtime metrics to a global entry sink. Spawns a background task that periodically samples [`RuntimeMetrics`]