Method send

src/compute-client/src/controller/instance.rs:1103–1129

(&mut self, cmd: ComputeCommand)

    /// Sends a command to replicas of this instance.
    #[mz_ore::instrument(level = "debug")]
    fn send(&mut self, cmd: ComputeCommand) {
        // Record the command so that new replicas can be brought up to speed.
        // We record the *base* (un-specialized) command, so that the per-replica
        // dyncfg overrides are re-applied at replay time in `add_replica` rather
        // than baked into the shared history.
        self.history.push(cmd.clone());

        let target_replica = self.target_replica(&cmd);

        // Borrow the overrides and dyncfg separately from `self.replicas` so the per-replica
        // specialization below does not conflict with the mutable replica borrow.
        let overrides = &self.replica_dyncfg_overrides;
        let dyncfg = &self.dyncfg;

        if let Some(rid) = target_replica {
            if let Some(replica) = self.replicas.get_mut(&rid) {
                let cmd = Self::specialize_command_for_replica(cmd, rid, overrides, dyncfg);
                let _ = replica.client.send(cmd);
            }
        } else {
            for (rid, replica) in self.replicas.iter_mut() {
                let cmd =
                    Self::specialize_command_for_replica(cmd.clone(), *rid, overrides, dyncfg);
                let _ = replica.client.send(cmd);
            }
        }
    }

    /// Specializes a command for a specific replica by merging that replica's dyncfg override into
    /// its configuration. For `UpdateConfiguration` the override is merged into the update. For