Struct IrohBackend 

pub struct IrohBackend { /* private fields */ }

Backend Iroh Otimizado

Backend IPFS de alta performance com otimizações nativas:

• Cache multinível com compressão inteligente
• Pool de conexões com circuit breaking
• Processamento em batch para máximo throughput
• Monitoramento contínuo de performance

Implementations

impl IrohBackend

pub async fn new(config: &ClientConfig) -> Result<Self>

Cria uma nova instância do backend Iroh

Argumentos

• config - Configuração do cliente contendo path de dados

Retorna

Nova instância configurada do backend Iroh

Erros

Retorna erro se não conseguir inicializar o nó Iroh

pub async fn get_swarm_manager( &self, ) -> Result<Arc<RwLock<Option<SwarmManager>>>>

Obtém referência para o SwarmManager se disponível

pub async fn get_topic_mesh_peers(&self, topic: &str) -> Result<Vec<PeerId>>

Obtém peers do mesh do Gossipsub para um tópico específico

pub async fn publish_gossip(&self, topic: &str, data: &[u8]) -> Result<()>

Publica mensagem em tópico Gossipsub

pub async fn subscribe_gossip(&self, topic: &str) -> Result<()>

Subscreve a um tópico Gossipsub

pub async fn discover_peer_integrated( &self, node_id: NodeId, ) -> Result<Vec<NodeAddr>>

Descobre peers usando sistema integrado DHT + Discovery

pub async fn publish_node_integrated(&self, node_data: &NodeData) -> Result<u32>

Publica informações do nó no sistema integrado

pub async fn get_active_discoveries_status( &self, ) -> Result<HashMap<NodeId, DiscoveryStatus>>

Obtém status das descobertas ativas

pub async fn force_dht_sync(&self) -> Result<()>

Força sincronização DHT com todas as sessões ativas

impl IrohBackend

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

Descobre um peer específico

pub async fn get_discovery_cache_statistics( &self, ) -> Result<DiscoveryCacheStats>

Obtém estatísticas do cache LRU de discovery

pub async fn get_cache_statistics(&self) -> Result<SimpleCacheStats>

Obtém estatísticas do cache otimizado

pub async fn optimize_performance(&self) -> Result<()>

Executa otimização automática de performance

pub async fn get_config_info(&self) -> String

Utiliza configuração para ajustes dinâmicos

pub async fn get_connection_pool_status(&self) -> String

Obtém informações do pool de conexões

pub async fn discovery_by_method( &self, node_id: NodeId, method: DiscoveryMethod, ) -> Result<Vec<String>>

Executa discovery específico por método

pub async fn get_discovery_stats(&self) -> String

Obtém estatísticas do sistema de discovery como String formatada

pub async fn get_performance_monitor_status(&self) -> String

Obtém status do monitor de performance

pub async fn generate_performance_report(&self) -> String

Gera relatório detalhado de performance

impl IrohBackend

pub fn create_pubsub_interface(self: Arc<Self>) -> IrohPubSub

Cria uma interface PubSub para este backend

Trait Implementations

impl IpfsBackend for IrohBackend

fn add<'life0, 'async_trait>( &'life0 self, data: Pin<Box<dyn AsyncRead + Send>>, ) -> Pin<Box<dyn Future<Output = Result<AddResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Adiciona dados ao IPFS e retorna o CID resultante

fn cat<'life0, 'life1, 'async_trait>( &'life0 self, cid: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn AsyncRead + Send>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Recupera dados do IPFS pelo CID

fn pin_add<'life0, 'life1, 'async_trait>( &'life0 self, cid: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fixa um objeto no storage local (evita garbage collection)

fn pin_rm<'life0, 'life1, 'async_trait>( &'life0 self, cid: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove fixação de um objeto (permite garbage collection)

fn pin_ls<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<PinInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Lista objetos fixados

fn connect<'life0, 'life1, 'async_trait>( &'life0 self, peer: &'life1 PeerId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Conecta explicitamente a um peer

fn peers<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<PeerInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Lista peers atualmente conectados

fn id<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<NodeInfo>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Obtém informações do nó local

fn dht_find_peer<'life0, 'life1, 'async_trait>( &'life0 self, peer: &'life1 PeerId, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Resolve um peer ID para seus endereços conhecidos

fn repo_stat<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<RepoStats>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Obtém estatísticas do repositório local

fn version<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<VersionInfo>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Obtém versão e informações do nó IPFS

fn block_get<'life0, 'life1, 'async_trait>( &'life0 self, cid: &'life1 Cid, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Obtém um bloco raw pelo seu CID

fn block_put<'life0, 'async_trait>( &'life0 self, data: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<Cid>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Armazena dados raw como bloco

fn block_stat<'life0, 'life1, 'async_trait>( &'life0 self, cid: &'life1 Cid, ) -> Pin<Box<dyn Future<Output = Result<BlockStats>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Verifica se um bloco existe localmente

fn backend_type(&self) -> BackendType

Retorna o tipo/nome do backend

fn is_online<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Verifica se o backend está online e operacional

fn metrics<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<BackendMetrics>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Obtém métricas de performance do backend

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<HealthStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Executa health check completo do backend