Struct MemoryStore 

pub struct MemoryStore<C = FixedSizeChunker, L = FlatLayout>
where
    C: Chunker,
    L: Layout,
{ /* private fields */ }

An in-memory storage for IPLD node and raw blocks with reference counting.

This store maintains a reference count for each stored block. Reference counting is used to determine when a block can be safely removed from the store.

Implementations

impl<C, L> MemoryStore<C, L>

where C: Chunker, L: Layout,

pub fn new(chunker: C, layout: L) -> Self

Creates a new MemoryStore with the given chunker and layout.

pub fn debug(&self)

where C: Clone + Send, L: Clone + Send,

Prints all the blocks in the store.

Trait Implementations

impl<C, L> Clone for MemoryStore<C, L>

where C: Chunker + Clone, L: Layout + Clone,

fn clone(&self) -> MemoryStore<C, L>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C, L> Debug for MemoryStore<C, L>

where C: Chunker + Debug, L: Layout + Debug,

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

Formats the value using the given formatter.

impl Default for MemoryStore

fn default() -> Self

Returns the “default value” for a type.

impl<C, L> IpldStore for MemoryStore<C, L>

where C: Chunker + Clone + Send + Sync, L: Layout + Clone + Send + 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, reader: 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>) -> 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<T>(&self, cid: &Cid) -> StoreResult<T>

where T: DeserializeOwned,

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.

impl<C, L> IpldStoreSeekable for MemoryStore<C, L>

where C: Chunker + Clone + Send + Sync, L: LayoutSeekable + Clone + Send + Sync,

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

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