risingwave_stream::from_proto::sink

Function telemetry_sink_build

source
fn telemetry_sink_build(
    sink_id: &SinkId,
    connector_name: &str,
    sink_format_desc: &Option<SinkFormatDesc>,
)