Struct ipfs_embed::Store

pub struct Store<C: Codec, M: MultihashDigest> { /* fields omitted */ }

Implementations

impl<C: Codec, M: MultihashDigest> Store<C, M>

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

pub fn peer_id(&self) -> &PeerId

pub fn address(&self) -> &Multiaddr

pub fn blocks(&self) -> impl Iterator<Item = Result<Cid>>

pub fn metadata(&self, cid: &Cid) -> Result<Metadata>

pub fn get_local(&self, cid: &Cid) -> Result<Option<IVec>>

Trait Implementations

impl<C: Codec, M: MultihashDigest> AliasStore for Store<C, M>

fn alias<'a>(
    &'a self,
    alias: &'a [u8],
    block: &'a Block<C, M>
) -> StoreResult<'a, ()>

Creates an alias for a Cid with announces the alias on the public network.

fn unalias<'a>(&'a self, alias: &'a [u8]) -> StoreResult<'a, ()>

Removes an alias for a Cid.

fn resolve<'a>(&'a self, alias: &'a [u8]) -> StoreResult<'a, Option<Cid>>

Resolves an alias for a Cid.

impl<C: Clone + Codec, M: Clone + MultihashDigest> Clone for Store<C, M>

fn clone(&self) -> Store<C, M>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<C: Debug + Codec, M: Debug + MultihashDigest> Debug for Store<C, M>

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

Formats the value using the given formatter.

impl<C: Codec, M: MultihashDigest> ReadonlyStore for Store<C, M>

type Codec = C

The codec type of the store.

type Multihash = M

The multihash type of the store.

const MAX_BLOCK_SIZE: usize

The maximum block size supported by the store.

fn get<'a>(&'a self, cid: Cid) -> StoreResult<'a, Block<C, M>>

Returns a block from the store. If the block is not in the store it fetches it from the network and pins the block. Dropping the future cancels the request.

fn get_ipld(
    &'a self,
    cid: &'a Cid
) -> Pin<Box<dyn Future<Output = Result<Ipld, Error>> + 'a + Send>>

Returns the ipld representation of a block with cid.

fn get_path(
    &'a self,
    path: &'a DagPath<'a>
) -> Pin<Box<dyn Future<Output = Result<Ipld, Error>> + 'a + Send>>

Resolves a path recursively and returns the ipld.

impl<C: Codec, M: MultihashDigest> Store for Store<C, M>

fn insert<'a>(&'a self, block: &'a Block<C, M>) -> StoreResult<'a, ()>

Inserts and pins block into the store and announces it if it is visible.

fn insert_batch<'a>(&'a self, batch: &'a [Block<C, M>]) -> StoreResult<'a, Cid>

Inserts a batch of blocks atomically into the store and announces them block if it is visible. The last block is pinned.

fn flush(&self) -> StoreResult<'_, ()>

Flushes the write buffer.

fn unpin<'a>(&'a self, cid: &'a Cid) -> StoreResult<'a, ()>

Decreases the ref count on a cid.