Struct TenantAwareSqlitePushConfigStore 

pub struct TenantAwareSqlitePushConfigStore { /* private fields */ }

Tenant-scoped SQLite-backed PushConfigStore.

Each operation is scoped to the tenant from TenantContext.

Schema

CREATE TABLE IF NOT EXISTS tenant_push_configs (
    tenant_id TEXT NOT NULL DEFAULT '',
    task_id   TEXT NOT NULL,
    id        TEXT NOT NULL,
    data      TEXT NOT NULL,
    PRIMARY KEY (tenant_id, task_id, id)
);

Implementations

impl TenantAwareSqlitePushConfigStore

pub async fn new(url: &str) -> Result<Self, Error>

Opens (or creates) a SQLite database and initializes the schema.

Errors

Returns an error if the database cannot be opened or migration fails.

pub async fn from_pool(pool: SqlitePool) -> Result<Self, Error>

Creates a store from an existing connection pool.

Errors

Returns an error if the schema migration fails.

Trait Implementations

impl Clone for TenantAwareSqlitePushConfigStore

fn clone(&self) -> TenantAwareSqlitePushConfigStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TenantAwareSqlitePushConfigStore

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

Formats the value using the given formatter.

impl PushConfigStore for TenantAwareSqlitePushConfigStore

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.