Struct InMemoryPushConfigStore 

pub struct InMemoryPushConfigStore { /* private fields */ }

In-memory PushConfigStore backed by a HashMap.

Uses a secondary index (task_counts) to track the number of configs per task, avoiding an O(n) scan of all keys when enforcing per-task limits.

Implementations

impl InMemoryPushConfigStore

pub fn new() -> Self

Creates a new empty in-memory push config store with default limits.

pub fn with_max_configs_per_task(max: usize) -> Self

Creates a new push config store with a custom per-task config limit.

pub const fn with_max_total_configs(self, max: usize) -> Self

Sets the global maximum number of push configs across all tasks.

Prevents unbounded memory growth when many tasks register configs. Default: 100,000.

Trait Implementations

impl Debug for InMemoryPushConfigStore

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

Formats the value using the given formatter.

impl Default for InMemoryPushConfigStore

fn default() -> Self

Returns the “default value” for a type.

impl PushConfigStore for InMemoryPushConfigStore

fn set<'a>( &'a self, config: TaskPushNotificationConfig, ) -> Pin<Box<dyn Future<Output = A2aResult<TaskPushNotificationConfig>> + Send + 'a>>

Stores (creates or updates) a push notification config.

fn get<'a>( &'a self, task_id: &'a str, id: &'a str, ) -> Pin<Box<dyn Future<Output = A2aResult<Option<TaskPushNotificationConfig>>> + Send + 'a>>

Retrieves a push notification config by task ID and config ID.

fn list<'a>( &'a self, task_id: &'a str, ) -> Pin<Box<dyn Future<Output = A2aResult<Vec<TaskPushNotificationConfig>>> + Send + 'a>>

Lists all push notification configs for a task.

fn delete<'a>( &'a self, task_id: &'a str, id: &'a str, ) -> Pin<Box<dyn Future<Output = A2aResult<()>> + Send + 'a>>

Deletes a push notification config by task ID and config ID.