xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add tq header

This commit is contained in:
Liu Jicong 2021-10-18 13:15:42 +08:00
parent 353400ae4c
commit c0dfa6cdd2
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
include/server/vnode/tq/tq.h
View File

@ -103,6 +103,15 @@ int tqCommit(STQ*);
//void* will be replace by a msg type //void* will be replace by a msg type
int tqHandleConsumeMsg(STQ*, tmqConsumeReq* msg); 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 #ifdef __cplusplus
} }
#endif #endif