Struct A2aTaskStore 

pub struct A2aTaskStore { /* private fields */ }

Task store over a CAS-style KV.

Implementations

impl A2aTaskStore

pub fn new(kv: Arc<dyn KvStore>, bucket: String) -> Self

Build a new store backed by kv writing under bucket (typical: DEFAULT_BUCKET).

pub fn with_event_sink(self, sink: TaskEventSink) -> Self

Wire a TaskEventSink so state transitions surface on the configured pubsub. Returns Self for builder-style chaining.

pub async fn put(&self, task: &Task) -> Result<(), A2aError>

Persist a task and update its context index.

pub async fn get(&self, id: &str) -> Result<Option<Task>, A2aError>

Fetch a task by id.

pub async fn list( &self, context_id: Option<&str>, ) -> Result<Vec<Task>, A2aError>

List tasks. context_id = Some(ctx) reads the index; None is not supported in v0.0.1 and returns an empty vec — callers must supply a context.

pub async fn delete(&self, id: &str) -> Result<(), A2aError>

Delete a task and remove its id from the context index.