Struct Inner

struct Inner {
    path: PathBuf,
    view_retention: u64,
    migrated: HashSet<String>,
}

Fields

path: PathBuf

view_retention: u64

migrated: HashSet<String>

Implementations

impl Inner

fn config_path(&self) -> PathBuf

fn migration(&self) -> PathBuf

fn voted_view_path(&self) -> PathBuf

fn restart_view_path(&self) -> PathBuf

fn decided_leaf_path(&self) -> PathBuf

Path to a directory containing decided leaves.

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 vid_dir_path(&self) -> PathBuf

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_proposals_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 libp2p_dht_path(&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 update_migration(&mut self) -> 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<()>

async fn generate_decide_events( &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 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, QuorumCertificate2<SeqTypes>)>>

fn finalized_state_cert( &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.