Skip to main content

extract_throttle_config

risingwave_meta::barrier::command

Function extract_throttle_config 

Source 
pub(crate) fn extract_throttle_config(
    config: &mut HashMap<FragmentId, (ThrottleConfig, PbStreamNode)>,
    apply: impl FnMut(FragmentId, &PbStreamNode) -> bool,
) -> Option<Mutation>