New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Support handle msgs from external in HOOK_WAIT state. #1572
Conversation
wanghaEMQ
commented
Dec 21, 2023
- handle msgs from external in HOOK_WAIT state.
- Support read key and offset from json from external.
- Support forward msgs or parquet filename to local broker to active handler.
Signed-off-by: wanghaemq <wangwei@emqx.io>
Signed-off-by: wanghaemq <wangwei@emqx.io>
Signed-off-by: wanghaemq <wangwei@emqx.io>
Signed-off-by: wanghaemq <wangwei@emqx.io>
Signed-off-by: wanghaemq <wangwei@emqx.io>
Codecov ReportAttention:
Additional details and impacted files@@ Coverage Diff @@
## master #1572 +/- ##
==========================================
- Coverage 57.00% 56.43% -0.57%
==========================================
Files 18 18
Lines 6663 6753 +90
==========================================
+ Hits 3798 3811 +13
- Misses 2865 2942 +77 ☔ View full report in Codecov by Sentry. |
* NEW [hook] Support search parquet and send files with mqtt. Signed-off-by: wanghaemq <wangwei@emqx.io>
|
||
for (i = 0; i < conf->web_hook.pool_size; i++) { | ||
works[i] = alloc_work(sock, &conf->web_hook, &conf->exchange); | ||
works[i]->id = i; | ||
works[i]->mqtt_sock = &mqtt_sock; |
Check warning
Code scanning / CodeQL
Local variable address stored in non-local memory Warning
source
…are matched. Signed-off-by: wanghaemq <wangwei@emqx.io>
Signed-off-by: wanghaemq <wangwei@emqx.io>
* FIX [hook] Fix the wrong filenames in json. Signed-off-by: wanghaemq <wangwei@emqx.io>
Signed-off-by: wanghaemq <wangwei@emqx.io>
Signed-off-by: wanghaemq <wangwei@emqx.io>
Signed-off-by: wanghaemq <wangwei@emqx.io>
Signed-off-by: wanghaemq <wangwei@emqx.io>
Signed-off-by: wanghaemq <wangwei@emqx.io>
Signed-off-by: jaylin <jaylin@emqx.io>
be aware that searching result could lay in both MQ and parquet file @wanghaEMQ |