Struct ipld_block_builder::IpldCache

pub struct IpldCache<S, C, T> { /* fields omitted */ }

Cache for ipld blocks.

Implementations

impl<S, C, T> IpldCache<S, C, T>

pub fn new(store: S, codec: C, size: usize) -> Self

Creates a new cache of size size.

Trait Implementations

impl<S: Store + Send + Sync, C, T> Cache<C, T> for IpldCache<S, C, T> where
    C: Decoder + Encoder + Clone + Send + Sync,
    T: Decode<<C as Decoder>::Codec> + Encode<<C as Encoder>::Codec> + Clone + Send + Sync, 

fn create_batch(&self) -> CacheBatch<C, T>

Creates a typed batch.

fn create_batch_with_capacity(&self, capacity: usize) -> CacheBatch<C, T>

Creates a typed batch.

fn insert_batch<'life0, 'async_trait>(
    &'life0 self,
    batch: CacheBatch<C, T>
) -> Pin<Box<dyn Future<Output = Result<Cid>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Inserts a batch into the store.

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

Encodes and inserts a block.

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

Unpins a block.

impl<S: ReadonlyStore + Send + Sync, C, T> ReadonlyCache<C, T> for IpldCache<S, C, T> where
    C: Decoder + Clone + Send + Sync,
    T: Decode<<C as Decoder>::Codec> + Clone + Send + Sync, 

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

Returns a decoded block.