Struct SamodLoader 

pub struct SamodLoader { /* private fields */ }

A state machine for loading a samod repository.

SamodLoader handles the initialization phase of a samod repository, coordinating between the user and the driver to load or generate the storage ID and perform any other setup operations required before the repository can be used.

Usage

use samod_core::{PeerId, SamodLoader, LoaderState, UnixTimestamp, io::{StorageResult, IoResult}};
use rand::SeedableRng;

let mut rng = rand::rngs::StdRng::from_rng(&mut rand::rng());
let mut loader = SamodLoader::new(PeerId::from("test"));

loop {
    match loader.step(&mut rng, UnixTimestamp::now()) {
        LoaderState::NeedIo(tasks) => {
            // Execute IO tasks and provide results
            for task in tasks {
                // ... execute task ...
                loader.provide_io_result(result);
            }
        }
        LoaderState::Loaded(samod) => {
            // Repository is loaded and ready to use
            break;
        }
    }
}

Implementations

impl SamodLoader

pub fn new(local_peer_id: PeerId) -> Self

Creates a new samod loader.

Arguments

• now - The current timestamp for initialization

Returns

A new SamodLoader ready to begin the loading process.

pub fn step<R: Rng>(&mut self, rng: &mut R, _now: UnixTimestamp) -> LoaderState

Advances the loader state machine.

This method should be called repeatedly until LoaderState::Loaded is returned. When LoaderState::NeedIo is returned, the caller must execute the provided IO tasks and call provide_io_result for each one before calling step again.

Arguments

• now - The current timestamp

Returns

The current state of the loader.

pub fn provide_io_result(&mut self, result: IoResult<StorageResult>)

Provides the result of an IO operation.

This method should be called for each IO task that was returned by step. The loader passes the result directly to the driver for processing.

Arguments

• result - The result of executing an IO task