Struct DiscoveryService 

pub struct DiscoveryService { /* private fields */ }

Discovery service for finding Mecha10 nodes

Examples

use mecha10_cli::services::{DiscoveryService, DiscoveryConfig};

let service = DiscoveryService::new();

// Configure discovery
let config = DiscoveryConfig::default();

// Discover nodes
let nodes = service.discover(&config).await?;
for node in nodes {
    println!("Found node: {} at {}:{}", node.node_id, node.host, node.port);
}

// Monitor for new nodes
service.monitor(&config, |node| {
    println!("New node discovered: {}", node.node_id);
}).await?;

Implementations

impl DiscoveryService

pub fn new() -> Self

Create a new discovery service

pub async fn discover( &mut self, config: &DiscoveryConfig, ) -> Result<Vec<NodeInfo>>

Discover active nodes on the network

Arguments

• config - Discovery configuration

pub async fn monitor<F>( &mut self, config: &DiscoveryConfig, callback: F, ) -> Result<()>

where F: FnMut(&NodeInfo),

Monitor for new nodes

Arguments

• config - Discovery configuration
• callback - Function to call when a new node is discovered

pub fn get_nodes(&self) -> Vec<&NodeInfo>

Get list of currently known nodes

pub fn get_node(&self, node_id: &str) -> Option<&NodeInfo>

Get a specific node by ID

Arguments

• node_id - Node identifier

pub fn cleanup_stale_nodes(&mut self, timeout: Duration) -> usize

Remove stale nodes that haven’t sent heartbeats

Arguments

• timeout - Maximum time since last heartbeat

pub async fn announce( &self, config: &DiscoveryConfig, node_info: &NodeInfo, ) -> Result<()>

Broadcast presence announcement

Arguments

• config - Discovery configuration
• node_info - Information about this node

pub async fn heartbeat( &self, config: &DiscoveryConfig, node_id: &str, ) -> Result<()>

Send heartbeat for a node

Arguments

• config - Discovery configuration
• node_id - Node identifier

pub fn node_count(&self) -> usize

Get node count

pub fn get_nodes_by_type(&self, node_type: &str) -> Vec<&NodeInfo>

Get nodes by type

Arguments

• node_type - Type of nodes to filter

pub fn clear(&mut self)

Clear all discovered nodes

Trait Implementations

impl Default for DiscoveryService

fn default() -> Self

Returns the “default value” for a type.