Struct TaskBroker 

pub struct TaskBroker { /* private fields */ }

Implementations

impl TaskBroker

pub fn new(msg_tx: Sender<Msg>) -> Self

pub fn seed(&self, store: TaskStore)

Overwrite the store wholesale: startup resume seeding, rewind/fork and /clear (empty store). No publish — the reducer already holds this truth; it is telling us, not the other way around.

pub fn add_tokens(&self, completion_tokens: u64)

Accumulate a completed request’s completion tokens into the session-monotonic counter. Called by the effect runner on every provider usage report; task cost deltas read this counter at the in_progress and completed edges.

pub async fn create( &self, specs: Vec<TaskSpec>, origin: TaskOrigin, ) -> (Vec<TaskItem>, TaskStore)

Append new tasks; returns the created items and publishes.

pub async fn update(&self, edits: Vec<TaskEdit>) -> (ApplyReport, TaskStore)

Apply differential edits; returns the per-item report (with advisory notes) and publishes.

pub async fn user_edit(&self, edit: UserTaskEdit) -> (String, TaskStore)

Apply a /tasks user edit. Returns the outcome line shown in the transcript and the id it affected (for the model notice).

pub async fn record_evidence(&self, entry: EvidenceEntry)

Attach evidence to the current in-progress task, if any. Publishes only when something was recorded.

pub fn snapshot(&self) -> TaskStore

Trait Implementations

impl Clone for TaskBroker

fn clone(&self) -> TaskBroker

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.