Method truncate

nodedb-cluster/src/raft_storage.rs:129–175

(&mut self, index: u64)

    }

    fn truncate(&mut self, index: u64) -> nodedb_raft::error::Result<()> {
        let write_txn =
            self.db
                .begin_write()
                .map_err(|e| nodedb_raft::error::RaftError::Storage {
                    detail: format!("write txn: {e}"),
                })?;
        {
            let mut table = write_txn.open_table(ENTRIES).map_err(|e| {
                nodedb_raft::error::RaftError::Storage {
                    detail: format!("open entries: {e}"),
                }
            })?;

            // Collect keys >= index to remove.
            let start = index_key(index);
            let keys_to_remove: Vec<[u8; 8]> = table
                .range(start.as_slice()..)
                .map_err(|e| nodedb_raft::error::RaftError::Storage {
                    detail: format!("range: {e}"),
                })?
                .filter_map(|r| {
                    r.ok().map(|(k, _)| {
                        let mut buf = [0u8; 8];
                        buf.copy_from_slice(k.value());
                        buf
                    })
                })
                .collect();

            for key in &keys_to_remove {
                table.remove(key.as_slice()).map_err(|e| {
                    nodedb_raft::error::RaftError::Storage {
                        detail: format!("remove: {e}"),
                    }
                })?;
            }
        }
        write_txn
            .commit()
            .map_err(|e| nodedb_raft::error::RaftError::Storage {
                detail: format!("commit truncate: {e}"),
            })?;

        debug!(from_index = index, "raft log truncated");
        Ok(())
    }

    fn load_entries_after(&self, snapshot_index: u64) -> nodedb_raft::error::Result<Vec<LogEntry>> {
        let read_txn =