Struct TaskManager 

pub struct TaskManager { /* private fields */ }

A2A Task Manager - handles task creation, updates, and queries

Implementations

impl TaskManager

pub fn new() -> Self

Create a new task manager

pub fn with_capacity(max_tasks: usize) -> Self

Create a new task manager with custom capacity

pub async fn create_task(&self, context_id: Option<String>) -> Task

Create a new task

pub async fn get_task(&self, task_id: &str) -> Option<Task>

Get a task by ID

pub async fn get_task_or_error(&self, task_id: &str) -> A2aResult<Task>

Get a task by ID, returning an error if not found

pub async fn update_status( &self, task_id: &str, state: TaskState, message: Option<Message>, ) -> A2aResult<Task>

Update task status

pub async fn add_artifact( &self, task_id: &str, artifact: Artifact, ) -> A2aResult<Task>

Add an artifact to a task

pub async fn add_message( &self, task_id: &str, message: Message, ) -> A2aResult<Task>

Add a message to task history

pub async fn cancel_task(&self, task_id: &str) -> A2aResult<Task>

Cancel a task

pub async fn list_tasks(&self, params: ListTasksParams) -> ListTasksResult

List tasks with optional filtering

pub async fn get_tasks_by_context(&self, context_id: &str) -> Vec<Task>

Get tasks by context ID

pub async fn task_count(&self) -> usize

Get the number of tasks

pub async fn clear(&self)

Clear all tasks (for testing)

pub async fn set_webhook_config( &self, config: TaskPushNotificationConfig, ) -> A2aResult<()>

Set webhook configuration for a task

pub async fn get_webhook_config( &self, task_id: &str, ) -> Option<TaskPushNotificationConfig>

Get webhook configuration for a task

pub async fn remove_webhook_config(&self, task_id: &str)

Remove webhook configuration for a task

Trait Implementations

impl Clone for TaskManager

fn clone(&self) -> TaskManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TaskManager

fn default() -> Self

Returns the “default value” for a type.