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.

Currently only SQLite URLs are supported (e.g. sqlite::memory:, sqlite:data.db). Passing a PostgreSQL or MySQL URL will return an error.

pub async fn with_push_sender( database_url: &str, push_sender: impl PushNotificationSender + 'static, ) -> Result<Self, A2AError>

Create a new SQLx task storage with a custom push notification sender.

Currently only SQLite URLs are supported.

pub async fn with_migrations( database_url: &str, additional_migrations: &[&str], ) -> Result<Self, A2AError>

Create a new SQLx task storage with additional migrations.

Currently only SQLite URLs are supported.

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.

Trait Implementations

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 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.