add function

include/libs/wal/wal.h

@@ -58,9 +58,9 @@ void     walStop(twalh);
 void     walClose(twalh);
 
 //write
-int64_t  walWriteWithMsgType(twalh, int8_t msgType, void* body, int32_t bodyLen);
+//int64_t  walWriteWithMsgType(twalh, int8_t msgType, void* body, int32_t bodyLen);
 int64_t  walWrite(twalh, void* body, int32_t bodyLen);
-int64_t  walWriteBatch(twalh, void* body, int32_t* bodyLen, int32_t batchSize);
+int64_t  walWriteBatch(twalh, void** bodies, int32_t* bodyLen, int32_t batchSize);
 
 //apis for lifecycle management
 void     walFsync(twalh, bool force);

source/server/vnode/tq/src/tq.c

@@ -59,13 +59,27 @@ int tqOpenTGroup(STQ* pTq, const char* topic, int cgId) {
 /*int tqCloseTCGroup(STQ* pTq, const char* topic, int cgId) {*/
   /*tqGroupHandle* handle = tqLookupGroupHandle(pTq, topic, cgId);*/
   /*return tqCommitTCGroup(handle);*/
-}
+/*}*/
 
 int tqDropTCGroup(STQ* pTq, const char* topic, int cgId) {
   //delete from disk
   return 0;
 }
 
+
+int tqFetchMsg(tqGroupHandle* handle, void* msg) {
+  return 0;
+}
+
+int tqMoveOffsetToNext(tqGroupHandle* handle) {
+  return 0;
+}
+
+
+tqGroupHandle* tqFindGHandleBycId(STQ* pTq, int64_t cId) {
+  return NULL;
+}
+
 int tqPushMsg(STQ* pTq , void* p, int64_t version) {
   //add reference
   //judge and launch new query