Struct IpldCache

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

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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: 'async_trait,

Encodes and inserts a block.

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Flushes all buffers.

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

where Self: 'async_trait, 'life0: 'async_trait, 'life1: '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 Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Returns a decoded block.