Struct DualStore 

pub struct DualStore<A, B>
where
    A: IpldStore,
    B: IpldStore,
{ /* private fields */ }

A dual store that stores blocks on two different stores.

Implementations

impl<A, B> DualStore<A, B>

where A: IpldStore, B: IpldStore,

pub fn new(store_a: A, store_b: B, config: DualStoreConfig) -> Self

Creates a new dual store from two stores.

pub async fn get_node_from<D>( &self, cid: &Cid, choice: Choice, ) -> StoreResult<D>

where D: DeserializeOwned + Send,

Gets the type stored as an IPLD data from a chosen store by its Cid.

pub async fn get_bytes_from<'a>( &'a self, cid: &'a Cid, choice: Choice, ) -> StoreResult<Pin<Box<dyn AsyncRead + Send + Sync + 'a>>>

Gets the bytes stored in a chosen store as raw bytes by its Cid.

pub async fn get_raw_block_from( &self, cid: &Cid, choice: Choice, ) -> StoreResult<Bytes>

Gets raw bytes from a chosen store as a single block by its Cid.

pub async fn put_node_into<T>( &self, data: &T, choice: Choice, ) -> StoreResult<Cid>

where T: Serialize + IpldReferences + Sync,

Saves a serializable type to a chosen store and returns the Cid to it.

pub async fn put_bytes_into( &self, bytes: impl AsyncRead + Send + Sync, choice: Choice, ) -> StoreResult<Cid>

Saves raw bytes to a chosen store and returns the Cid to it.

pub async fn put_raw_block_into( &self, bytes: impl Into<Bytes> + Send, choice: Choice, ) -> StoreResult<Cid>

Saves raw bytes as a single block to a chosen store and returns the Cid to it.

pub async fn has_from(&self, cid: &Cid, choice: Choice) -> bool

Checks if a block exists in a chosen store by its Cid.

Trait Implementations

impl<A, B> Clone for DualStore<A, B>

where A: IpldStore + Clone, B: IpldStore + Clone,

fn clone(&self) -> DualStore<A, B>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A, B> Debug for DualStore<A, B>

where A: IpldStore + Debug, B: IpldStore + Debug,

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

Formats the value using the given formatter.

impl<A, B> IpldStore for DualStore<A, B>

where A: IpldStore + Sync, B: IpldStore + Sync,

async fn put_node<T>(&self, data: &T) -> StoreResult<Cid>

where T: Serialize + IpldReferences + Sync,

Saves an IPLD serializable object to the store and returns the Cid to it.

async fn put_bytes<'a>( &'a self, bytes: impl AsyncRead + Send + Sync + 'a, ) -> StoreResult<Cid>

Takes a reader of raw bytes, saves it to the store and returns the Cid to it.

async fn put_raw_block( &self, bytes: impl Into<Bytes> + Send, ) -> StoreResult<Cid>

Tries to save bytes as a single block to the store. Unlike put_bytes, this method does not chunk the data and does not create intermediate merkle nodes.

async fn get_node<D>(&self, cid: &Cid) -> StoreResult<D>

where D: DeserializeOwned + Send,

Gets a type stored as an IPLD data from the store by its Cid.

async fn get_bytes<'a>( &'a self, cid: &'a Cid, ) -> StoreResult<Pin<Box<dyn AsyncRead + Send + Sync + 'a>>>

Gets a reader for the underlying bytes associated with the given Cid.

async fn get_raw_block(&self, cid: &Cid) -> StoreResult<Bytes>

Retrieves raw bytes of a single block from the store by its Cid.

async fn has(&self, cid: &Cid) -> bool

Checks if the store has a block with the given Cid.

fn get_supported_codecs(&self) -> HashSet<Codec>

Returns the codecs supported by the store.

fn get_node_block_max_size(&self) -> Option<u64>

Returns the allowed maximum block size for IPLD and merkle nodes. If there is no limit, None is returned.

fn get_raw_block_max_size(&self) -> Option<u64>

Returns the allowed maximum block size for raw bytes. If there is no limit, None is returned.

async fn is_empty(&self) -> StoreResult<bool>

Checks if the store is empty.

async fn get_size(&self) -> StoreResult<u64>

Returns the number of blocks in the store.