Struct TaskContextBuilder 

pub struct TaskContextBuilder { /* private fields */ }

Fluent builder for TaskContext.

let (handle, ctx) = TaskContextBuilder::new()
    .thread_pool(Arc::new(RayonThreadPool::with_default_threads()?))
    .database(db)
    .graph_db(graph)
    .vector_db(vectors)
    .progress(ProgressToken::new())
    .build()?;

Implementations

impl TaskContextBuilder

pub fn new() -> TaskContextBuilder

pub fn thread_pool(self, pool: Arc<dyn CpuPool>) -> TaskContextBuilder

pub fn database(self, db: Arc<DatabaseConnection>) -> TaskContextBuilder

pub fn graph_db(self, graph: Arc<dyn GraphDBTrait>) -> TaskContextBuilder

pub fn vector_db(self, vectors: Arc<dyn VectorDB>) -> TaskContextBuilder

pub fn progress(self, token: ProgressToken) -> TaskContextBuilder

Set a pre-built progress token. Defaults to a fresh root token.

pub fn pipeline_context(self, ctx: PipelineContext) -> TaskContextBuilder

Set pipeline run identity context.

pub fn exec_status(self, mgr: Arc<dyn ExecStatusManager>) -> TaskContextBuilder

Set the per-item status manager for incremental deduplication. Defaults to NoopExecStatusManager if not set.

pub fn pipeline_watcher(self, w: Arc<dyn PipelineWatcher>) -> TaskContextBuilder

Inject a pipeline watcher into the context.

When set, the registry’s ScopedRunWatcher is stored here so that library functions can publish lifecycle events without needing to know about the registry. Defaults to None (no watcher).

pub fn build(self) -> Result<(CancellationHandle, TaskContext), CoreError>

Build the context. Returns (CancellationHandle, TaskContext) so the caller keeps the handle while the task receives the token.

Trait Implementations

impl Default for TaskContextBuilder

fn default() -> TaskContextBuilder

Returns the “default value” for a type.