Skip to main content

Module ingestion

Module ingestion 

Available on crate features std and ua only.
Expand description

Bounded ingestion checkpoints for transaction retries and out-of-order delivery.

Structs§

IngestionCheckpoint
Completed sequences above the contiguous prefix, sorted and nonadjacent.
IngestionCursor
The containing transaction also commits counts and reservoirs under its run-row lock. The checkpoint alone is not evidence that those effects were committed.
IngestionLimits
ObservationId
A writer assigns sequences only after reserving capacity in its bounded queue. Retries keep the same run and sequence; a new run never reuses its identifier.
RetentionWindow
Queries include the current partial UTC day and complete preceding buckets.
SequenceRange

Enums§

IngestionDisposition