fn spawn_diff(&mut self, diff: &ConfigDiff, mut new_pieces: Pieces, rt: &mut runtime::Runtime) {
        // Sources
        for name in &diff.sources.to_change {
            info!("Rebuilding source {:?}", name);
            self.spawn_source(name, &mut new_pieces, rt);
        }

        for name in &diff.sources.to_add {
            info!("Starting source {:?}", name);
            self.spawn_source(&name, &mut new_pieces, rt);
        }

        // Transforms
        for name in &diff.transforms.to_change {
            info!("Rebuilding transform {:?}", name);
            self.spawn_transform(&name, &mut new_pieces, rt);
        }

        for name in &diff.transforms.to_add {
            info!("Starting transform {:?}", name);
            self.spawn_transform(&name, &mut new_pieces, rt);
        }

        // Sinks
        for name in &diff.sinks.to_change {
            info!("Rebuilding sink {:?}", name);
            self.spawn_sink(&name, &mut new_pieces, rt);
        }

        for name in &diff.sinks.to_add {
            info!("Starting sink {:?}", name);
            self.spawn_sink(&name, &mut new_pieces, rt);
        }
    }
/// Starts new and changed pieces of topology.
Starts new and changed pieces of topology.
Starts new and changed pieces of topology .
fn spawn_diff(&mut self, diff: &ConfigDiff, mut new_pieces: Pieces, rt: &mut runtime::Runtime) {
        // Sources
        for name in &diff.sources.to_change {
            info!("Rebuilding source {:?}", name);
            self.spawn_source(name, &mut new_pieces, rt);
        }
        for name in &diff.sources.to_add {
            info!("Starting source {:?}", name);
            self.spawn_source(&name, &mut new_pieces, rt);
        }
        // Transforms
        for name in &diff.transforms.to_change {
            info!("Rebuilding transform {:?}", name);
            self.spawn_transform(&name, &mut new_pieces, rt);
        }
        for name in &diff.transforms.to_add {
            info!("Starting transform {:?}", name);
            self.spawn_transform(&name, &mut new_pieces, rt);
        }
        // Sinks
        for name in &diff.sinks.to_change {
            info!("Rebuilding sink {:?}", name);
            self.spawn_sink(&name, &mut new_pieces, rt);
        }
        for name in &diff.sinks.to_add {
            info!("Starting sink {:?}", name);
            self.spawn_sink(&name, &mut new_pieces, rt);
        }
    }
fn spawn_diff ( & mut self , diff : & ConfigDiff , mut new_pieces : Pieces , rt : & mut runtime :: Runtime ) { // Sources for name in & diff . sources . to_change { info ! ( " " name ) ; self . spawn_source ( name , & mut new_pieces , rt ) ; } for name in & diff . sources . to_add { info ! ( " " name ) ; self . spawn_source ( & name , & mut new_pieces , rt ) ; } // Transforms for name in & diff . transforms . to_change { info ! ( " " name ) ; self . spawn_transform ( & name , & mut new_pieces , rt ) ; } for name in & diff . transforms . to_add { info ! ( " " name ) ; self . spawn_transform ( & name , & mut new_pieces , rt ) ; } // Sinks for name in & diff . sinks . to_change { info ! ( " " name ) ; self . spawn_sink ( & name , & mut new_pieces , rt ) ; } for name in & diff . sinks . to_add { info ! ( " " name ) ; self . spawn_sink ( & name , & mut new_pieces , rt ) ; } }
Starts new and changed pieces of topology.
Starts new and changed pieces of topology .
&mut self
diff
&ConfigDiff
new_pieces
Pieces
rt
&mut runtime::Runtime