Struct AnnounceCache 

pub struct AnnounceCache { /* private fields */ }

Announce cache backed by filesystem.

Implementations

impl AnnounceCache

pub fn new(base_path: PathBuf) -> Self

Create an announce cache at the given directory. The directory must already exist (created by ensure_storage_dirs).

pub fn store( &self, packet_hash: &[u8; 32], raw: &[u8], interface_name: Option<&str>, ) -> Result<()>

Store a cached announce to disk.

packet_hash: 32-byte packet hash (used as filename) raw: raw announce bytes (pre-hop-increment) interface_name: optional interface name string

pub fn get( &self, packet_hash: &[u8; 32], ) -> Result<Option<(Vec<u8>, Option<String>)>>

Retrieve a cached announce from disk.

Returns (raw_bytes, interface_name_or_none).

pub fn entries(&self) -> Result<ReadDir>

Open a directory iterator for incremental cleanup.

pub fn clean( &self, active_hashes: &[[u8; 32]], batch_limit: usize, ) -> Result<(usize, bool)>

Remove cached announces whose packet hashes are not in the active set.

active_hashes: set of packet hashes that should be kept. batch_limit: maximum number of files to process per call (0 = unlimited). Returns (removed_count, finished) where finished is true if all files were processed (no more work to do).

pub fn clean_batch( &self, active_hashes: &[[u8; 32]], entries: &mut ReadDir, batch_limit: usize, ) -> Result<(usize, bool)>

Incrementally remove stale cached announces from an existing directory iterator.

entries keeps iteration state across calls, allowing batched cleanup to make forward progress through large directories.