Struct InMemoryTaskStore 

pub struct InMemoryTaskStore { /* private fields */ }

In-memory TaskStore backed by a RwLock<HashMap>.

When at capacity and a new task id is inserted, the least recently updated task is evicted (LRU). Re-inserting an existing id never evicts. This is the default backend used by A2AServer.

Implementations

impl InMemoryTaskStore

pub fn new() -> Self

Create a store with the default capacity (DEFAULT_MAX_TASKS).

pub fn with_max_tasks(max_tasks: usize) -> Self

Create a store with an explicit capacity cap.

Trait Implementations

impl Clone for InMemoryTaskStore

fn clone(&self) -> InMemoryTaskStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryTaskStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for InMemoryTaskStore

fn default() -> Self

Returns the “default value” for a type.

impl TaskStore for InMemoryTaskStore

fn upsert<'life0, 'async_trait>( &'life0 self, stored: StoredTask, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Insert a new task or replace an existing one.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<StoredTask>, StoreError>> + Send + 'async_trait>>

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

Fetch a task snapshot by id, or None if absent.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 TaskFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<StoredTask>, StoreError>> + Send + 'async_trait>>

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

List task snapshots matching filter, ordered by creation (oldest first).

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool, StoreError>> + Send + 'async_trait>>

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

Delete a task by id. Returns true if a task was actually removed.

fn compare_and_update<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, update: StoredTask, ) -> Pin<Box<dyn Future<Output = Result<bool, StoreError>> + Send + 'async_trait>>

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

Atomically replace the stored task for task_id when the currently stored status may transition to the update’s status (per TaskStatus::can_transition_to). Returns true when the update was applied.