Struct MeshClient 

pub struct MeshClient { /* private fields */ }

Implementations

impl MeshClient

pub async fn new(cfg: MeshClientConfig) -> Result<Self, Error>

pub async fn register(&self, card: &AgentCard) -> Result<(), Error>

pub async fn request( &self, opts: RequestOptions, ) -> Result<MatchOrReject, Error>

Publish a capability request on the control plane and await a reply. Returns the raw JSON reply as serde_json::Value for now.

pub async fn listen( &self, handler: MatchHandler, ) -> Result<ListenSubscription, Error>

Listen for matches directed to this agent DID. Handler will be invoked for each incoming match/reject.

pub async fn start_heartbeat( &self, interval_ms: u64, ) -> Result<HeartbeatHandle, Error>

Start periodic heartbeats to the control plane.

pub async fn close(self) -> Result<(), Error>