Struct FeedSource 

pub struct FeedSource { /* private fields */ }

Generation-aware wrapper: owns the generation number alongside the backlog. The runtime persists generation via kevy-persist’s feed sidecars; this type only holds the in-memory value.

Implementations

impl FeedSource

pub fn new(generation: u64, source: ReplicationSource) -> Self

Wrap a backlog at an explicit generation (loaded from the feed sidecar at boot, or 1 for a fresh data dir).

pub fn generation(&self) -> u64

Current generation.

pub fn source(&self) -> &ReplicationSource

Access the wrapped backlog (push side + replica streaming keep their existing ReplicationSource API).

pub fn source_mut(&mut self) -> &mut ReplicationSource

Mutable access for push_mutation / drop_up_to.

pub fn bump_generation(&mut self)

Break continuity: bump the generation and restart offsets at 0 (FLUSHALL / restore / unclean-boot policy). The backlog empties — frames from the old generation must never be served under the new one.

pub fn tail(&self) -> (u64, u64)

The tail cursor: (generation, next_offset) — where a consumer resuming after a rebuild starts.

pub fn read( &self, cursor_gen: u64, offset: u64, max: usize, ) -> Result<Vec<FeedFrame<'_>>, FeedRead>

Serve up to max frames at cursor (generation, offset).

• Stale generation → Resync (any pre-bump cursor is unservable — uniqueness of (gen, offset) forbids re-serving).
• Generation from the future → Future (caller confusion).
• Evicted offset → Resync with the current tail.