Method append

nodedb-cluster/src/raft_storage.rs:87–127

(&mut self, entries: &[LogEntry])

impl LogStorage for RedbLogStorage {
    fn append(&mut self, entries: &[LogEntry]) -> nodedb_raft::error::Result<()> {
        if entries.is_empty() {
            return Ok(());
        }

        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}"),
                }
            })?;

            for entry in entries {
                let key = index_key(entry.index);
                let value = encode_versioned(entry).map_err(|e| {
                    nodedb_raft::error::RaftError::Storage {
                        detail: format!("serialize entry: {e}"),
                    }
                })?;
                table
                    .insert(key.as_slice(), value.as_slice())
                    .map_err(|e| nodedb_raft::error::RaftError::Storage {
                        detail: format!("insert entry: {e}"),
                    })?;
            }
        }
        write_txn
            .commit()
            .map_err(|e| nodedb_raft::error::RaftError::Storage {
                detail: format!("commit append: {e}"),
            })?;

        debug!(count = entries.len(), "raft log appended");
        Ok(())
    }

    fn truncate(&mut self, index: u64) -> nodedb_raft::error::Result<()> {
        let write_txn =