Struct ResultStash 

pub struct ResultStash {
    stash_dir: PathBuf,
    config: StashConfig,
    entries: Mutex<HashMap<String, StashEntry>>,
}

Disk-backed result stash.

Fields

stash_dir: PathBuf

config: StashConfig

entries: Mutex<HashMap<String, StashEntry>>

Implementations

impl ResultStash

pub fn new(stash_dir: PathBuf, config: StashConfig) -> Result<Self>

Create a new stash rooted at stash_dir. Creates the directory if missing.

pub fn config(&self) -> &StashConfig

Return the stash configuration.

pub fn insert_bytes( &self, task_id: i32, result_name: String, format: StashFormat, data: Vec<u8>, ) -> Result<String>

Insert an in-memory payload. Writes it to a new temp file in the stash directory and returns the handle.

pub fn insert_file( &self, task_id: i32, result_name: String, format: StashFormat, path: PathBuf, ) -> Result<String>

Insert a reference to an existing file (plugin-owned). The file is not copied or touched, and is never deleted by the stash.

pub fn take(&self, handle: &str) -> Option<StashEntry>

Take the entry for handle, removing it from the map.

The returned entry’s file has not been deleted - the caller (typically on_pull_result) reads it, then calls Self::cleanup_after_pull to delete SDK-owned files.

pub fn peek_size(&self, handle: &str) -> Option<u64>

Return size_bytes for handle without removing the entry.

pub fn cleanup_after_pull(&self, entry: &StashEntry)

Delete the SDK-written temp file for a pulled entry. No-op for plugin-owned files.

pub fn sweep_task(&self, task_id: i32) -> usize

Remove all entries for a finished task. SDK-owned files are deleted; plugin-owned files are left alone. Returns the number of entries reclaimed.

pub fn sweep_expired(&self) -> usize

Remove entries older than self.config.ttl. SDK-owned files deleted; plugin-owned files left alone. Returns the number of entries reclaimed.

fn sweep_where(&self, predicate: impl Fn(&StashEntry) -> bool) -> usize

pub fn sweep_orphans_on_startup(stash_dir: &Path) -> Result<usize>

Sweep any files in stash_dir that are not tracked in entries. Called once on startup to clean up orphans from a previous crashed run. Does not touch files referenced by live entries (which is always empty on startup).