Struct InMemoryTaskStore 

pub struct InMemoryTaskStore { /* private fields */ }

In-process task store with TTL expiry and LRU capacity eviction.

Implementations

impl InMemoryTaskStore

pub fn new() -> Self

Create a store with default configuration.

pub fn with_config(config: InMemoryTaskStoreConfig) -> Self

Create a store with explicit TTL and capacity settings.

Trait Implementations

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 get<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Task>, A2AError>> + Send + 'async_trait>>

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

Fetch a task by its identifier.

fn put<'life0, 'life1, 'async_trait>( &'life0 self, task: &'life1 Task, ) -> Pin<Box<dyn Future<Output = Result<(), A2AError>> + Send + 'async_trait>>

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

Insert or replace a task snapshot.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, req: &'life1 ListTasksRequest, ) -> Pin<Box<dyn Future<Output = Result<ListTasksResponse, A2AError>> + Send + 'async_trait>>

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

Implementations should reject invalid pagination inputs or delegate to ListTasksRequest::validate() before applying query semantics.

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

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

Delete a task by identifier.