Struct IpfsClient 

pub struct IpfsClient { /* private fields */ }

Cliente principal da API IPFS Core

Implementations

impl IpfsClient

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

Cria uma nova instância do cliente IPFS

pub async fn default() -> Result<Self>

Cria uma instância com configuração padrão

pub async fn development() -> Result<Self>

Cria uma instância para desenvolvimento

pub async fn production() -> Result<Self>

Cria uma instância para produção

pub async fn testing() -> Result<Self>

Cria uma instância para testes

pub async fn new_with_backend(backend: Arc<IrohBackend>) -> Result<Self>

Cria uma instância usando um backend Iroh existente

pub async fn is_online(&self) -> bool

Verifica se o nó está funcionando

pub async fn add<R>(&self, data: R) -> Result<AddResponse>

where R: AsyncRead + Send + Unpin + 'static,

Adiciona dados ao IPFS usando backend Iroh

pub async fn add_bytes(&self, data: Vec<u8>) -> Result<AddResponse>

Adiciona dados de Vec ao IPFS (helper method)

pub async fn cat(&self, path: &str) -> Result<Pin<Box<dyn AsyncRead + Send>>>

Recupera dados do IPFS pelo hash/CID usando backend Iroh

pub async fn dag_get(&self, cid: &Cid, _path: Option<&str>) -> Result<Vec<u8>>

Recupera um objeto DAG do IPFS

pub async fn dag_put(&self, data: &[u8]) -> Result<Cid>

Armazena um objeto DAG no IPFS

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

Publica uma mensagem em um tópico do pubsub

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

Subscreve a um tópico do pubsub

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

Lista os peers conectados a um tópico do pubsub

pub async fn pubsub_topics(&self) -> Result<Vec<String>>

Lista todos os tópicos ativos

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

Cancela subscrição de um tópico

pub async fn swarm_connect(&self, peer: &PeerId) -> Result<()>

Conecta a um peer específico

pub async fn swarm_peers(&self) -> Result<Vec<PeerInfo>>

Lista todos os peers conectados ao swarm

pub async fn id(&self) -> Result<NodeInfo>

Obtém informações sobre este nó

pub async fn pin_add(&self, hash: &str, recursive: bool) -> Result<PinResponse>

Adiciona um objeto aos pins

pub async fn pin_rm(&self, hash: &str) -> Result<PinResponse>

Remove um objeto dos pins

pub async fn pin_ls( &self, pin_type_filter: Option<PinType>, ) -> Result<Vec<PinResponse>>

Lista objetos pinned

pub async fn repo_stat(&self) -> Result<RepoStats>

Obtém estatísticas do repositório

pub fn get_channel_id(&self, other_peer: &PeerId) -> String

Gera um ID único para canal de comunicação entre dois peers Compatível com get_channel_id do one_on_one_channel.rs

pub fn config(&self) -> &ClientConfig

Obtém configuração atual

pub fn node_id(&self) -> PeerId

Obtém ID do nó

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

Interrompe o cliente IPFS

Trait Implementations

impl Clone for IpfsClient

fn clone(&self) -> IpfsClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl IpfsClientCompat for IpfsClient

async fn add_compat<R>(&self, data: R) -> Result<AddResponse>

where R: AsyncRead + Send + Unpin + 'static,

async fn cat_compat(&self, hash: &str) -> Result<Vec<u8>>