Struct MeshClient 

pub struct MeshClient {
    pub listeners: Arc<Mutex<HashMap<String, Arc<dyn EventListener>>>>,
    pub reconnect_attempts: u32,
    pub user_disconnected: bool,
    /* private fields */
}

Fields

listeners: Arc<Mutex<HashMap<String, Arc<dyn EventListener>>>>

reconnect_attempts: u32

user_disconnected: bool

Implementations

impl MeshClient

pub async fn join(&mut self) -> Result<(), ClientError>

Join the mesh using the invite token.

pub async fn list_models(&self) -> Result<Vec<Model>, ClientError>

List available models on the mesh.

pub fn chat( &self, request: ChatRequest, listener: Arc<dyn EventListener>, ) -> RequestId

Start a chat completion request. Sync — returns a RequestId immediately. Streaming tokens are delivered via listener.on_event() on the runtime thread.

pub fn responses( &self, request: ResponsesRequest, listener: Arc<dyn EventListener>, ) -> RequestId

Start a responses request. Sync — returns a RequestId immediately.

pub fn cancel(&self, request_id: RequestId)

Cancel an in-flight request. No-op if the request_id is unknown. Emits Event::Failed { error: "cancelled" } to the request’s listener when found.

pub async fn status(&self) -> Status

Return the current mesh connection status.

pub async fn disconnect(&mut self)

pub async fn reconnect(&mut self) -> Result<(), ClientError>

pub fn add_event_listener(&self, listener: Arc<dyn EventListener>) -> String

pub fn remove_event_listener(&self, listener_id: &str)

impl MeshClient

pub async fn connect_control_plane( &self, options: ControlPlaneBootstrapOptions, ) -> Result<ControlPlaneConnection, ControlPlaneClientError>

Bootstrap config transport using the explicit owner-control endpoint policy.

Owner-control endpoints are not discovered through gossip or status APIs; callers must provide them explicitly through out-of-band bootstrap.