Struct SqlxTaskStorage 

pub struct SqlxTaskStorage { /* private fields */ }

SQLx-based task storage for persistent storage.

Persistence-only: streaming fan-out lives in InMemoryStreamingHandler and push-webhook delivery behind the AsyncPushNotifier port (handed out via push_notifier). The store still owns push-config CRUD (AsyncNotificationManager) — that is config persistence.

Implementations

impl SqlxTaskStorage

pub async fn new(database_url: &str) -> Result<Self, A2AError>

Create a new SQLx task storage with the given database URL.

The scheme picks the backend: sqlite::memory:, sqlite:data.db, or postgres://user:pass@host/db. Each needs its cargo feature (sqlite, postgres) compiled in, and the error says so when it is missing.

Pool sizing, statement logging, a custom push sender and agent-specific migrations go through builder.

pub fn builder(database_url: impl Into<String>) -> SqlxStorageBuilder

Configure a store before opening it.

let storage = SqlxTaskStorage::builder("postgres://user:pass@localhost/a2a")
    .max_connections(20)
    .log_statements(true)
    .connect()
    .await?;

pub fn push_notifier(&self) -> Arc<dyn AsyncPushNotifier>

Hand out this store’s push-notification registry as an AsyncPushNotifier.

The returned notifier shares the same config registry the store writes to via AsyncNotificationManager::set_config, so a config registered on the store is immediately visible to the notifier at the composition edge.

pub fn max_connections(&self) -> u32

The connection cap the pool was opened with — what SqlxStorageBuilder::max_connections asked for, read back off the pool. On PostgreSQL this is the store’s share of a server-wide limit.

Trait Implementations

impl AsyncContextStateStore for SqlxTaskStorage

fn load_state<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, context_id: &'life1 ContextId, caller: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<ContextState, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Everything visible from this context: its own keys, plus the caller’s user: keys.

fn remember<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, context_id: &'life1 ContextId, caller: Option<&'life2 str>, key: &'life3 StateKey, value: &'life4 str, ) -> Pin<Box<dyn Future<Output = Result<Remembered, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Record value under key, reporting what the key held before.

fn forget<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, context_id: &'life1 ContextId, caller: Option<&'life2 str>, key: &'life3 StateKey, ) -> Pin<Box<dyn Future<Output = Result<bool, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Drop key, reporting whether it held anything.

impl AsyncConversationStore for SqlxTaskStorage

fn load<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, context_id: &'life1 ContextId, caller: Option<&'life2 str>, limit: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<Conversation, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Load the newest digest and the messages recorded after its watermark.

fn compact<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, context_id: &'life1 ContextId, caller: Option<&'life2 str>, digest: Digest, ) -> Pin<Box<dyn Future<Output = Result<(), A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Append a digest covering everything through Digest::covers_through, claiming the context for caller if it is new.

impl AsyncEventLog for SqlxTaskStorage

fn append<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, event: UpdateEvent, ) -> Pin<Box<dyn Future<Output = Result<SeqEvent, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Record event as the next event on task_id’s stream and return it with the id it was given.

fn replay<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, from: u64, ) -> Pin<Box<dyn Future<Output = Result<Replay, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

What this log can still replay to a client whose last id was from.

fn discard<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Forget a task’s events.

impl AsyncNotificationManager for SqlxTaskStorage

fn get_config<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 GetTaskPushNotificationConfigParams, ) -> Pin<Box<dyn Future<Output = Result<TaskPushNotificationConfig, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get a push-notification config for a task.

fn list_configs<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 ListTaskPushNotificationConfigsParams, ) -> Pin<Box<dyn Future<Output = Result<Vec<TaskPushNotificationConfig>, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List all push-notification configs for a task.

fn delete_config<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 DeleteTaskPushNotificationConfigParams, ) -> Pin<Box<dyn Future<Output = Result<(), A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete a push-notification config. Idempotent per the v1.0.0 spec.

fn set_config<'life0, 'life1, 'async_trait>( &'life0 self, config: &'life1 TaskPushNotificationConfig, ) -> Pin<Box<dyn Future<Output = Result<TaskPushNotificationConfig, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Create or replace a push-notification config, returning it with any server-assigned ID populated.

impl AsyncRetention for SqlxTaskStorage

fn sweep<'life0, 'life1, 'async_trait>( &'life0 self, policy: &'life1 RetentionPolicy, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Swept, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete everything policy marks stale as of now.

impl AsyncTaskLifecycle for SqlxTaskStorage

fn create<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 TaskId, context_id: &'life2 ContextId, ) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Create a new task in the given context.

fn update_status<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, state: TaskState, message: Option<Message>, ) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update task status, optionally appending a message to history.

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<bool, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check whether a task exists.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, history_length: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get a task by ID with optional history length limit.

fn cancel<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Cancel a task.

impl AsyncTaskQuery for SqlxTaskStorage

fn list<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 ListTasksParams, ) -> Pin<Box<dyn Future<Output = Result<ListTasksResult, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List tasks with filtering and pagination (A2A v1.0.0 tasks/list).

impl AsyncTaskVersioning for SqlxTaskStorage

fn version<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<u64, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Current stored version of a task. Bumped on every successful mutation.

fn get_versioned<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, history_length: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<VersionedTask, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetch a task together with its current version (history-limited as in AsyncTaskLifecycle::get).

fn update_status_checked<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, expected: u64, state: TaskState, message: Option<Message>, ) -> Pin<Box<dyn Future<Output = Result<VersionedTask, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update status only if the stored version equals expected.

impl Clone for SqlxTaskStorage

Available on crate feature sqlx-storage only.

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.