Struct InMemoryCoverage 

pub struct InMemoryCoverage { /* private fields */ }

A pod-local, in-memory coverage store. Real deployments back this with a durable store colocated with raw (ADR-0053); this is the local write-behind tier and the test/reference implementation. Union-merge semantics are the same regardless of backing.

Implementations

impl InMemoryCoverage

pub fn new() -> Self

A fresh, empty store.

Trait Implementations

impl CoverageStore for InMemoryCoverage

fn record<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sink: &'life1 SinkId, span: &'life2 OffsetSpan, ) -> Pin<Box<dyn Future<Output = Result<(), CoverageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Record that span was durably written by sink. Merges by union with existing coverage; overlapping/adjacent ranges coalesce. Idempotent.

fn covered<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sink: &'life1 SinkId, topic: &'life2 str, partition: i32, ) -> Pin<Box<dyn Future<Output = Result<Vec<CoveredRange>, CoverageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

The union-merged covered ranges for (sink, topic, partition), ordered by start.

fn gaps<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sink: &'life1 SinkId, topic: &'life2 str, partition: i32, up_to: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<CoveredRange>, CoverageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

The gaps in [0, up_to) not yet covered for (sink, topic, partition) — the windows recovery must replay.

impl Debug for InMemoryCoverage

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

Formats the value using the given formatter.

impl Default for InMemoryCoverage

fn default() -> InMemoryCoverage

Returns the “default value” for a type.