Struct ShardedStateEngine 

pub struct ShardedStateEngine<M>
where
    M: MetadataStore + 'static,
{ /* private fields */ }

Implementations

impl<M> ShardedStateEngine<M>

where M: MetadataStore + 'static,

pub fn new(shards: Vec<Arc<dyn StateShard>>, _metadata: Arc<M>) -> Self

pub fn with_thread_pool( shards: Vec<Arc<dyn StateShard>>, _metadata: Arc<M>, thread_pool: Option<Arc<ThreadPool>>, ) -> Self

pub fn shard_count(&self) -> usize

pub fn apply_replayed_block( &self, block_height: BlockId, operations: &[Operation], undo: &BlockUndo, ) -> StoreResult<()>

Trait Implementations

impl<M> StateEngine for ShardedStateEngine<M>

where M: MetadataStore + 'static,

fn total_keys(&self) -> usize

fn prepare_journal( &self, block_height: BlockId, ops: &[Operation], ) -> StoreResult<BlockDelta>

fn commit( &self, block_height: BlockId, delta: BlockDelta, ) -> StoreResult<(StateStats, BlockUndo)>

fn revert(&self, block_height: BlockId, undo: BlockUndo) -> StoreResult<()>

fn lookup_many(&self, keys: &[Key]) -> Vec<Option<ValueBuf>>

fn lookup(&self, key: &Key) -> Option<ValueBuf>

fn snapshot_shards(&self) -> Vec<Arc<dyn StateShard>>