From c0dfa6cdd28510530510f7fe6caee340c87d13a9 Mon Sep 17 00:00:00 2001
From: Liu Jicong <liujicong@qq.com>
Date: Mon, 18 Oct 2021 13:15:42 +0800
Subject: [PATCH] add tq header

---
 include/server/vnode/tq/tq.h | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/include/server/vnode/tq/tq.h b/include/server/vnode/tq/tq.h
index 6e56e8256f..7cac0e81c4 100644
--- a/include/server/vnode/tq/tq.h
+++ b/include/server/vnode/tq/tq.h
@@ -103,6 +103,15 @@ int tqCommit(STQ*);
 //void* will be replace by a msg type
 int tqHandleConsumeMsg(STQ*, tmqConsumeReq* msg);
 
+int tqOpenTCGroup(STQ*, int64_t topicId, int64_t cgId, int64_t cId);
+int tqCloseTCGroup(STQ*, int64_t topicId, int64_t cgId, int64_t cId);
+int tqMoveOffsetToNext(STQ*, int64_t topicId, int64_t cgId);
+int tqResetOffset(STQ*, int64_t topicId, int64_t cgId, int64_t offset);
+int tqFetchMsg(STQ*, int64_t topicId, int64_t cgId);
+int tqRegisterContext(STQ*, int64_t topicId, int64_t cgId, void* ahandle);
+int tqLaunchQuery(STQ*, int64_t topicId, int64_t cgId, void* query);
+int tqSendLaunchQuery(STQ*, int64_t topicId, int64_t cgId, void* query);
+
 #ifdef __cplusplus
 }
 #endif