Enum IOTask 

pub enum IOTask {
    ReplaceRange {
        truncate_from: u64,
        new_entries: Vec<Entry>,
        done: Sender<Result<()>>,
    },
    Purge {
        cutoff: LogId,
        done: Sender<()>,
    },
    Reset {
        done: Sender<Result<()>>,
    },
    Flush(Sender<Result<()>>),
    Shutdown,
}

IO tasks for the dedicated raft-io thread.

All blocking storage operations route through this channel so they never run on tokio worker threads or the Raft event loop.

Variants

ReplaceRange

Atomically truncate from truncate_from then persist new_entries. Conflict-resolution path: truncate + write are a single atomic IO unit. done is signalled after the IO thread finishes the replace so callers can flush() knowing the truncation is durable.

Fields

truncate_from: u64

new_entries: Vec<Entry>

done: Sender<Result<()>>

Purge

Purge log entries up to cutoff from storage.

Fields

cutoff: LogId

done: Sender<()>

Reset

Reset log storage (snapshot install). Routes through IO thread so reset never runs on the Raft event loop.

Fields

done: Sender<Result<()>>

Flush(Sender<Result<()>>)

Persist any pending entries then fsync. The IO thread sends the fsync result (Ok or Err) back to the caller via the oneshot channel. Replaces the former FlushNow + WaitDurable two-message dance.

Shutdown

Shutdown the IO thread

Trait Implementations

impl Debug for IOTask

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.