Struct CustomDiscoveryService 

pub struct CustomDiscoveryService { /* private fields */ }

Implementação personalizada do Discovery service

Implementations

impl CustomDiscoveryService

pub async fn new( config: AdvancedDiscoveryConfig, client_config: ClientConfig, ) -> Result<Self>

Cria nova instância do CustomDiscoveryService

pub async fn discover_with_methods( &mut self, node_id: NodeId, methods: Vec<DiscoveryMethod>, ) -> Result<Vec<NodeAddr>>

Executa discovery usando múltiplos métodos

pub async fn get_discovery_cache_stats(&self) -> DiscoveryCacheStats

Obtém estatísticas detalhadas do cache LRU discovery

impl CustomDiscoveryService

pub async fn custom_discover( &mut self, node_id: &NodeId, ) -> Result<Vec<NodeAddr>, Box<dyn Error + Send + Sync>>

Método personalizado para discovery integrado com DHT

pub async fn query_iroh_endpoint_for_peer( &mut self, node_id: NodeId, ) -> Result<Vec<NodeAddr>, Box<dyn Error + Send + Sync>>

Consulta DHT usando endpoint do Iroh

pub async fn integrate_with_active_discoveries( &mut self, active_discoveries: &Arc<RwLock<HashMap<NodeId, DiscoverySession>>>, ) -> Result<(), Box<dyn Error + Send + Sync>>

Integra descoberta DHT com sistema de sessões ativas

pub async fn auto_publish_on_discovery( &self, node_data: &NodeData, config: &ClientConfig, ) -> Result<(), Box<dyn Error + Send + Sync>>

Publica automaticamente quando novos peers são descobertos

Trait Implementations

impl Debug for CustomDiscoveryService

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Discovery for CustomDiscoveryService

fn publish(&self, data: &NodeData)

Publica informações do nó para descoberta

fn resolve( &self, node_id: NodeId, ) -> Option<Pin<Box<dyn Stream<Item = Result<DiscoveryItem, DiscoveryError>> + Send + 'static>>>

Resolve endereços de um nó específico

fn subscribe( &self, ) -> Option<Pin<Box<dyn Stream<Item = DiscoveryEvent> + Send + 'static>>>

Subscribe para eventos de descoberta