diff options
| author | yangwei <[email protected]> | 2024-01-18 17:46:41 +0800 |
|---|---|---|
| committer | 杨威 <[email protected]> | 2024-01-29 05:52:26 +0000 |
| commit | 656dcf70d214513636df15191de903c7eb0abb91 (patch) | |
| tree | 19657c52efa3dd3d5c01ef47afbfc60f39546d30 /include | |
| parent | ae450151a47f4fc9ab34263b55a12d6133642037 (diff) | |
✨ feat(session_mq_ignore_message): code implementation
Diffstat (limited to 'include')
| -rw-r--r-- | include/stellar/stellar.h | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/include/stellar/stellar.h b/include/stellar/stellar.h index 9751d93..c10c8ec 100644 --- a/include/stellar/stellar.h +++ b/include/stellar/stellar.h @@ -7,6 +7,10 @@ struct stellar; int stellar_get_worker_thread_num(struct stellar *st); int stellar_get_current_thread_id(struct stellar *st); +int stellar_get_session_mq_topic_cnt(struct stellar *st); +int stellar_get_session_mq_subscriber_cnt(struct stellar *st, int topic_id); + + typedef void *plugin_init_callback(struct stellar *st); typedef void plugin_exit_callback(void *plugin_ctx); |