Struct A2AServer 

pub struct A2AServer {
    pub agent_card: AgentCard,
    pub registry: AgentCardRegistry,
    pub profile_store: ProfileStore,
    /* private fields */
}

A2A server for handling incoming JSON-RPC requests.

This is a protocol server (request router + in-memory task store), not a network server. A shell crate is responsible for exposing it over HTTP/SSE.

Fields

agent_card: AgentCard

This agent’s card.

registry: AgentCardRegistry

Registry of known agents.

profile_store: ProfileStore

Profile store for bearer token authentication.

Implementations

impl A2AServer

pub fn new(agent_card: AgentCard) -> Self

Create a new A2A server for the given agent card.

pub fn handle_request(&self, request: A2ARequest) -> A2AResponse

Handle an incoming JSON-RPC request.

pub fn handle_request_with_auth( &self, request: A2ARequest, auth_token: Option<&str>, ) -> A2AResponse

Handle an incoming JSON-RPC request with an optional bearer token.

pub fn get_task_caller(&self, task_id: &str) -> Option<AgentProfile>

Get the caller profile for a task (if known).

pub fn subscribe_events(&self) -> Receiver<A2ATaskEvent>

Subscribe to task lifecycle events for streaming adapters.

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

List currently known tasks.

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

Get a specific task snapshot.

pub fn update_task_status( &self, task_id: &str, status: TaskStatus, ) -> Result<(), String>

Update task status (for internal use).

pub fn update_task_status_with_reason( &self, task_id: &str, status: TaskStatus, reason: impl Into<String>, ) -> Result<(), String>

Update task status and message for internal execution bridges.

pub fn update_task_progress( &self, task_id: &str, progress: RemoteTaskProgress, ) -> Result<(), String>

Report in-flight task progress for internal execution bridges.

pub fn add_message( &self, task_id: &str, message: A2AMessage, ) -> Result<(), String>

Append a message to a task for final result delivery.

pub fn add_artifact( &self, task_id: &str, artifact: Artifact, ) -> Result<(), String>

Add an artifact to a task (for internal use).