Method replicate_to_all

nodedb-raft/src/node/internal.rs:145–161

Send `AppendEntries` to every tracked peer (voters + learners + observers). Observers are skipped when their advisory send queue is full — source commits are never gated on observer apply pace.

(&mut self)

    /// Observers are skipped when their advisory send queue is full — source
    /// commits are never gated on observer apply pace.
    pub(super) fn replicate_to_all(&mut self) {
        let voters_and_learners: Vec<u64> = self
            .config
            .peers
            .iter()
            .chain(self.config.learners.iter())
            .copied()
            .collect();
        for peer in voters_and_learners {
            self.send_append_entries(peer);
        }

        let observers: Vec<u64> = self.config.observers.clone();
        for observer in observers {
            self.send_append_entries_to_observer(observer);
        }
    }

    pub(super) fn send_append_entries(&mut self, peer: u64) {
        let leader = match &self.leader_state {