Struct SqlitePushConfigStore 

pub struct SqlitePushConfigStore { /* private fields */ }

SQLite-backed PushConfigStore.

Stores push notification configs as JSON blobs in a push_configs table.

Schema

CREATE TABLE IF NOT EXISTS push_configs (
    task_id TEXT NOT NULL,
    id      TEXT NOT NULL,
    data    TEXT NOT NULL,
    PRIMARY KEY (task_id, id)
);

Implementations

impl SqlitePushConfigStore

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

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

Errors

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

pub async fn from_pool( pool: Pool<Sqlite>, ) -> Result<SqlitePushConfigStore, Error>

Creates a store from an existing connection pool.

Errors

Returns an error if the schema migration fails.

Trait Implementations

impl Clone for SqlitePushConfigStore

fn clone(&self) -> SqlitePushConfigStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqlitePushConfigStore

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

Formats the value using the given formatter.

impl PushConfigStore for SqlitePushConfigStore

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.