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_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 a missed block for a network

Arguments

• network_id - Unique identifier for the network
• block - Block number to save

Returns

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

impl Clone for FileBlockStorage

fn clone(&self) -> FileBlockStorage

Returns a copy 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”