risingwave_meta::stream

Function validate_sink

source 
pub async fn validate_sink(prost_sink_catalog: &PbSink) -> MetaResult<()>