Struct MeshClient 

pub struct MeshClient { /* private fields */ }

Client-side mesh operations

Implementations

impl MeshClient

pub fn new(host: &str, port: u16) -> MeshClient

pub fn generate_instance_id() -> String

Generate a unique instance ID

pub async fn register( &self, instance_id: String, hostname: String, port: u16, capabilities: Vec<String>, agent_profiles: Vec<String>, ) -> Result<RegisterResponse, Error>

Register this instance with a mesh registry

pub async fn heartbeat( &self, instance_id: &str, metrics: Option<HashMap<String, Value>>, ) -> Result<HeartbeatResponse, Error>

Send heartbeat to registry

pub async fn list_instances(&self) -> Result<InstancesResponse, Error>

List all instances in the mesh

pub async fn deregister(&self, instance_id: &str) -> Result<(), Error>

Deregister from the mesh

pub async fn send_message( &self, source_instance: String, target_instance: Option<String>, message_type: MessageType, payload: Value, correlation_id: Option<String>, ) -> Result<SendMessageResponse, Error>

Send a message to another instance

pub async fn get_messages( &self, instance_id: &str, ) -> Result<PendingMessagesResponse, Error>

Get pending messages for an instance

pub async fn acknowledge_messages( &self, instance_id: &str, message_ids: Vec<String>, ) -> Result<(), Error>

Acknowledge delivered messages

Trait Implementations

impl Clone for MeshClient

fn clone(&self) -> MeshClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.