Struct A2aApi 

pub struct A2aApi { /* private fields */ }

Agent-to-agent communication system calls.

Wraps A2AProtocol for inter-agent task delegation and messaging. Also exposes oxi_sdk::MessageBus for broadcast-based inter-agent communication.

Implementations

impl A2aApi

pub fn new(protocol: Arc<A2AProtocol>) -> Self

Create a new A2aApi with a MessageBus (capacity 256).

pub fn protocol(&self) -> &Arc<A2AProtocol>

A2A protocol reference.

pub fn message_bus(&self) -> &MessageBus

Message bus reference for inter-agent broadcast messaging.

pub fn subscribe(&self) -> Receiver<InterAgentMessage>

Subscribe to messages on the bus.

pub fn get_message_log(&self, limit: Option<usize>) -> Vec<A2AMessageLogEntry>

Returns recent A2A message log entries.

If limit is Some(n), returns at most the last n entries.

pub fn recent_messages(&self, secs: u64) -> Vec<A2AMessageLogEntry>

Returns message-log entries whose timestamp is within the last secs seconds. Used by the topology endpoint to derive edges from a sliding window of recent activity.