Commit Graph

76 Commits

Author SHA1 Message Date
Thales Macedo Garitezi 08ef2c7b8b test(retainer): extend test suite for usage by other backends
Part of https://emqx.atlassian.net/browse/EMQX-11922
2024-03-01 17:27:15 -03:00
Ilya Averyanov dfdf7455d3 feat(retainer): make additional implementations pluggable
Co-authored-by: Thales Macedo Garitezi <thalesmg@gmail.com>
2024-02-28 18:43:17 +03:00
Ilya Averyanov d94066a10a chore(retainer): refactor types; remove hotwiring to builtin config 2024-02-28 18:43:16 +03:00
Zaiming (Stone) Shi 46877e979b chore: update copyright-year 2024-02-23 08:21:06 +01:00
Andrew Mayorov 21780e2126
feat(emqx-conf): manage mria tables explicitly during startup 2024-02-13 20:36:21 +01:00
Ilya Averyanov 90fd2b26d3 feat(banned): allow ban by clientid/username regexps, peerhost cidrs 2024-02-10 17:59:22 +03:00
Ivan Dyachkov fa6d65887d test(retainer): fix test cases 2024-01-29 08:42:36 +01:00
Ilya Averyanov 4c66a1135b
Merge pull request #12303 from savonarola/0111-fix-indexing
fix(retainer): fix topic search by index
2024-01-11 18:44:56 +02:00
Ilya Averyanov 09d524144b fix(retainer): fix topic search by index 2024-01-11 16:00:58 +03:00
firest f896cf2f4f fix(retain): add `hasnext` into the meta data for the `GET /retain/messages` 2024-01-11 16:14:40 +08:00
firest c180325e0a feat(retain): add two new endpoints for retain API 2024-01-08 19:11:43 +08:00
Zaiming (Stone) Shi d9f964a44f test: fix test cases after schema type namespace change 2023-11-22 16:58:05 +01:00
zhongwencool f4a88f717b feat: support retainer Start Length command 2023-10-11 11:47:37 +08:00
Paulo Zulato a85c948e23 feat(gcp-iot): port GCP IoT Core compatibility layer from e4.4
Fixes https://emqx.atlassian.net/browse/EMQX-10341
2023-08-09 10:48:25 -03:00
Stefan Strigler 1110b5d8f5 fix(emqx_retainer): return 404 in delete if topic not found 2023-07-08 14:43:43 +02:00
firest 6fedd0328f fix(retainer): Fix missing changes in configuration 2023-06-29 14:06:17 +08:00
zhongwencool 07172e42f0 test: integer CI check failed 2023-06-20 08:39:23 +08:00
firest 03c7b84e89 feat(retainer): add a field `deliver_rate` to limit the maximum delivery rate 2023-05-31 09:44:25 +08:00
firest 02f8d073f8 test(limiter): fix test errors and make spellcheck happy 2023-04-17 10:06:43 +08:00
Stefan Strigler 062ce5f819 refactor: rename emqx_map_lib to emqx_utils_maps 2023-04-14 13:41:34 +02:00
Stefan Strigler f8e9e54393 refactor: move emqx_json to emqx_utils_json 2023-04-14 13:31:27 +02:00
firest 908ac8d948 fix: speed up banned test cases 2023-01-26 13:04:55 +08:00
Thales Macedo Garitezi 51ad27cb4b test(retainer): assert that retained messages are not lost when changing storage type 2023-01-04 13:52:52 -03:00
Thales Macedo Garitezi 2f13bfd452 fix(retainer): change mnesia table storage types during update
https://emqx.atlassian.net/browse/EMQX-8650
2023-01-04 13:52:52 -03:00
Zaiming (Stone) Shi dbc10c2eed chore: update copyright year 2023 2023-01-02 09:22:27 +01:00
Ilya Averyanov 7ae3ecfccb chore(retainer): optimize index writes 2022-12-09 14:42:43 +03:00
firest 085074ac41 feat(banned): kick session when it is banned by clientid 2022-11-16 18:00:22 +08:00
firest 4290847b9d feat: filter out messages which the source client is banned when delivering the retained message 2022-11-10 10:21:21 +08:00
firest ebaba0c2b1 fix: Revert "feat(banned): clean retained/delayed data when client is banned"
This reverts commit 69701ff578.
2022-11-08 11:36:11 +08:00
firest 69701ff578 feat(banned): clean retained/delayed data when client is banned 2022-10-18 13:35:09 +08:00
firest 1a835e9bd4 test(retainer): add test case for start after retianer is disabled 2022-09-08 19:13:02 +08:00
firest d3f965dfe7 refactor(limiter): refactor the user interface 2022-07-20 13:57:31 +08:00
firest 7bc9f0af0f fix(retainer): fix test case error 2022-06-17 11:09:06 +08:00
ieQu1 9ca2e3bc2a feat(retainer): CLI to list and clean retained messages 2022-06-14 11:24:15 +02:00
Ilya Averyanov 4e76797927 fix(retainer): add additional test 2022-06-10 12:33:27 +03:00
ieQu1 8ff9a03df3 fix(retainer): Handle zero-length topic levels 2022-06-09 13:46:56 +02:00
firest 89de8274a0 test(retainer): fix flow control test case error 2022-05-24 12:44:47 +08:00
Thales Macedo Garitezi 9e706fc76d
feat(telemetry): count advanced mqtt feature usage
Originally, we wanted to just check if certain features were enabled.
Now, we want to count certain usage metrics for them.
2022-05-11 15:15:17 -03:00
firest 1355f7c887 fix(retainer): fix test case and xref error 2022-05-07 17:01:51 +08:00
JimMoen 041ea4ba5c test(retainer): retainer api page read 2022-05-05 20:33:39 +08:00
Ilya Averyanov 9b61997dc0 feat(retainer): add topic indexing 2022-04-20 19:55:57 +03:00
firest f1acfece6b chore(retainer): reformat retainer codes 2022-04-19 10:41:54 +08:00
firest beba7c9692 fix(limiter): improve code style and description 2022-03-18 16:00:42 +08:00
firest d28b34f0d1 fix(limiter): improve test case and fix some bugs 2022-03-18 16:00:42 +08:00
Zaiming (Stone) Shi d9ebca3294 test: fix emqx_retainer_api_SUITE infinity wait for table 2022-03-15 20:40:28 +01:00
Ilya Averyanov b3193181b2 chore(retainer): fix mqtt_v5 test suite 2022-03-15 12:55:02 +03:00
lafirest 3601d147e4 test(retainer): fix the flaky case 2022-03-09 10:12:49 +08:00
lafirest c6385762c6 test(retainer): improve test coverage from 63% to 92% 2022-03-04 15:24:08 +08:00
lafirest 9bdebabdbc fix(retainer): fix/add some comment 2022-03-02 11:34:19 +08:00
firest 19d4dabd04 fix(emqx_retainer): fix test case error 2022-02-25 10:08:44 +08:00