Struct PersistentStateStorage 

pub struct PersistentStateStorage { /* private fields */ }

Implementations

impl PersistentStateStorage

pub fn new( cells_db: CellsDb, files_dir: &Dir, node_state: Arc<NodeStateStorage>, block_handle_storage: Arc<BlockHandleStorage>, block_storage: Arc<BlockStorage>, shard_state_storage: Arc<ShardStateStorage>, ) -> Result<Self>

pub fn load_oldest_known_handle(&self) -> Option<BlockHandle>

pub fn oldest_known_handle_changed(&self) -> Notified<'_>

pub async fn preload(&self) -> Result<()>

pub fn state_chunk_size(&self) -> NonZeroU32

pub fn subscribe(&self) -> (Vec<PersistentState>, PersistentStateReceiver)

pub fn state_exists( &self, block_id: &BlockId, kind: PersistentStateKind, ) -> bool

pub fn get_state_info( &self, block_id: &BlockId, kind: PersistentStateKind, ) -> Option<PersistentStateInfo>

pub async fn read_state_part( &self, block_id: &BlockId, offset: u64, state_kind: PersistentStateKind, ) -> Option<Vec<u8>>

pub async fn store_shard_state( &self, mc_seqno: u32, handle: &BlockHandle, tracker_handle: RefMcStateHandle, ) -> Result<()>

pub async fn store_shard_state_file( &self, mc_seqno: u32, handle: &BlockHandle, file: File, ) -> Result<()>

pub async fn store_queue_state( &self, mc_seqno: u32, handle: &BlockHandle, block: BlockStuff, ) -> Result<()>

pub async fn store_queue_state_file( &self, mc_seqno: u32, handle: &BlockHandle, file: File, ) -> Result<()>

pub async fn rotate_persistent_states( &self, top_handle: &BlockHandle, ) -> Result<()>

Trait Implementations

impl Clone for PersistentStateStorage

fn clone(&self) -> PersistentStateStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.