Struct noosphere_cli::native::commands::serve::ipfs::KuboClient

pub struct KuboClient { /* private fields */ }

A high-level HTTP client for accessing IPFS Kubo RPC APIs and normalizing their expected payloads to Noosphere-friendly formats

Implementations

impl KuboClient

pub fn new(api_url: &Url) -> Result<Self>

Trait Implementations

impl Clone for KuboClient

fn clone(&self) -> KuboClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl IpfsClient for KuboClient

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

Returns true if the block (referenced by Cid) is pinned by the IPFS server

fn server_identity<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,

Returns a string that represents the identity (for example, a base64-encoded public key) of a node. This node is used to track syndication progress over time, so it should ideally be stable for a given server as the client interacts with it over time

fn syndicate_blocks<'life0, 'async_trait, R>(
    &'life0 self,
    car: R
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
    R: AsyncRead + Send + Sync + 'static + 'async_trait,
    Self: 'async_trait,
    'life0: 'async_trait,

Given some CAR bytes, syndicate that CAR to the IPFS server. Callers expect the roots in the CAR to be explicitly pinned, and for their descendents to be pinned by association.