Struct LocalMesh 

pub struct LocalMesh { /* private fields */ }

Implementations

impl LocalMesh

pub fn new(name: impl Into<String>) -> LocalMesh

pub fn request_queue(&self) -> Arc<RequestQueue>

Get the request queue (for sharing with agent wrappers)

impl LocalMesh

pub async fn broadcast( &self, message: Message, exclude: Option<&str>, ) -> Result<Vec<Result<(), Error>>, Error>

Broadcast a message to all agents in the mesh

pub async fn submit( &self, target: &str, payload: String, ) -> Result<String, Error>

Submit a request (fire-and-forget). Returns request ID.

pub fn get_pending(&self) -> Vec<MeshRequest>

Get pending requests

pub fn has_pending(&self) -> bool

Check if there are pending requests

pub fn get_results(&self) -> Vec<MeshResult>

Get available results (removes them from queue)

pub fn peek_results(&self) -> Vec<MeshResult>

Peek at results without removing

pub async fn send_reminders( &self, older_than_secs: f64, ) -> Result<Vec<String>, Error>

Send reminders for stale requests

pub async fn wait_for( &self, request_id: &str, timeout_secs: f64, reminder_interval_secs: f64, ) -> Result<MeshResult, Error>

Wait for a specific result with auto-reminders

pub async fn collect_results( &self, reminder_interval_secs: f64, ) -> Vec<MeshResult>

Collect all results, blocking until all pending complete

Trait Implementations

impl Mesh for LocalMesh

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, LocalMesh: 'async_trait,

Start the mesh and all registered agents.

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, LocalMesh: 'async_trait,

Stop the mesh and all agents.

fn add_agent<'life0, 'async_trait>( &'life0 self, agent: Box<dyn Agent>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, LocalMesh: 'async_trait,

Add an agent to the mesh.

fn send<'life0, 'life1, 'async_trait>( &'life0 self, message: Message, target: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, LocalMesh: 'async_trait,

Send a message to a specific agent by name.