Struct FileProgressStore

pub struct FileProgressStore { /* private fields */ }

Manages persistent progress information stored in a JSON file.

This struct encapsulates file operations for reading, writing, and synchronizing progress data to disk. It uses asynchronous I/O provided by tokio::fs for efficient operation within a Tokio runtime.

Example

use iota_data_ingestion_core::{FileProgressStore, ProgressStore};

#[tokio::main]
async fn main() {
    let mut store = FileProgressStore::new("progress.json").await.unwrap();
    store.save("task1".into(), 42).await.unwrap();
    let checkpoint = store.load("task1".into()).await.unwrap();
    assert_eq!(checkpoint, 42);
}

Implementations

impl FileProgressStore

pub async fn new(path: impl Into<PathBuf>) -> IngestionResult<Self>

Creates a new FileProgressStore by opening or creating the file at the specified path.

Trait Implementations

impl ProgressStore for FileProgressStore

type Error = IngestionError

fn load<'life0, 'async_trait>( &'life0 mut self, task_name: String, ) -> Pin<Box<dyn Future<Output = Result<CheckpointSequenceNumber, Self::Error>> + Send + 'async_trait>>

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

Loads the last saved checkpoint sequence number for a given task.

fn save<'life0, 'async_trait>( &'life0 mut self, task_name: String, checkpoint_number: CheckpointSequenceNumber, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Saves the current checkpoint sequence number for a given task.