risingwave_connector::sink::encoder::proto

Function encode_fields

source 
fn encode_fields<'a>(
    fields_with_datums: impl Iterator<Item = ((&'a str, &'a DataType), DatumRef<'a>)>,
    descriptor: &MessageDescriptor,
) -> Result<DynamicMessage, FieldEncodeError>