Struct PersistenceContext 

pub struct PersistenceContext<E, J, S, M>
where
    E: StateEngine + 'static,
    J: BlockJournal + 'static,
    S: Snapshotter + 'static,
    M: MetadataStore + 'static,
{ /* private fields */ }

Aggregates persistence-related state shared between the orchestrator and the runtime.

Implementations

impl<E, J, S, M> PersistenceContext<E, J, S, M>

where E: StateEngine + 'static, J: BlockJournal + 'static, S: Snapshotter + 'static, M: MetadataStore + 'static,

pub fn new( state_engine: Arc<E>, journal: Arc<J>, snapshotter: Arc<S>, metadata: Arc<M>, update_mutex: Arc<Mutex<()>>, settings: &PersistenceSettings, ) -> StoreResult<Self>

pub fn metrics(&self) -> &StoreMetrics

pub fn pending_blocks(&self) -> &PendingBlocks

pub fn durable_block_height(&self) -> BlockId

pub fn durable_block_tracker(&self) -> Arc<AtomicU64>

pub fn applied_block_height(&self) -> BlockId

pub fn set_applied_block(&self, block_height: BlockId)

pub fn set_durable_block(&self, block_height: BlockId)

pub fn rollback_barrier(&self) -> &Arc<AtomicU64>

pub fn set_rollback_barrier(&self, block_height: BlockId)

pub fn update_key_count(&self, total_keys: usize)

pub fn is_async(&self) -> bool

pub fn enqueue(&self, task: Arc<PersistenceTask>) -> StoreResult<()>

pub fn set_metadata_sync_interval( &self, sync_every_n_blocks: usize, ) -> StoreResult<()>

pub fn cancel_after(&self, block_height: BlockId) -> Vec<Arc<PersistenceTask>>

pub fn discard_pending_metadata_after(&self, block_height: BlockId)

pub fn flush_pending_metadata_through( &self, block_height: BlockId, ) -> StoreResult<()>

pub fn flush(&self) -> StoreResult<()>

pub fn enforce_snapshot_freshness(&self) -> StoreResult<()>

pub fn shutdown(&self) -> StoreResult<()>

pub fn fatal_error(&self) -> Option<StoreError>

pub fn ensure_healthy(&self) -> StoreResult<()>