Struct A2aServer 

pub struct A2aServer { /* private fields */ }

A2A server that handles incoming task requests.

Implementations

impl A2aServer

pub fn new(config: A2aServerConfig) -> Self

Create a new A2A server.

pub fn agent_card(&self) -> AgentCard

Return the cached agent card, generating it on first call. Use [invalidate_agent_card] to force regeneration.

pub fn invalidate_agent_card(&self)

Invalidate the cached agent card so the next call to [agent_card] regenerates it (e.g. after workflows change on disk).

pub fn handle_request(&self, request: &JsonRpcRequest) -> JsonRpcResponse

Handle an incoming JSON-RPC request.

pub fn update_task_status( &self, task_id: &str, state: TaskState, message: Option<String>, artifacts: Option<Vec<TaskArtifact>>, ) -> Result<()>

Update the status of a task (called by workflow runner).

pub fn list_tasks(&self) -> Vec<TaskResponse>

List all active tasks.