Struct MemoryBucketLogProvider 

pub struct MemoryBucketLogProvider { /* private fields */ }

In-memory bucket log provider using HashMaps

Implementations

impl MemoryBucketLogProvider

pub fn new() -> Self

Trait Implementations

impl BucketLogProvider for MemoryBucketLogProvider

type Error = MemoryBucketLogProviderError

fn exists<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<bool, BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

fn heads<'life0, 'async_trait>( &'life0 self, id: Uuid, height: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<Link>, BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

Get the possible heads for a bucket based on passed height

fn append<'life0, 'async_trait>( &'life0 self, id: Uuid, name: String, current: Link, previous: Option<Link>, height: u64, ) -> Pin<Box<dyn Future<Output = Result<(), BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

Append a version of the bucket to the log

fn height<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<u64, BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

Return the greatest height of the bucket version within the chain

fn has<'life0, 'async_trait>( &'life0 self, id: Uuid, link: Link, ) -> Pin<Box<dyn Future<Output = Result<Vec<u64>, BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

Check if a link exists within a bucket

fn list_buckets<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Uuid>, BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

List all bucket IDs that have log entries

fn head<'life0, 'async_trait>( &'life0 self, id: Uuid, height: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<(Link, u64), BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

Get the peers canonical head based on its log entries

impl Clone for MemoryBucketLogProvider

fn clone(&self) -> MemoryBucketLogProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemoryBucketLogProvider

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

Formats the value using the given formatter.

impl Default for MemoryBucketLogProvider

fn default() -> Self

Returns the “default value” for a type.