pub fn frontier_tracking(&self, start: &mut Vec<GlobalId>, cease: &mut Vec<GlobalId>) {
        match self {
            Command::Compute(ComputeCommand::CreateDataflows(dataflows), _instance) => {
                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::Compute(ComputeCommand::DropIndexes(index_ids), _instance) => {
                for id in index_ids.iter() {
                    cease.push(*id);
                }
            }
            Command::Compute(ComputeCommand::DropSinks(sink_ids), _instance) => {
                for id in sink_ids.iter() {
                    cease.push(*id);
                }
            }
            Command::Storage(StorageCommand::AddSourceTimestamping { id, .. }) => {
                start.push(*id);
            }
            Command::Storage(StorageCommand::DropSourceTimestamping { id }) => {
                cease.push(*id);
            }
            Command::Compute(ComputeCommand::CreateInstance(logging), _instance) => {
                if let Some(logging_config) = logging {
                    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::Compute(ComputeCommand::CreateDataflows(dataflows), _instance) => {
                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::Compute(ComputeCommand::DropIndexes(index_ids), _instance) => {
                for id in index_ids.iter() {
                    cease.push(*id);
                }
            }
            Command::Compute(ComputeCommand::DropSinks(sink_ids), _instance) => {
                for id in sink_ids.iter() {
                    cease.push(*id);
                }
            }
            Command::Storage(StorageCommand::AddSourceTimestamping { id, .. }) => {
                start.push(*id);
            }
            Command::Storage(StorageCommand::DropSourceTimestamping { id }) => {
                cease.push(*id);
            }
            Command::Compute(ComputeCommand::CreateInstance(logging), _instance) => {
                if let Some(logging_config) = logging {
                    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 :: Compute ( ComputeCommand :: CreateDataflows ( dataflows ) , _instance ) => { 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 :: Compute ( ComputeCommand :: DropIndexes ( index_ids ) , _instance ) => { for id in index_ids . iter ( ) { cease . push ( * id ) ; } } Command :: Compute ( ComputeCommand :: DropSinks ( sink_ids ) , _instance ) => { for id in sink_ids . iter ( ) { cease . push ( * id ) ; } } Command :: Storage ( StorageCommand :: AddSourceTimestamping { id , .. } ) => { start . push ( * id ) ; } Command :: Storage ( StorageCommand :: DropSourceTimestamping { id } ) => { cease . push ( * id ) ; } Command :: Compute ( ComputeCommand :: CreateInstance ( logging ) , _instance ) => { if let Some ( logging_config ) = logging { 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>