Struct CaptureRunCheckpoint 

pub struct CaptureRunCheckpoint {
    pub format_version: u16,
    pub run: CaptureRunId,
    pub authorized: bool,
    pub last_day: u32,
    pub sequences: IngestionCheckpoint,
}

Available on crate features std and ua only.

Loaded under the store’s authorization and run-row locks.

Fields

format_version: u16

run: CaptureRunId

authorized: bool

last_day: u32

sequences: IngestionCheckpoint

Implementations

impl CaptureRunCheckpoint

pub fn new( run: CaptureRunId, authorized: bool, current_day: u32, limits: IngestionBatchLimits, ) -> Result<CaptureRunCheckpoint, ProfileDataError>

impl CaptureRunCheckpoint

pub fn prepare( &self, current_day: u32, attempt: IngestionAttempt, pending: &[PendingBucketObservation<'_>], seed: [u8; 32], limits: IngestionBatchLimits, ) -> Result<PreparedIngestion, ProfileDataError>

Prepare all effects without mutating loaded state. The store atomically commits the returned run checkpoint, buckets and global quota deltas. Its locks must span the read, this call, and commit. IDs are trusted writer identities: bounded checkpoints detect retries, not conflicting retry bodies.

Trait Implementations

impl Clone for CaptureRunCheckpoint

fn clone(&self) -> CaptureRunCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CaptureRunCheckpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CaptureRunCheckpoint

fn deserialize<__D>( __deserializer: __D, ) -> Result<CaptureRunCheckpoint, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CaptureRunCheckpoint

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

where __S: Serializer,

Serialize this value into the given Serde serializer.