risingwave_stream::from_proto::source

Function telemetry_source_build

source 
fn telemetry_source_build(
    source_type: &str,
    source_id: &TableId,
    source_info: &PbStreamSourceInfo,
    with_props: &BTreeMap<String, String>,
)