Creates a `(BoxEntrySink, PendingSinkResolver)` pair for deferred sink attachment. The returned sink can be used immediately. While the resolver has

Clone produces a fresh handle to the same shared value, without a captured snapshot.

# Panics The default (no provider supplied) builds an empty [`SdkMeterProvider`] with no readers attached, which does not require a tokio runtime. I

Create a [`TestEntrySink`] and a connected [`BoxEntrySink`] that can be used in your application This requires that the `test-util` feature be enable

Convert a `#[metric]` directly to `TestEntry` # Example ``` use metrique::unit_of_work::metrics; use metrique_writer::test_util::test_metric; #[met

Wrap `entry` in a smart pointer that will automatically append it to this sink when dropped. This will help enforce that an entry is always appended

Add a value to the histogram. The value is converted to observations using the metric value's implementation, then recorded in the aggregation strate

Return all the entries inside the test sink Note: this does not drain or otherwise modify the contained entries

This method is mostly useful for the EMF internal implementation

Add a new entry into this aggregate

Returns an entry at a specific index

Atomically replace the shared value. All handles (including this one) will see the new value on their next [`snapshot`](State::snapshot), unless they

Converts an [`Entry`] into a `TestEntry` that can be introspected > NOTE: This method is probably not what you want. For testing an individual metric

Pull the stored duration out of the state, leaving empty state behind

Bind the format to an `output` IO destination to create an [`EntryIoStream`]. This is the way to get an [`EntryIoStream`] from a [`Format`] and an [`

Set a thread-local time source override and return a guard When the guard is dropped, the thread-local override will be cleared # Examples ``` use me

The public name defined by CloudWatch for the unit.

Build an [`Emf`] for formatting metrics with the input configuration ## Example This will publish the metrics to both the `MyApp` and the `MyApp2` n

Add 1 to this counter

Returns the amount of time elapsed since this instant was created # Returns The elapsed time as a Duration # Examples ``` use metrique_timesource:

Starts the stopwatch and returns a guard that will stop it when dropped. The stopwatch will accumulate time until the guard is dropped. Multiple call

Drains all currently appended entries from the sink and returns them as an owned [`Vec`]. The sink can still be used afterwards.

Send an entry to be aggregated

Records an occurrence of a value in the histogram.

Skips all entry validations When `skip` is true, this is a shorthand that enables all of: - [`allow_dimensions_with_no_data`](Self::allow_dimensions_

Update the value.

Open the slot and provie an initial value

Extend this error with all of the validation failures recorded in `other`.

Return a config with a custom sampling interval. Defaults to 30 seconds. Intervals below [`sysinfo::MINIMUM_CPU_UPDATE_INTERVAL`] (~200ms) produce un

Return the content of the inner `Vec<u8>` as a String, panicking if it's not valid utf-8

See [`std::time::SystemTime::duration_since`]

Extend this error with all of the validation failures recorded in `error`, but only require `&mut Self`.

Async flush of remaining PutLogEvents batches. The submit loop drains remaining payloads, then signals completion. After this returns, the stream det

Capture and return a snapshot of the current value. The first call captures the value; subsequent calls return the same `Arc<T>`.

Add the field `name` context for all of the validation failures reported in `self`.

Helper function to format an entry and return the parsed EMF output

[Merge](`Entry::merge_by_ref`) every entry written to this formatter with the contents of `globals`. There is intentionally both a [`EntryIoStreamExt

Synchronous counterpart to [`Self::flush_async`]: drive `force_flush` on the meter provider directly, blocking the calling thread until the flush comp

Get a reference to the value, if present.

Set the value for this `Flex` field. This is useful for builder-style construction. # Example ```rust use metrique::flex::Flex; let metric = Flex::n

Flush all pending entries

Returns [`Ok`] if no validation failures were recorded, otherwise [`Err`] [`ValidationError`] containing all of the recorded validation falures.

Record a single observation.

Set this counter to `i`, discarding the previous value

Drive `force_flush` on the meter provider and resolve once it's done. Errors from `force_flush` are logged at `warn` level. Callers outside a tokio r

Record a generic validation failure with a reason string.

Clear the values in this distribution, making it empty

Read out the current value of the metrics, resetting counters and histograms (and not resetting gauges).