Struct UsageReads 

pub struct UsageReads { /* private fields */ }

See the module docs. process_table is the one production instance.

Implementations

impl UsageReads

pub fn held_at( &self, key: &str, now_ms: u64, ) -> Option<(TransientReadFailure, u64)>

The active hold for key: its failure and when it ends.

pub fn record_at( &self, key: &str, fetched: Fetched, now_ms: u64, ) -> Result<(UsageSnapshot, SeatIdentity), ReadError>

Record one network read for key at now_ms and classify it.

pub fn last_good_for( &self, key: &str, current: &SeatIdentity, ) -> Option<UsageSnapshot>

The slot’s last successful snapshot, if it was read from the account now stored in the slot (current): never another account’s reading.

pub fn forget_last_good(&self, key: &str)

Drop the slot’s last good reading (e.g. after a reported limit).

pub fn forget(&self, key: &str)

Drop the slot’s hold and last good reading (synaps auth state --clear): the next read goes to the network. The gate stays, so a read in flight keeps its single flight; if one is in flight, its result is still recorded when it lands.

pub async fn read<F, Fut>( &self, key: &str, fetch: F, ) -> (Result<(UsageSnapshot, SeatIdentity), ReadError>, ReadPath)

where F: FnOnce() -> Fut, Fut: Future<Output = Fetched>,

Read key: a held failure is returned without a request; otherwise one flight per key, and a reader that waited for a flight takes its result.

Trait Implementations

impl Default for UsageReads

fn default() -> UsageReads

Returns the “default value” for a type.