Struct Register 

pub struct Register {
    pub name: &'static str,
    pub shard_entries: usize,
    pub max_age_seconds: i64,
}

The bounds of one register.

Fields

name: &'static str

Directory name under the archive store.

shard_entries: usize

Keys per shard; the oldest record is evicted first.

max_age_seconds: i64

A record older than this is neither returned nor kept.

Implementations

impl Register

pub fn update_many<V: Serialize + DeserializeOwned>( &self, now: i64, items: Vec<(String, V)>, merge: impl Fn(&str, V, V) -> V, ) -> bool

Record many values at once under one lock, one write per touched shard: merge(key, current, new) gives the value kept under a key that already holds one. Keys that are malformed are skipped. false: the lock was not obtained or a shard could not be written (its keys are then not recorded; unknown is the safe state).

pub fn read_all<V: DeserializeOwned>(&self, now: i64) -> Vec<(String, i64, V)>

Every fresh record of every shard with the time it was recorded, for a holder that keeps the register in memory and loads it once. A shard that is oversized, foreign or undecodable contributes nothing.

Trait Implementations

impl Clone for Register

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Register

impl Debug for Register

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

Formats the value using the given formatter.