Struct RestTransport 

pub struct RestTransport { /* private fields */ }

REST (HTTP+JSON) transport implementation.

Maps A2A operations to RESTful HTTP endpoints.

Implementations

impl RestTransport

pub fn new(client: Client, base_url: String) -> Self

Build a RestTransport from a pre-constructed reqwest::Client.

Trait Implementations

impl Transport for RestTransport

fn send_message<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, params: &'life1 ServiceParams, req: &'life2 SendMessageRequest, ) -> Pin<Box<dyn Future<Output = Result<SendMessageResponse, A2AError>> + Send + 'async_trait>>

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

fn send_streaming_message<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, params: &'life1 ServiceParams, req: &'life2 SendMessageRequest, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<'static, Result<StreamResponse, A2AError>>, A2AError>> + Send + 'async_trait>>

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

fn get_task<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, params: &'life1 ServiceParams, req: &'life2 GetTaskRequest, ) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>

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

fn list_tasks<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, params: &'life1 ServiceParams, req: &'life2 ListTasksRequest, ) -> Pin<Box<dyn Future<Output = Result<ListTasksResponse, A2AError>> + Send + 'async_trait>>

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

fn cancel_task<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, params: &'life1 ServiceParams, req: &'life2 CancelTaskRequest, ) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>

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

fn subscribe_to_task<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, params: &'life1 ServiceParams, req: &'life2 SubscribeToTaskRequest, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<'static, Result<StreamResponse, A2AError>>, A2AError>> + Send + 'async_trait>>

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

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

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

fn get_push_config<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, params: &'life1 ServiceParams, req: &'life2 GetTaskPushNotificationConfigRequest, ) -> Pin<Box<dyn Future<Output = Result<TaskPushNotificationConfig, A2AError>> + Send + 'async_trait>>

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

fn list_push_configs<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, params: &'life1 ServiceParams, req: &'life2 ListTaskPushNotificationConfigsRequest, ) -> Pin<Box<dyn Future<Output = Result<ListTaskPushNotificationConfigsResponse, A2AError>> + Send + 'async_trait>>

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

fn delete_push_config<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, params: &'life1 ServiceParams, req: &'life2 DeleteTaskPushNotificationConfigRequest, ) -> Pin<Box<dyn Future<Output = Result<(), A2AError>> + Send + 'async_trait>>

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

fn get_extended_agent_card<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, params: &'life1 ServiceParams, _req: &'life2 GetExtendedAgentCardRequest, ) -> Pin<Box<dyn Future<Output = Result<AgentCard, A2AError>> + Send + 'async_trait>>

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

fn destroy<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), A2AError>> + Send + 'async_trait>>

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