Struct TenantAwareInMemoryPushConfigStore 

pub struct TenantAwareInMemoryPushConfigStore { /* private fields */ }

Tenant-isolated in-memory PushConfigStore.

Maintains a separate InMemoryPushConfigStore per tenant for full data isolation. The current tenant is determined from TenantContext.

Example

use a2a_protocol_server::push::tenant_config_store::TenantAwareInMemoryPushConfigStore;
use a2a_protocol_server::push::PushConfigStore;
use a2a_protocol_server::store::tenant::TenantContext;

let store = TenantAwareInMemoryPushConfigStore::new();

// Scoped to tenant A
TenantContext::scope("tenant-a", async {
    // store.set(config).await;
}).await;

Implementations

impl TenantAwareInMemoryPushConfigStore

pub fn new() -> TenantAwareInMemoryPushConfigStore

Creates a new tenant-aware push config store with default limits.

pub fn with_limits( max_tenants: usize, max_configs_per_task: usize, ) -> TenantAwareInMemoryPushConfigStore

Creates with custom limits.

pub async fn tenant_count(&self) -> usize

Returns the number of active tenant partitions.

Trait Implementations

impl Debug for TenantAwareInMemoryPushConfigStore

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

Formats the value using the given formatter.

impl Default for TenantAwareInMemoryPushConfigStore

fn default() -> TenantAwareInMemoryPushConfigStore

Returns the “default value” for a type.

impl PushConfigStore for TenantAwareInMemoryPushConfigStore

fn set<'a>( &'a self, config: TaskPushNotificationConfig, ) -> Pin<Box<dyn Future<Output = Result<TaskPushNotificationConfig, A2aError>> + 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 = Result<Option<TaskPushNotificationConfig>, A2aError>> + 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 = Result<Vec<TaskPushNotificationConfig>, A2aError>> + 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 = Result<(), A2aError>> + Send + 'a>>

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