Struct rust_ipfs::repo::Repo

pub struct Repo { /* private fields */ }

Describes a repo.

Consolidates a blockstore, a datastore and a subscription registry.

Implementations

impl Repo

pub fn new(repo_type: StoragePath) -> Self

pub fn new_raw( block_store: Arc<dyn BlockStore>, data_store: Arc<dyn DataStore>, lockfile: Arc<dyn Lock> ) -> Self

pub fn new_fs(path: impl AsRef<Path>) -> Self

pub fn new_memory() -> Self

pub async fn migrate(&self, repo: &Self) -> Result<(), Error>

pub fn shutdown(&self)

Shutdowns the repo, cancelling any pending subscriptions; Likely going away after some refactoring, see notes on crate::Ipfs::exit_daemon.

pub fn is_online(&self) -> bool

pub async fn init(&self) -> Result<(), Error>

pub async fn open(&self) -> Result<(), Error>

pub async fn put_block(&self, block: Block) -> Result<(Cid, BlockPut), Error>

Puts a block into the block store.

pub async fn get_block( &self, cid: &Cid, peers: &[PeerId], local_only: bool ) -> Result<Block, Error>

Retrives a block from the block store, or starts fetching it from the network and awaits until it has been fetched.

pub async fn get_block_now(&self, cid: &Cid) -> Result<Option<Block>, Error>

Retrieves a block from the block store if it’s available locally.

pub async fn contains(&self, cid: &Cid) -> Result<bool, Error>

Check to determine if blockstore contain a block

pub async fn list_blocks(&self) -> Result<Vec<Cid>, Error>

Lists the blocks in the blockstore.

pub async fn remove_block(&self, cid: &Cid) -> Result<Cid, Error>

Remove block from the block store.

pub async fn get_ipns(&self, ipns: &PeerId) -> Result<Option<IpfsPath>, Error>

Get an ipld path from the datastore.

pub async fn put_ipns( &self, ipns: &PeerId, path: &IpfsPath ) -> Result<(), Error>

Put an ipld path into the datastore.

pub async fn remove_ipns(&self, ipns: &PeerId) -> Result<(), Error>

Remove an ipld path from the datastore.

pub async fn insert_pin( &self, cid: &Cid, recursive: bool, local_only: bool ) -> Result<(), Error>

Pins a given Cid recursively or directly (non-recursively).

pub async fn insert_direct_pin(&self, cid: &Cid) -> Result<(), Error>

Inserts a direct pin for a Cid.

pub async fn insert_recursive_pin( &self, cid: &Cid, refs: BoxStream<'_, Result<Cid, IpldRefsError>> ) -> Result<(), Error>

Inserts a recursive pin for a Cid.

pub async fn remove_direct_pin(&self, cid: &Cid) -> Result<(), Error>

Removes a direct pin for a Cid.

pub async fn remove_recursive_pin( &self, cid: &Cid, refs: BoxStream<'_, Result<Cid, IpldRefsError>> ) -> Result<(), Error>

Removes a recursive pin for a Cid.

pub async fn cleanup(&self) -> Result<Vec<Cid>, Error>

Function to perform a basic cleanup of unpinned blocks

pub async fn is_pinned(&self, cid: &Cid) -> Result<bool, Error>

Checks if a Cid is pinned.

pub async fn list_pins( &self, mode: Option<PinMode> ) -> BoxStream<'static, Result<(Cid, PinMode), Error>>

pub async fn query_pins( &self, cids: Vec<Cid>, requirement: Option<PinMode> ) -> Result<Vec<(Cid, PinKind<Cid>)>, Error>

impl Repo

pub fn data_store(&self) -> &dyn DataStore

Trait Implementations

impl Clone for Repo

fn clone(&self) -> Repo

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Repo

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

Formats the value using the given formatter.

impl From<Repo> for IpldDag

fn from(repo: Repo) -> Self

Converts to this type from the input type.

impl Store for Repo

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

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

fn has<'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,