Struct GraphExtractionUnit 

pub struct GraphExtractionUnit { /* private fields */ }

Extraction against the daemon’s own store, with a provider built from config. Runs exactly what recall-echo graph extract runs.

Implementations

impl GraphExtractionUnit

pub fn new( graph: Arc<GraphMemory>, llm: Box<dyn LlmProvider>, conversations_dir: PathBuf, quarantine_path: PathBuf, ) -> Self

Trait Implementations

impl ExtractionUnit for GraphExtractionUnit

fn pending<'life0, 'async_trait>( &'life0 self, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<u32>, GraphError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Log numbers still awaiting extraction, at most limit of them.

fn extract<'life0, 'async_trait>( &'life0 self, log_number: u32, ) -> Pin<Box<dyn Future<Output = Result<UnitReport, GraphError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Extract one archive and mark it extracted. Marking is the last thing it does, so a failure or an interruption leaves the archive pending.

fn quarantine<'life0, 'life1, 'async_trait>( &'life0 self, log_number: u32, _reason: &'life1 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Stop offering this archive: it has failed [MAX_UNIT_ATTEMPTS] times.