Struct FileBlockStorage

pub struct FileBlockStorage { /* private fields */ }

File-based implementation of block storage

Stores blocks and processing state in JSON files within a configured directory structure.

Implementations

impl FileBlockStorage

pub fn new(storage_path: PathBuf) -> Self

Creates a new file-based block storage instance

Initializes storage with the provided path

Trait Implementations

impl BlockStorage for FileBlockStorage

fn get_last_processed_block<'life0, 'life1, 'async_trait>( &'life0 self, network_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves the last processed block from a network-specific file

The file is named “{network_id}_last_block.txt”

fn save_last_processed_block<'life0, 'life1, 'async_trait>( &'life0 self, network_id: &'life1 str, block: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Saves the last processed block to a network-specific file

Note

Overwrites any existing last block file for the network

fn save_blocks<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, network_slug: &'life1 str, blocks: &'life2 [BlockType], ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Saves blocks to a timestamped JSON file

Note

Creates a new file for each save operation, named: “{network_id}blocks{timestamp}.json”

fn delete_blocks<'life0, 'life1, 'async_trait>( &'life0 self, network_slug: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Deletes all block files for a network

Note

Uses glob pattern matching to find and delete all files matching: “{network_id}blocks*.json”

fn save_missed_blocks<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, network_id: &'life1 str, blocks: &'life2 [u64], ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Saves multiple missed blocks for a network in a single operation

This method saves new missed blocks to the JSON file. It first loads existing entries, adds the new blocks (deduplicating), and saves back.

Arguments

• network_id - Unique identifier for the network
• blocks - Slice of block numbers to save

Returns

• Result<(), anyhow::Error> - Success or error

fn get_missed_blocks<'life0, 'life1, 'async_trait>( &'life0 self, network_id: &'life1 str, max_block_age: u64, current_block: u64, max_retries: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<MissedBlockEntry>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves missed blocks eligible for recovery

fn update_missed_block_status<'life0, 'life1, 'async_trait>( &'life0 self, network_id: &'life1 str, block_number: u64, status: MissedBlockStatus, error: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Updates the status of a missed block

fn remove_recovered_blocks<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, network_id: &'life1 str, block_numbers: &'life2 [u64], ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Removes recovered blocks from storage

fn prune_old_missed_blocks<'life0, 'life1, 'async_trait>( &'life0 self, network_id: &'life1 str, max_block_age: u64, current_block: u64, ) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Prunes missed blocks older than max_block_age

impl Clone for FileBlockStorage

fn clone(&self) -> FileBlockStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for FileBlockStorage

fn default() -> Self

Default implementation for FileBlockStorage

Initializes storage with the default path “data”