Struct StorageMigrationPlanner 

pub struct StorageMigrationPlanner {
    pub records: HashMap<u64, MigrationRecord>,
    pub next_task_id: u64,
}

Plans and tracks migrations of blocks across storage tiers.

Example

use ipfrs_storage::migration_planner::{StorageMigrationPlanner, StorageTier};

let mut planner = StorageMigrationPlanner::new();
let id = planner.plan_migration(1, "bafyexample".into(), StorageTier::Nvme, StorageTier::Hdd, 4_000_000, vec![]);
assert!(planner.start_task(id, 0));
assert!(planner.complete_task(id, 10));

Fields

records: HashMap<u64, MigrationRecord>

All records keyed by their task_id.

next_task_id: u64

Counter used to assign the next unique task identifier.

Implementations

impl StorageMigrationPlanner

pub fn new() -> Self

Creates an empty planner with no tasks.

pub fn plan_migration( &mut self, block_id: u64, cid: String, from: StorageTier, to: StorageTier, size_bytes: u64, depends_on: Vec<u64>, ) -> u64

Plans a migration and returns the new task’s ID.

The direction is determined by comparing from and to:

• from > to → Promote
• from <= to → Demote

The cost estimate uses the formula size_bytes / 1_000_000 + 10 (ms).

pub fn start_task(&mut self, task_id: u64, current_tick: u64) -> bool

Transitions a task from Pending to InProgress.

Returns false if:

• the task does not exist,
• the task is not in Pending state, or
• any dependency is not yet Completed.

pub fn complete_task(&mut self, task_id: u64, current_tick: u64) -> bool

Transitions a task from InProgress to Completed.

Returns false if the task is not found or not InProgress.

pub fn fail_task(&mut self, task_id: u64) -> bool

Transitions a task to Failed.

Accepted from either Pending or InProgress. Returns false if the task is not found or already in a terminal state.

pub fn rollback_task(&mut self, task_id: u64) -> bool

Transitions a task from Failed to RolledBack.

Returns false if the task is not found or not in Failed state.

pub fn ready_tasks(&self) -> Vec<u64>

Returns the IDs of all tasks that are Pending and whose every dependency has Completed.

The list is sorted in ascending order of task_id.

pub fn get_record(&self, task_id: u64) -> Option<&MigrationRecord>

Returns an immutable reference to the record for task_id, or None.

pub fn stats(&self) -> PlannerStats

Computes aggregate statistics over all tracked records.

Trait Implementations

impl Default for StorageMigrationPlanner

fn default() -> Self

Returns the “default value” for a type.