pub struct DefaultRequestHandler { /* private fields */ }Expand description
Default implementation of RequestHandler that orchestrates
task lifecycle management, storage, and executor dispatch.
Implementations§
Source§impl DefaultRequestHandler
impl DefaultRequestHandler
pub fn new(executor: impl AgentExecutor, task_store: impl TaskStore) -> Self
pub fn with_push_config_store( self, push_config_store: impl PushConfigStore, ) -> Self
pub fn with_push_notifications( self, push_config_store: impl PushConfigStore, push_sender: HttpPushSender, ) -> Self
pub fn with_capabilities(self, capabilities: AgentCapabilities) -> Self
Trait Implementations§
Source§impl RequestHandler for DefaultRequestHandler
impl RequestHandler for DefaultRequestHandler
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,
Auto Trait Implementations§
impl !RefUnwindSafe for DefaultRequestHandler
impl !UnwindSafe for DefaultRequestHandler
impl Freeze for DefaultRequestHandler
impl Send for DefaultRequestHandler
impl Sync for DefaultRequestHandler
impl Unpin for DefaultRequestHandler
impl UnsafeUnpin for DefaultRequestHandler
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request