pub fn frontier_tracking(&self, start: &mut Vec<GlobalId>, cease: &mut Vec<GlobalId>) {
        match self {
            Command::CreateDataflows(dataflows) => {
                for dataflow in dataflows.iter() {
                    for (sink_id, _) in dataflow.sink_exports.iter() {
                        start.push(*sink_id)
                    }
                    for (index_id, _, _) in dataflow.index_exports.iter() {
                        start.push(*index_id);
                    }
                }
            }
            Command::DropIndexes(index_ids) => {
                for id in index_ids.iter() {
                    cease.push(*id);
                }
            }
            Command::DropSinks(sink_ids) => {
                for id in sink_ids.iter() {
                    cease.push(*id);
                }
            }
            Command::AddSourceTimestamping { id, .. } => {
                start.push(*id);
            }
            Command::DropSourceTimestamping { id } => {
                cease.push(*id);
            }
            Command::EnableLogging(logging_config) => {
                start.extend(logging_config.log_identifiers());
            }
            _ => {
                // Other commands have no known impact on frontier tracking.
            }
        }
    }
/// Indicates which global ids should start and cease frontier tracking.
///
/// Identifiers added to `start` will install frontier tracking, and indentifiers
/// added to `cease` will uninstall frontier tracking.
Indicates which global ids should start and cease frontier tracking.
Identifiers added to `start` will install frontier tracking, and indentifiers
added to `cease` will uninstall frontier tracking.
Indicates which global ids should start and cease frontier tracking . Identifiers added to ` start ` will install frontier tracking and indentifiers added to ` cease ` will uninstall frontier tracking .
pub fn frontier_tracking(&self, start: &mut Vec<GlobalId>, cease: &mut Vec<GlobalId>) {
        match self {
            Command::CreateDataflows(dataflows) => {
                for dataflow in dataflows.iter() {
                    for (sink_id, _) in dataflow.sink_exports.iter() {
                        start.push(*sink_id)
                    }
                    for (index_id, _, _) in dataflow.index_exports.iter() {
                        start.push(*index_id);
                    }
                }
            }
            Command::DropIndexes(index_ids) => {
                for id in index_ids.iter() {
                    cease.push(*id);
                }
            }
            Command::DropSinks(sink_ids) => {
                for id in sink_ids.iter() {
                    cease.push(*id);
                }
            }
            Command::AddSourceTimestamping { id, .. } => {
                start.push(*id);
            }
            Command::DropSourceTimestamping { id } => {
                cease.push(*id);
            }
            Command::EnableLogging(logging_config) => {
                start.extend(logging_config.log_identifiers());
            }
            _ => {
                // Other commands have no known impact on frontier tracking.
            }
        }
    }
pub fn frontier_tracking ( & self , start : & mut Vec < GlobalId > , cease : & mut Vec < GlobalId > ) { match self { Command :: CreateDataflows ( dataflows ) => { for dataflow in dataflows . iter ( ) { for ( sink_id , _ ) in dataflow . sink_exports . iter ( ) { start . push ( * sink_id ) } for ( index_id , _ , _ ) in dataflow . index_exports . iter ( ) { start . push ( * index_id ) ; } } } Command :: DropIndexes ( index_ids ) => { for id in index_ids . iter ( ) { cease . push ( * id ) ; } } Command :: DropSinks ( sink_ids ) => { for id in sink_ids . iter ( ) { cease . push ( * id ) ; } } Command :: AddSourceTimestamping { id , .. } => { start . push ( * id ) ; } Command :: DropSourceTimestamping { id } => { cease . push ( * id ) ; } Command :: EnableLogging ( logging_config ) => { start . extend ( logging_config . log_identifiers ( ) ) ; } _ => { // Other commands have no known impact on frontier tracking. } } }
Indicates which global ids should start and cease frontier tracking.
Indicates which global ids should start and cease frontier tracking .
&self
start
&mut Vec<GlobalId>
cease
&mut Vec<GlobalId>
&self
start
&mut Vec<GlobalId>
cease
&mut Vec<GlobalId>