Struct IngestionCursor 

pub struct IngestionCursor { /* private fields */ }

Available on crate features std and ua only.

The containing transaction also commits counts and reservoirs under its run-row lock. The checkpoint alone is not evidence that those effects were committed.

Implementations

impl IngestionCursor

pub fn new(limits: IngestionLimits) -> IngestionCursor

pub fn from_checkpoint( checkpoint: &IngestionCheckpoint, limits: IngestionLimits, ) -> Result<IngestionCursor, ProfileDataError>

pub fn checkpoint(&self) -> IngestionCheckpoint

pub fn record( &mut self, sequence: u64, ) -> Result<IngestionDisposition, ProfileDataError>

Record a sequence in the transaction’s private cursor. Failed admission changes nothing. A gap is never treated as completed merely because a larger sequence arrived first.

Trait Implementations

impl Clone for IngestionCursor

fn clone(&self) -> IngestionCursor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IngestionCursor

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

Formats the value using the given formatter.