Method read_committed_entries

nodedb-cluster/src/multi_raft/core.rs:286–298

Read committed log entries for a Raft group in the inclusive index range `[lo, hi]`. `hi` is clamped to the group's `commit_index` so callers that pass `u64::MAX` never read uncommitted entries. Used by the Calvin scheduler's rebuild path to replay sequenced transactions from the sequencer Raft log after a restart. Returns `Err(ClusterError::Raft(RaftError::LogCompacted))` if `lo` has been comp

(
        &self,
        group_id: u64,
        lo: u64,
        hi: u64,
    )

    /// has been compacted into a snapshot (caller must install a snapshot
    /// instead of replaying from log).
    pub fn read_committed_entries(
        &self,
        group_id: u64,
        lo: u64,
        hi: u64,
    ) -> Result<Vec<nodedb_raft::message::LogEntry>> {
        let node = self
            .groups
            .get(&group_id)
            .ok_or(ClusterError::GroupNotFound { group_id })?;
        let entries = node.log_entries_range(lo, hi)?;
        Ok(entries.to_vec())
    }
}

// Re-export LogEntry so callers of `read_committed_entries` can name the type.