Skip to main content

spawn_worker_with_spool

Function spawn_worker_with_spool 

Source
pub fn spawn_worker_with_spool(
    capacity: usize,
    bridge: Arc<dyn EventBus>,
    embedder: Arc<dyn Embedder>,
    vector_sink: Arc<dyn VectorSink>,
    spool_dir: Option<PathBuf>,
    metrics: Arc<Registry>,
) -> WorkerHandle
Expand description

Start the worker pool with vector persistence and optional ATIF journal.