Struct ActivityTally 

pub struct ActivityTally {
    pub recorded: u64,
    pub retained: u64,
    pub source_high_water: u64,
    pub latest: Option<LatestActivity>,
}

What one run’s activity amounts to, kept so retention cannot erase the fact of its silence or the boundary that makes retries safe.

Fields

recorded: u64

Records ever received for the run. The count wraps at u64::MAX.

retained: u64

Records the feed still holds for it.

source_high_water: u64

The highest source_sequence accepted; zero before any activity. A record at or below it that is no longer retained is expired, never recorded again.

latest: Option<LatestActivity>

The latest record received, even when retention has since removed it.

Trait Implementations

impl Clone for ActivityTally

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActivityTally

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ActivityTally

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ActivityTally

impl PartialEq for ActivityTally

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for ActivityTally

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 ActivityTally