Struct RetryBuffer 

pub struct RetryBuffer { /* private fields */ }

File-based retry buffer for failed enrichment attempts.

Implementations

impl RetryBuffer

pub fn new() -> Self

Create a new retry buffer with the default path.

pub fn buffer_path() -> PathBuf

Get the default buffer directory path.

Uses XDG state directory: ~/.local/state/nexus-memory-system/pending-enrichment/

pub fn write_failed( &self, event: &NormalizedHookEvent, candidates: &[MemoryCandidate], error: &str, ) -> Result<PathBuf>

Write a failed enrichment attempt to the buffer.

Creates a JSON file named {timestamp}_{uuid}.json in the buffer directory. Creates the directory if it doesn’t exist.

Returns the path to the created file.

pub fn list_pending(&self) -> Result<Vec<PathBuf>>

List all pending retry artifacts in the buffer directory.

Returns paths to all .json files in the buffer.

pub fn read_pending(path: &Path) -> Result<RetryArtifact>

Read a pending retry artifact from disk.

pub fn remove_pending(path: &Path) -> Result<()>

Remove a pending retry artifact from disk.

pub fn pending_count(&self) -> Result<usize>

Count the number of pending retry artifacts.

pub fn clear_all(&self) -> Result<usize>

Clear all pending retry artifacts.

Returns the number of artifacts removed.

Trait Implementations

impl Default for RetryBuffer

fn default() -> Self

Returns the “default value” for a type.