Struct WindowedCounterGroup 

pub struct WindowedCounterGroup { /* private fields */ }

A CounterGroup restricted to torn-safe windowed access.

Holds an inner base CounterGroup and exposes only the windowed writer/reader (set_with_window/load_with_window), the lock-free read accessors, and metadata — not the base group’s lock-free mutators (set/add/increment). Because no lock-free mutator is reachable, a windowless write is unrepresentable and torn-safety is enforced by the type. The window store and the atomic (value, window) pairing live on the inner base group (Phase-1 GroupWindows lock); this wrapper only narrows the API.

Implementations

impl WindowedCounterGroup

pub const fn new(entries: usize) -> Self

Create a windowed counter group with the given number of entries.

pub fn entries(&self) -> usize

Return the number of entries in this group.

pub fn set_with_window(&self, idx: usize, value: u64, window: Window) -> bool

Set the counter at idx to value and record its acquisition window as a torn-safe pair. Returns false if idx is out of bounds.

pub fn load_with_window(&self, idx: usize) -> (Option<u64>, Option<Window>)

Load the counter at idx and its acquisition window as a torn-safe pair. Returns (None, None) if idx is out of bounds.

pub fn value(&self, idx: usize) -> Option<u64>

Load the current value of the counter at idx.

pub fn set_metadata(&self, idx: usize, metadata: HashMap<String, String>)

Set metadata for the entry at idx.

pub fn insert_metadata(&self, idx: usize, key: String, value: String)

Set a single metadata key-value pair for the entry at idx.

pub fn load_metadata(&self, idx: usize) -> Option<HashMap<String, String>>

Load metadata for the entry at idx.

pub fn metadata_snapshot(&self) -> Vec<(usize, HashMap<String, String>)>

Snapshot all metadata.

pub fn clear_metadata(&self, idx: usize)

Remove metadata for the entry at idx.

Trait Implementations

impl Metric for WindowedCounterGroup

fn as_any(&self) -> Option<&dyn Any>

Get the current metric as an Any instance. This is meant to allow custom processing for known metric types.

fn value(&self) -> Option<Value<'_>>

Get the value of the current metric, should it be enabled.

fn is_enabled(&self) -> bool

Indicate whether this metric has been set up.

fn load_window(&self) -> Option<Window>

Get this metric’s acquisition window, if one has been recorded.

fn value_with_window(&self) -> (Option<Value<'_>>, Option<Window>)

Get this metric’s value and its acquisition window as a torn-safe pair.

fn provide<'a>(&'a self, request: &mut Request<'a>)

Provides type based access to context.