feat(tmq): new message type RAWDATA

Author: zitsen

taos-optin/src/raw/mod.rs

@@ -1479,7 +1479,7 @@ impl RawRes {
 
                         Some(raw)
                     }
-                    tmq_res_t::TMQ_RES_TABLE_META => {
+                    _ => {
                         todo!()
                     }
                 }

taos-optin/src/tmq/mod.rs

@@ -384,6 +384,8 @@ impl From<RawRes> for MessageSet<Meta, Data> {
             tmq_res_t::TMQ_RES_DATA => Self::Data(Data::new(raw)),
             tmq_res_t::TMQ_RES_TABLE_META => Self::Meta(Meta::new(raw)),
             tmq_res_t::TMQ_RES_METADATA => Self::MetaData(Meta::new(raw.clone()), Data::new(raw)),
+            // TODO: New variant RAWDATA since 3.3.6.0
+            _ => Self::MetaData(Meta::new(raw.clone()), Data::new(raw)),
         }
     }
 }
@@ -432,6 +434,11 @@ impl AsConsumer for Consumer {
                         Meta::new(raw.clone()),
                         Data::new(raw),
                     ),
+                    // TODO: New variant RAWDATA since 3.3.6.0
+                    _ => taos_query::tmq::MessageSet::MetaData(
+                        Meta::new(raw.clone()),
+                        Data::new(raw),
+                    ),
                 },
             )
         }))
@@ -567,7 +574,9 @@ impl AsAsyncConsumer for Consumer {
                             tmq_res_t::TMQ_RES_INVALID => unreachable!(),
                             tmq_res_t::TMQ_RES_DATA => MessageSet::Data(Data::new(raw)),
                             tmq_res_t::TMQ_RES_TABLE_META => MessageSet::Meta(Meta::new(raw)),
-                            tmq_res_t::TMQ_RES_METADATA => MessageSet::MetaData(Meta::new(raw.clone()), Data::new(raw))
+                            tmq_res_t::TMQ_RES_METADATA => MessageSet::MetaData(Meta::new(raw.clone()), Data::new(raw)),
+                            // TODO: New variant RAWDATA since 3.3.6.0
+                            _ => MessageSet::MetaData(Meta::new(raw.clone()), Data::new(raw)),
                         },
                     )
                 });

taos-optin/src/types/tmq.rs

@@ -90,9 +90,11 @@ pub type tmq_commit_cb =
 #[repr(C)]
 #[derive(Debug, PartialEq, Eq, Clone, Copy)]
 #[allow(dead_code)]
+#[non_exhaustive]
 pub enum tmq_res_t {
     TMQ_RES_INVALID = -1,
     TMQ_RES_DATA = 1,
     TMQ_RES_TABLE_META = 2,
     TMQ_RES_METADATA = 3,
+    TMQ_RES_RAWDATA = 4,
 }