Struct FileIngestionManifest 

pub struct FileIngestionManifest { /* private fields */ }

Tracks ingested files with bounded retention.

Implementations

impl FileIngestionManifest

pub fn new() -> Self

Creates an empty manifest.

pub fn contains(&self, path: &str) -> bool

Returns true if the path has been ingested (exact or probabilistic match).

pub fn size_changed(&self, path: &str, current_size: u64) -> bool

Checks whether a file was previously ingested with a different size.

Returns true if the path is known AND the recorded size differs.

pub fn insert(&mut self, path: String, entry: FileEntry)

Inserts a file entry into the active set.

pub fn active_count(&self) -> usize

Returns the number of active entries.

pub fn active_entries(&self) -> impl Iterator<Item = (&str, &FileEntry)>

Returns an iterator over active entries for introspection.

pub fn snapshot_for_dedup(&self) -> Self

Creates a read-only snapshot for the discovery engine’s dedup checks.

The snapshot contains the same active entries and bloom filter, but will not receive future inserts. This is intentional — the source’s poll_batch does a belt-and-suspenders dedup check anyway.

pub fn maybe_evict(&mut self, max_count: usize, max_age_ms: u64)

Evicts entries that exceed the count cap or age limit.

Evicted entries are added to the Bloom filter for probabilistic dedup.

pub fn to_checkpoint(&self, checkpoint: &mut SourceCheckpoint)

Serializes the manifest into SourceCheckpoint fields.

pub fn from_checkpoint(checkpoint: &SourceCheckpoint) -> Result<Self, Error>

Restores the manifest from a checkpoint.

Errors

Returns an error if deserialization fails.

Trait Implementations

impl Debug for FileIngestionManifest

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

Formats the value using the given formatter.

impl Default for FileIngestionManifest

fn default() -> Self

Returns the “default value” for a type.