Struct TenantAwareSqliteTaskStore 

pub struct TenantAwareSqliteTaskStore { /* private fields */ }

Tenant-scoped SQLite-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.

Example

use a2a_protocol_server::store::TenantAwareSqliteTaskStore;
use a2a_protocol_server::store::tenant::TenantContext;

let store = TenantAwareSqliteTaskStore::new("sqlite::memory:").await?;

TenantContext::scope("acme", async {
    // All operations here are scoped to tenant "acme"
}).await;

Implementations

impl TenantAwareSqliteTaskStore

pub const fn with_max_page_size(self, max: u32) -> Self

Caps the page size list returns, however large a page is asked for.

Defaults to DEFAULT_MAX_PAGE_SIZE, which explains why this store needs its own knob rather than reading TaskStoreConfig.

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.

pub async fn purge_expired( &self, policy: &RetentionPolicy, ) -> A2aResult<PurgeReport>

Deletes terminal tasks that have outlived policy.

Nothing calls this for you. A persistent store keeps every task until an operator says otherwise — see retention for why that is the default and why the in-memory store does the opposite — so this is the hook for whatever already schedules work: a cron entry, a Kubernetes CronJob, a tokio interval in your own binary.

Only Completed, Failed, Canceled and Rejected tasks are eligible. A task still Working, or parked in InputRequired waiting on a human, is never deleted however old it is.

Safe to run from several replicas at once: each batch is a single DELETE whose subquery picks the rows, so two sweeps racing delete disjoint sets rather than colliding.

Errors

Returns an error if a delete fails. A sweep that fails partway has still committed its earlier batches; the counts in the returned report are lost in that case, but the deletions are not undone and the next sweep simply continues.

Trait Implementations

impl Clone for TenantAwareSqliteTaskStore

fn clone(&self) -> TenantAwareSqliteTaskStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TenantAwareSqliteTaskStore

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

Formats the value using the given formatter.

impl TaskStore for TenantAwareSqliteTaskStore

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

Saves (creates or updates) a task.

fn get<'a>( &'a self, id: &'a TaskId, ) -> Pin<Box<dyn Future<Output = A2aResult<Option<Task>>> + 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 = A2aResult<TaskListResponse>> + Send + 'a>>

Lists tasks matching the given filter parameters.

fn insert_if_absent<'a>( &'a self, task: &'a Task, ) -> Pin<Box<dyn Future<Output = A2aResult<bool>> + 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 = A2aResult<()>> + Send + 'a>>

Deletes a task by its ID.

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

Returns the total number of tasks in the store.

fn save_artifact_delta<'a>( &'a self, task: &'a Task, delta: ArtifactDelta, ) -> Pin<Box<dyn Future<Output = A2aResult<()>> + Send + 'a>>

Persists an artifact change that has already been applied to task.