Struct TenantAwarePostgresTaskStore 

pub struct TenantAwarePostgresTaskStore { /* private fields */ }

Tenant-scoped PostgreSQL-backed TaskStore.

Each operation is scoped to the tenant from TenantContext. Tasks are stored with a tenant_id column for database-level isolation, enabling efficient per-tenant queries and deletion.

Implementations

impl TenantAwarePostgresTaskStore

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

Opens a PostgreSQL connection pool and initializes the schema.

Errors

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

pub async fn from_pool( pool: Pool<Postgres>, ) -> Result<TenantAwarePostgresTaskStore, Error>

Creates a store from an existing connection pool.

Errors

Returns an error if the schema migration fails.

Trait Implementations

impl Clone for TenantAwarePostgresTaskStore

fn clone(&self) -> TenantAwarePostgresTaskStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TenantAwarePostgresTaskStore

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

Formats the value using the given formatter.

impl TaskStore for TenantAwarePostgresTaskStore

fn save<'a>( &'a self, task: Task, ) -> Pin<Box<dyn Future<Output = Result<(), A2aError>> + Send + 'a>>

Saves (creates or updates) a task.

fn get<'a>( &'a self, id: &'a TaskId, ) -> Pin<Box<dyn Future<Output = Result<Option<Task>, A2aError>> + Send + 'a>>

Retrieves a task by its ID, returning None if not found.

fn list<'a>( &'a self, params: &'a ListTasksParams, ) -> Pin<Box<dyn Future<Output = Result<TaskListResponse, A2aError>> + Send + 'a>>

Lists tasks matching the given filter parameters.

fn insert_if_absent<'a>( &'a self, task: Task, ) -> Pin<Box<dyn Future<Output = Result<bool, A2aError>> + Send + 'a>>

Atomically inserts a task only if no task with the same ID exists.

fn delete<'a>( &'a self, id: &'a TaskId, ) -> Pin<Box<dyn Future<Output = Result<(), A2aError>> + Send + 'a>>

Deletes a task by its ID.

fn count<'a>( &'a self, ) -> Pin<Box<dyn Future<Output = Result<u64, A2aError>> + Send + 'a>>

Returns the total number of tasks in the store.