Struct AgentContext 

pub struct AgentContext {
    pub mesh_name: String,
    /* private fields */
}

Fields

mesh_name: String

The name of the mesh this agent is running in.

Implementations

impl AgentContext

pub fn new(mesh_name: String, request_queue: Option<Arc<RequestQueue>>) -> Self

Create a new agent context.

Arguments

• mesh_name - Name of the mesh
• request_queue - Optional request queue for request/response pattern

pub fn report_result(&self, request_id: &str, response: String)

Report a result for a pending request.

Call this to send a response back to the requester when handling a message with a correlation ID.

pub fn has_request_queue(&self) -> bool

Check if this context has a request queue available.

pub fn listen(&mut self, callback: impl Fn(&AgentEvent) + Send + Sync + 'static)

Register an event listener.

pub fn emit(&self, event: AgentEvent)

Emit an event to all listeners.