Skip to main content

RequestHandler

a2a_server::handler

Trait RequestHandler 

Source 
pub trait RequestHandler:
    Send
    + Sync
    + 'static {
    // Required methods
    fn send_message<'life0, 'life1, 'async_trait>(
        &'life0 self,
        params: &'life1 ServiceParams,
        req: SendMessageRequest,
    ) -> Pin<Box<dyn Future<Output = Result<SendMessageResponse, A2AError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn send_streaming_message<'life0, 'life1, 'async_trait>(
        &'life0 self,
        params: &'life1 ServiceParams,
        req: 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;
    fn get_task<'life0, 'life1, 'async_trait>(
        &'life0 self,
        params: &'life1 ServiceParams,
        req: GetTaskRequest,
    ) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn list_tasks<'life0, 'life1, 'async_trait>(
        &'life0 self,
        params: &'life1 ServiceParams,
        req: ListTasksRequest,
    ) -> Pin<Box<dyn Future<Output = Result<ListTasksResponse, A2AError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn cancel_task<'life0, 'life1, 'async_trait>(
        &'life0 self,
        params: &'life1 ServiceParams,
        req: CancelTaskRequest,
    ) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn subscribe_to_task<'life0, 'life1, 'async_trait>(
        &'life0 self,
        params: &'life1 ServiceParams,
        req: 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;
    fn create_push_config<'life0, 'life1, 'async_trait>(
        &'life0 self,
        params: &'life1 ServiceParams,
        req: TaskPushNotificationConfig,
    ) -> Pin<Box<dyn Future<Output = Result<TaskPushNotificationConfig, A2AError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn get_push_config<'life0, 'life1, 'async_trait>(
        &'life0 self,
        params: &'life1 ServiceParams,
        req: GetTaskPushNotificationConfigRequest,
    ) -> Pin<Box<dyn Future<Output = Result<TaskPushNotificationConfig, A2AError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn list_push_configs<'life0, 'life1, 'async_trait>(
        &'life0 self,
        params: &'life1 ServiceParams,
        req: ListTaskPushNotificationConfigsRequest,
    ) -> Pin<Box<dyn Future<Output = Result<ListTaskPushNotificationConfigsResponse, A2AError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn delete_push_config<'life0, 'life1, 'async_trait>(
        &'life0 self,
        params: &'life1 ServiceParams,
        req: DeleteTaskPushNotificationConfigRequest,
    ) -> Pin<Box<dyn Future<Output = Result<(), A2AError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn get_extended_agent_card<'life0, 'life1, 'async_trait>(
        &'life0 self,
        params: &'life1 ServiceParams,
        req: GetExtendedAgentCardRequest,
    ) -> Pin<Box<dyn Future<Output = Result<AgentCard, A2AError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}
Expand description

Transport-agnostic request handler interface.

This is the core interface consumed by all protocol bindings (JSON-RPC, REST, gRPC). The DefaultRequestHandler provides a standard implementation that orchestrates task lifecycle, storage, and executor dispatch.

Required Methods§

Source

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

Source

fn send_streaming_message<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 ServiceParams, req: 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,

Source

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

Source

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

Source

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

Source

fn subscribe_to_task<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 ServiceParams, req: 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,

Source

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

Source

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

Source

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

Source

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

Source

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

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§