Struct PostgresPushConfigStore 

pub struct PostgresPushConfigStore { /* private fields */ }

PostgreSQL-backed PushConfigStore.

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

Schema

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

Implementations

impl PostgresPushConfigStore

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

Opens a PostgreSQL connection pool 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<Postgres>, ) -> Result<PostgresPushConfigStore, Error>

Creates a store from an existing connection pool.

Errors

Returns an error if the schema migration fails.

Trait Implementations

impl Clone for PostgresPushConfigStore

fn clone(&self) -> PostgresPushConfigStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresPushConfigStore

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

Formats the value using the given formatter.

impl PushConfigStore for PostgresPushConfigStore

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.