risingwave_connector::sink::encoder::proto

Function validate_fields

Source 
fn validate_fields<'a>(
    fields: impl Iterator<Item = (&'a str, &'a DataType)>,
    descriptor: &MessageDescriptor,
) -> Result<(), FieldEncodeError>