Struct RetainedBucketWindow 

pub struct RetainedBucketWindow { /* private fields */ }

Available on crate features std and ua only.

One authorization/profile/flow/structural scope, with no duplicate day coverage.

Implementations

impl RetainedBucketWindow

pub fn new( domain: CanonicalDomain, scope: ValueId, seed: [u8; 32], limits: ProfileWindowLimits, ) -> Result<RetainedBucketWindow, ProfileDataError>

pub fn observe( &mut self, current_day: u32, observation_day: u32, observation: ObservationId, value: &CanonicalValue, ) -> Result<(), ProfileDataError>

The enclosing transaction must admit this observation ID exactly once. Day and byte-budget checks complete before counts or retention change.

pub fn advance(&mut self, current_day: u32) -> Result<(), ProfileDataError>

Remove expired state even when no new observations arrive. The day comes from the receiver clock via profile_utc_day, never peer metadata.

pub fn select( &self, current_day: u32, horizon: u32, ) -> Result<CountedObservationBucket, ProfileDataError>

The current partial UTC day counts toward the requested horizon. Expired counts and samples cannot influence the result.

pub fn retained_bytes(&self) -> usize

pub fn snapshot(&self) -> RetainedBucketsSnapshot

pub fn from_snapshot( snapshot: &RetainedBucketsSnapshot, expected_domain: CanonicalDomain, expected_scope: ValueId, seed: [u8; 32], limits: ProfileWindowLimits, ) -> Result<RetainedBucketWindow, ProfileDataError>

Trait Implementations

impl Clone for RetainedBucketWindow

fn clone(&self) -> RetainedBucketWindow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetainedBucketWindow

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

Formats the value using the given formatter.