risingwave_meta::manager

Function get_referred_connection_ids_from_sink

Source 
pub fn get_referred_connection_ids_from_sink(sink: &PbSink) -> HashSet<u32>