Struct Procession 

pub struct Procession {
    pub chunks: Vec<Chunk>,
    pub labels: LabelSet,
}

This represents a time series of metrics collected over some length of time

Fields

chunks: Vec<Chunk>

The series of chunks representing ~65 seconds of time in each chunk

labels: LabelSet

The set of all unique keys and labels currently in the set

Implementations

impl Procession

pub fn memory_size(&self) -> usize

A naive attempt to calculate the memory size of the current state

pub fn insert_entry(&mut self, entry: Entry, label: u16)

Insert a new entry into the last (or newly last) Chunk

pub fn last_chunk_and_ms(&mut self, now: OffsetDateTime) -> (&mut Chunk, u16)

Find the last chunk in this Procession along with the number of milliseconds since the reference time on that chunk. If either there are no chunks already available or the number of milliseconds since the last chunk’s reference time would exceed u16::MAX a new chunk is added and a mutable reference to that chunk is returned with a ms value of 0

pub fn ensure_label(&mut self, k: &Key) -> u16

Ensure the provided key is in the [labels]

pub fn iter(&self) -> MetricsRefIterator<'_>

create an iterator for the raw metric events currently recorded that will be tied to the lifetime of this instance of the Procession

pub fn iter_owned(&self) -> MetricsIterator<'_>

create an iterator for the raw metric events currently recorded providing owned version of all events

Trait Implementations

impl Clone for Procession

fn clone(&self) -> Procession

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Procession

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Procession

fn default() -> Procession

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Procession

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'a> From<&'a Procession> for MetricsRefIterator<'a>

fn from(value: &'a Procession) -> Self

Converts to this type from the input type.

impl<'a> From<&'a Procession> for MetricsIterator<'a>

fn from(value: &'a Procession) -> Self

Converts to this type from the input type.

impl FromIterator<Metric> for Procession

fn from_iter<T: IntoIterator<Item = Metric>>(iter: T) -> Self

Creates a value from an iterator.

impl<'a> FromIterator<MetricRef<'a>> for Procession

fn from_iter<T: IntoIterator<Item = MetricRef<'a>>>(iter: T) -> Self

Creates a value from an iterator.

impl PartialEq for Procession

fn eq(&self, other: &Procession) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for Procession

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Procession