Struct Inner 

struct Inner {
    path: PathBuf,
    view_retention: u64,
}

Fields

path: PathBuf

view_retention: u64

Implementations

impl Inner

fn config_path(&self) -> PathBuf

fn voted_view_path(&self) -> PathBuf

fn restart_view_path(&self) -> PathBuf

fn decided_leaf2_path(&self) -> PathBuf

fn legacy_anchor_leaf_path(&self) -> PathBuf

The path from previous versions where there was only a single file for anchor leaves.

fn vid2_dir_path(&self) -> PathBuf

fn da_dir_path(&self) -> PathBuf

fn drb_dir_path(&self) -> PathBuf

fn da2_dir_path(&self) -> PathBuf

fn quorum_proposals2_dir_path(&self) -> PathBuf

fn upgrade_certificate_dir_path(&self) -> PathBuf

fn stake_table_dir_path(&self) -> PathBuf

fn next_epoch_qc(&self) -> PathBuf

fn eqc(&self) -> PathBuf

fn high_qc2(&self) -> PathBuf

fn boundary_qc2(&self) -> PathBuf

fn epoch_drb_result_dir_path(&self) -> PathBuf

fn epoch_root_block_header_dir_path(&self) -> PathBuf

fn finalized_state_cert_dir_path(&self) -> PathBuf

fn state_cert_dir_path(&self) -> PathBuf

fn decided_cert2_dir_path(&self) -> PathBuf

fn load_cert2(&self, view: ViewNumber) -> Result<Option<Certificate2<SeqTypes>>>

cert2 is only persisted for the view that is directly finalized (the newest leaf in a decided chain). Ancestor views finalized indirectly have no cert2 file on disk for those, this returns Ok(None)

fn append_cert2( &mut self, view: ViewNumber, cert2: &Certificate2<SeqTypes>, ) -> Result<()>

fn replace( &mut self, path: &Path, pred: impl FnOnce(File) -> Result<bool>, write: impl FnOnce(File) -> Result<()>, ) -> Result<()>

Overwrite a file if a condition is met.

The file at path, if it exists, is opened in read mode and passed to pred. If pred returns true, or if there was no existing file, then write is called to update the contents of the file. write receives a truncated file open in write mode and sets the contents of the file.

The final replacement of the original file is atomic; that is, path will be modified only if the entire update succeeds.

fn collect_garbage( &mut self, decided_view: ViewNumber, prune_intervals: &[RangeInclusive<ViewNumber>], ) -> Result<()>

fn prune_files( &mut self, dir_path: PathBuf, prune_view: ViewNumber, keep_decided_view: Option<ViewNumber>, prune_intervals: &[RangeInclusive<ViewNumber>], ) -> Result<()>

fn parse_decided_leaf( &self, bytes: &[u8], ) -> Result<(Leaf2, CertificatePair<SeqTypes>)>

async fn generate_decide_events( &mut self, view: ViewNumber, consumer: &impl EventConsumer, ) -> Result<Vec<RangeInclusive<ViewNumber>>>

Generate events based on persisted decided leaves.

Returns a list of closed intervals of views which can be safely deleted, as all leaves within these view ranges have been processed by the event consumer.

fn skip_decide_events( &mut self, view: ViewNumber, ) -> Result<Vec<RangeInclusive<ViewNumber>>>

fn load_da_proposal( &self, view: ViewNumber, ) -> Result<Option<Proposal<SeqTypes, DaProposal2<SeqTypes>>>>

fn load_vid_share( &self, view: ViewNumber, ) -> Result<Option<Proposal<SeqTypes, VidDisperseShare<SeqTypes>>>>

fn load_anchor_leaf(&self) -> Result<Option<(Leaf2, CertificatePair<SeqTypes>)>>

fn store_finalized_state_cert( &mut self, view: ViewNumber, ) -> Result<Option<LightClientStateUpdateCertificateV2<SeqTypes>>>

Trait Implementations

impl Debug for Inner

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

Formats the value using the given formatter.