yuanbiao/emqx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
20,433 Commits 393 Branches 684 Tags 74 MiB
c90f4f5794
Commit Graph

20433 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Kjell Winblad
c90f4f5794 fix(DynamoDB connector): fix error in status check when no workers 2024-03-12 17:22:22 +01:00
Kjell Winblad
91514f3ace refactor: clean up over complicated code 
This commit cleans up overly complicated code and handles
the case when the worker pool is empty.

Thank you @thalesmg for suggesting this change.

Co-authored-by: Thales Macedo Garitezi <thalesmg@gmail.com>
 2024-03-12 10:22:29 +01:00
Kjell Winblad
29e0ddefbc docs: add change log entry 2024-03-12 10:22:19 +01:00
Kjell Winblad
1d1cdc1009 fix: return error reason from dynamo connector status check 
Fixes:
https://emqx.atlassian.net/browse/EMQX-11934
 2024-03-12 10:22:08 +01:00
JianBo He
f24a76e770
Merge pull request #12668 from emqx/leap-year-bug-sql-fun 
fix: port the changes for date_to_unix_ts SQL fun from 4.4
 2024-03-12 10:48:31 +08:00
Andrew Mayorov
d725206bcb
Merge pull request #12624 from keynslug/fix/EMQX-11901/ds-error-class 
feat(sessds): handle recoverable errors during replay
 2024-03-11 12:41:45 +01:00
SergeTupchiy
b673ad3e5c
Merge pull request #12673 from zmstone/0308-fix-base64-compatibility-on-otp25 
fix(mgmt): avoid using base64:decode/2 and encode/2
 2024-03-11 13:23:37 +02:00
Serge Tupchii
980a4c3a4d fix(emqx_mgmt_api): use emqx_utils:bin_to_hexstr/2 2024-03-11 10:40:19 +02:00
Serge Tupchii
f376aa8072 refactor(emqx_mgmt_api_clients): remove unnecessary function 2024-03-11 10:39:09 +02:00
zmstone
2cc1c563df fix(mgmt): avoid using base64:decode/2 and encode/2 
they are not available in otp 25
 2024-03-08 16:46:54 +01:00
Thales Macedo Garitezi
79d7821222
Merge pull request #12655 from thalesmg/fix-kconsu-status-r56-20240306 
fix(kafka_consumer): check client connectivity
 2024-03-08 10:53:44 -03:00
Shawn
29111a2192 fix: dialyzer problems 2024-03-08 14:25:19 +08:00
Shawn
163d095dca fix: port the changes for date_to_unix_ts SQL fun from 4.4 2024-03-08 10:48:08 +08:00
Thales Macedo Garitezi
963e0de0c3 fix(kafka_consumer): check client connectivity 
Fixes https://emqx.atlassian.net/browse/EMQX-11945
 2024-03-07 14:22:03 -03:00
Andrew Mayorov
f7e3afde16
test(ds): avoid introducing new macros 2024-03-07 16:49:20 +01:00
Andrew Mayorov
69427dc42d
test(ds): add tests for error mapping and replay recovery 2024-03-07 12:59:58 +01:00
Andrew Mayorov
e7e8771277
fix(sessds): set replay retry timer if initial replay/3 fails 2024-03-07 12:59:58 +01:00
Andrew Mayorov
09905d78cd
chore(ds): make error handling slightly simpler 
Co-Authored-By: Thales Macedo Garitezi <thalesmg@gmail.com>
 2024-03-07 12:59:57 +01:00
Andrew Mayorov
b604c3dbd4
refactor(sessds): make replay error handling a bit more clear 
Also leave a forgotten TODO.
 2024-03-07 12:59:57 +01:00
Andrew Mayorov
3f3e33b2cb
fix(sessds): untangle pull and replay retry timers 
And restore the convention that timer handler always manages only
its own timers.
 2024-03-07 12:59:57 +01:00
Andrew Mayorov
b39c710ec2
fix(ds): tidy up few typespecs 2024-03-07 12:59:57 +01:00
Andrew Mayorov
1cf672e78d
feat(sessds): handle recoverable errors during replay 2024-03-07 12:59:57 +01:00
Andrew Mayorov
2146d9e1fe
feat(ds): introduce error classes in critical API functions 
For now, only recoverable / unrecoverable errors are introduced.
 2024-03-07 12:59:57 +01:00
SergeTupchiy
1f38813cb9
Merge pull request #12561 from SergeTupchiy/EMQX-11861-client-mqueue-inflight-API 
feat: add client mqueue/inflight messages API
 2024-03-07 13:20:31 +02:00
Serge Tupchii
a2e761681e feat: add client mqueue/inflight messages API 2024-03-07 12:06:49 +02:00
zmstone
6a2731f2da Merge remote-tracking branch 'origin/master' into release-56 2024-03-07 09:36:37 +01:00
Zaiming (Stone) Shi
98034cb4dd
Merge pull request #12660 from zmstone/sync-5.5.1 
Sync 5.5.1
 2024-03-07 09:36:08 +01:00
Thales Macedo Garitezi
c62dd56a4a
Merge pull request #12661 from thalesmg/ds-atomic-store-m-20240305 
feat(ds): add atomic store API
 2024-03-06 17:48:28 -03:00
zmstone
f57f2fa1b7 chore: bump app version numbers 2024-03-06 19:37:06 +01:00
Thales Macedo Garitezi
df3ebc5c56
Merge pull request #12659 from thalesmg/test-flaky-pulsar-r56-20240306 
test(pulsar): fix flaky test
 2024-03-06 15:29:01 -03:00
Thales Macedo Garitezi
b421363661
Merge pull request #12656 from thalesmg/fix-gprodu-status-r56-20240306 
fix(gcp_pubsub_producer): check for topic existence when creating action
 2024-03-06 15:28:51 -03:00
Thales Macedo Garitezi
5d87d400f4 feat(ds): add atomic store API 
Part of https://emqx.atlassian.net/browse/EMQX-11841
 2024-03-06 15:24:14 -03:00
Thales Macedo Garitezi
78b8eb9a1b
Merge pull request #12658 from thalesmg/test-flaky-elasticsearch-r56-20240306 
test(elastic_search): fix flaky test (r56)
 2024-03-06 14:24:20 -03:00
zmstone
9cbeb3720a Merge remote-tracking branch 'origin/release-55' into sync-5.5.1 2024-03-06 17:55:14 +01:00
Thales Macedo Garitezi
dc16e59f2c fix(gcp_pubsub_producer): check for topic existence when creating action 
Fixes https://emqx.atlassian.net/browse/EMQX-11949
 2024-03-06 13:43:50 -03:00
zmstone
e99546e009 Merge remote-tracking branch 'origin/release-56' into sync-5.5.1 2024-03-06 17:27:54 +01:00
Thales Macedo Garitezi
eacd803a37 test(pulsar): fix flaky test 2024-03-06 12:07:02 -03:00
Thales Macedo Garitezi
fd7eacb953 test(elastic_search): fix flaky test 2024-03-06 11:38:22 -03:00
Kjell Winblad
78d5f76f70
Merge pull request #12652 from kjellwinblad/kjell/rule_engine/fix/subbits/EMQX-11942 
fix: add subbits/4 and subits/5 rule_engine functions
 2024-03-06 15:20:30 +01:00
Zaiming (Stone) Shi
fc8b5d4522
Merge pull request #12646 from zmstone/0304-rule-engin-func-fix-zone-shift-in-date-string-parse 
fix(rule_func): time zone shift at wrong precision
 2024-03-06 13:22:30 +01:00
zmstone
58be029ead chore: bump version to 5.5.1 2024-03-06 09:50:13 +01:00
JianBo He
f1e9da9048
Merge pull request #12604 from thalesmg/test-gcp-consu-tm-m-20240227 
test(gcp_pubsub_consumer): add test case for updating topic when there is a topic mapping
 2024-03-06 09:13:41 +08:00
JianBo He
1737df05c7
Merge pull request #12641 from zmstone/0304-improve-text-log-formatter 
0304 improve text log formatter
 2024-03-06 09:12:18 +08:00
Kjell Winblad
8cf681ad3b
Merge pull request #12639 from kjellwinblad/kjell/fix_flaky_test_case/emqx_broker_SUITE.connected_client_count_group.quic.t_connected_client_count_transient_takeover 
test(emqx_broker_SUITE): fix flaky test case
 2024-03-05 18:02:07 +01:00
Ilya Averyanov
3285edc004
Merge pull request #12650 from savonarola/0305-refine-retainer-readme 
chore(retainer): actualize README
 2024-03-05 18:57:02 +02:00
Thales Macedo Garitezi
3ce8dcaa3f
Merge pull request #12643 from thalesmg/test-flaky-elasticsearch-m-20240304 
test(elastic_search): fix flaky test
 2024-03-05 13:53:42 -03:00
Kjell Winblad
f0aecaf16f docs: add changelog text for new rule engine subbits functions 2024-03-05 17:15:04 +01:00
Thales Macedo Garitezi
24cb45a643 test(elastic_search): fix flaky test 2024-03-05 11:29:49 -03:00
Thales Macedo Garitezi
69dcc69761
Merge pull request #12640 from thalesmg/sync-r56-m-20240304 
sync `release-56` to `master`
 2024-03-05 10:44:28 -03:00
Kjell Winblad
365d054e01 fix: add subbits/4 and subits/5 rule_engine functions 
The documentation for the family of subbits functions says that the
fifth and sixth parameters are optional (since they only make sense when
the forth parameter is 'integer'). However, before this commit
`subbits/4` and `subbits/5` did not exist.

Fixes:
https://emqx.atlassian.net/browse/EMQX-11942
https://github.com/emqx/emqx/issues/12587
 2024-03-05 13:27:07 +01:00