451b03ff99
feat(ds): add generic preconditions implementation
2024-08-01 14:26:45 +02:00
f792418a68
Merge pull request #13552 from JimMoen/fix-plugin-app-takes-too-long
...
fix: add a startup timeout limit for the plugin application
2024-08-01 16:46:09 +08:00
15b3f4deb0
fix: rm unused func and exports
2024-08-01 15:00:24 +08:00
7a251c9ead
test: handle frame error for CONNECT packets
2024-08-01 10:26:31 +08:00
37a89d0094
fix: enrich parse_state and connection serialize opts
2024-08-01 10:26:31 +08:00
c313aa89f0
fix: try throw proto_ver and proto_name when parsing CONNECT packet
2024-08-01 10:26:31 +08:00
6db1c0a446
refactor: separate function to handle `frame_error`
2024-08-01 10:26:31 +08:00
a6a9538e73
refactor: move JWT worker and helpers to separate app
...
Some bridge applications might need to use JWTs before the `emqx_connector` is started, so
we must move JWT table initialization to a separate dependency application.
2024-07-31 14:52:12 -03:00
9f97bff7d0
feat: expose `resource_opts.query_mode` for pulsar action
...
Fixes https://emqx.atlassian.net/browse/EMQX-12782
2024-07-31 11:13:11 -03:00
e42021d314
Merge pull request #13554 from id/20240731-sync-release-57
...
sync release-57
2024-07-31 15:48:37 +02:00
08c58cc319
Merge pull request #13543 from thalesmg/20240730-r57-sr-delete-protobuf-cache
...
fix(schema registry): clear protobuf code cache when deleting/updating serdes
2024-07-31 10:16:48 -03:00
150fee87f1
Merge pull request #13541 from thalesmg/20240730-r57-unset-crl-check-listener
...
fix(crl): force remove CRL fields from SSL opts after listener update
2024-07-31 10:16:35 -03:00
85cff5e7eb
fix: merge conflicts
2024-07-31 09:14:29 -03:00
569f48f5a1
fix(mgmt): Return 404 for /ds/ API endpoints when DS is disabled
2024-07-31 13:44:38 +02:00
2cf86e76ee
Merge pull request #13551 from ieQu1/EMQX-12587
...
fix(sessds): Expose durable sessions in the config API
2024-07-31 12:00:26 +02:00
74cef7937d
Merge remote-tracking branch 'upstream/release-57' into 20240731-sync-release-57
2024-07-31 11:31:29 +02:00
c658cfe269
fix: make static_check happy
2024-07-31 17:17:13 +08:00
a246551914
fix: add a startup timeout limit for the plugin application
2024-07-31 17:17:11 +08:00
a23b8266b1
fix(sessds): Expose durable sessions in the config API
2024-07-31 10:18:38 +02:00
d69342a2fc
chore(emqx): Remove ra from the list of EMQX dependencies
2024-07-31 09:56:28 +02:00
e6bfc14cc9
fix: try-catch optional `on_config_changed/2` plugin app callback
2024-07-31 10:09:02 +08:00
3d1f0c756c
feat: call plugin's app module `on_config_changed/2` callback
...
assume the module: `[PluginName]_app`
2024-07-31 10:09:02 +08:00
1c4402b12c
test(clients v2 api): attempt to reduce flakiness
...
https://github.com/emqx/emqx/actions/runs/10161391242/job/28101183920#step:6:331
2024-07-30 14:07:08 -03:00
ebb69f4ebf
fix(crl): force remove crl fields from SSL opts after listener update
...
Fixes https://emqx.atlassian.net/browse/EMQX-12785
2024-07-30 14:00:24 -03:00
fd961f9da7
fix(schema registry): clear protobuf code cache when deleting/updating serde
...
Fixes https://emqx.atlassian.net/browse/EMQX-12789
2024-07-30 13:52:34 -03:00
08f70e4a25
feat(queue): move ds shared sub dependent test to emqx_ds_shared_sub app
2024-07-30 14:19:39 +03:00
e408804efb
feat(queue): fix dialyzer issues
2024-07-30 13:01:48 +03:00
e294d35703
feat(queue): add schema descriptions
2024-07-30 13:01:48 +03:00
303ff95e10
feat(queue): add stub for CRUD API
2024-07-30 13:01:48 +03:00
23f0e88b45
feat(queue): add integration with external broker
2024-07-30 13:01:46 +03:00
f0dd1bc4f4
feat(queue): add shared sub support to the management API
2024-07-30 13:01:20 +03:00
9b30320ddb
feat(queue): simplify progress report on disconnect
2024-07-30 13:01:20 +03:00
cae27293a5
feat(queue): move route registration to sessions
2024-07-30 13:01:19 +03:00
81f4103d60
feat(queue): avoid cyclic dependencies
2024-07-30 13:01:19 +03:00
bab526be24
feat(queue): self-revoke all shared streams on session open
2024-07-30 13:01:19 +03:00
9307a82004
feat(queue): rearrange leader's code
2024-07-30 13:01:19 +03:00
b8e8f7c8e0
feat(queue): add pre_renew_streams callback
2024-07-30 13:01:18 +03:00
a97a0d6400
feat(queue): fix dialyzer issues
2024-07-30 13:01:18 +03:00
8705956cdc
feat(queue): update docs
2024-07-30 13:01:18 +03:00
f213569460
feat(queue): clarify naming; identify shared subs by full topic filter
2024-07-30 13:01:18 +03:00
7e23f8d19f
feat(queue): fix include
2024-07-30 13:01:17 +03:00
a676ede6b8
feat(queue): improve logging
2024-07-30 13:01:17 +03:00
9e5e7a23c5
feat(queue): remove unnecessary acked flag
2024-07-30 13:01:17 +03:00
143086b0ef
feat(queue): replace invalid rewing algorithm with skipping iterator
2024-07-30 13:01:16 +03:00
c569625dd1
feat(queue): handle partially unacked ranges
2024-07-30 13:01:16 +03:00
7daab1ab23
feat(queue): move replay progress to a separate data structure
2024-07-30 13:01:16 +03:00
077ee38530
feat(queue): add config
2024-07-30 13:01:15 +03:00
b74189570d
feat(queue): do not use ee app from emqx app
2024-07-30 13:01:15 +03:00
649cf88042
feat(queue): kick agents that do not return to the replaying state for long
2024-07-30 13:01:15 +03:00
1496f7f778
feat(queue): add leader_rank_progress test
2024-07-30 13:01:15 +03:00
91dd1183ad
feat(queue): fix dialyzer issues
2024-07-30 13:01:14 +03:00
65ab81ff74
feat(queue): fix quick resubscription
2024-07-30 13:01:14 +03:00
53d4cd3174
feat(queue): rename leader' stream_progresses to stream_states
2024-07-30 13:01:14 +03:00
7d004b37da
feat(queue): implement stream finalization
2024-07-30 13:01:13 +03:00
e5547005eb
feat(queue): implement resubscribe test
2024-07-30 13:01:13 +03:00
fada2a3fea
feat(queue): reorganize and document shared subs module
2024-07-30 13:01:13 +03:00
b4a010d63b
feat(queue): implement unsubscribe
2024-07-30 13:01:13 +03:00
9bde981c44
feat(queue): fix static check issues
2024-07-30 13:01:12 +03:00
7658e081c5
feat(queue): move design docs to the EIP
2024-07-30 13:01:12 +03:00
8dce530d15
feat(queue): fix progress reporting and more tests
...
We test reassignment during the intensive replay
2024-07-30 13:01:12 +03:00
a20d262327
feat(queue): send progress before fetching new messages
2024-07-30 13:01:11 +03:00
d32f282feb
feat(queue): add graceful disconnect
2024-07-30 13:01:11 +03:00
1d728a05b2
feat(queue): send metadata with agent when connecting to leader
...
It will be used to attach agent taints to improve stream assignment.
2024-07-30 13:01:11 +03:00
49bff5c08a
feat(queue): wrap remote calls in a proto
2024-07-30 13:01:10 +03:00
61eda0ff31
feat(queue): identify agents by SessionId in tests
2024-07-30 13:01:10 +03:00
8f0d807c00
feat(queue): add new test scenarios
2024-07-30 13:01:10 +03:00
bceb5d43ed
feat(queue): fix stream rebalancing issues, update tests
2024-07-30 13:01:10 +03:00
03fea34962
feat(queue): document protocol between agent and leader
...
Document leader's states
2024-07-30 13:01:09 +03:00
082514f557
feat(queue): implement full protocol between agent and leader
2024-07-30 13:01:09 +03:00
c831f0772f
feat(queue): handle renew_lease_timeout
2024-07-30 13:01:09 +03:00
ca455ad992
Merge pull request #13532 from emqx/sync-release-57-20240729-021938
...
Sync release-57
2024-07-30 10:49:09 +02:00
a49cd78aae
refactor: force getenv to access only OS env with prefix EMQXVAR_
2024-07-29 23:54:00 +02:00
18721d05bc
Merge pull request #13526 from ieQu1/replicant-ee
...
fix(mria): Reserve replicant role for EE only
2024-07-29 22:10:06 +02:00
7f7d0741d2
Merge pull request #13528 from zmstone/0726-unrecoverable-error-limit
...
0726 unrecoverable error limit
2024-07-29 21:32:14 +02:00
2e39c4ad5e
Merge pull request #13495 from thalesmg/20240719-m-hide-enable-fields-mkII
...
chore: hide enable flags from schema and config examples
2024-07-29 21:31:20 +02:00
e08425e67d
refactor(log-throttler): remove unnecessary code
...
there is no need to reset counters before erasing
2024-07-29 20:41:27 +02:00
f6f1d32da0
feat: throttle with resource_id
2024-07-29 20:41:27 +02:00
2924ec582a
feat: add unrecoverable_resource_error throttle
2024-07-29 20:41:27 +02:00
8dc1d1424a
chore: add resource tag for log
2024-07-29 20:41:27 +02:00
693d5dd394
feat: attempt to automatically decode `payload` similar to key and message templates
2024-07-29 13:01:06 -03:00
60aefd1065
Merge pull request #13520 from lafirest/feat/scram-rest-acl
...
feat(scram): supports ACL rules in `scram_restapi` backend
2024-07-29 22:46:50 +08:00
c637422302
Merge pull request #13518 from thalesmg/20240724-r57-dynamic-kprodu-action-mkIII
...
feat(kafka producer): allow dynamic topics (mkIII)
2024-07-29 22:43:20 +08:00
e80d43d14d
test(fix): use ebin path without plugins
...
Without the filtering that already exists in cth:ebin_path, the rebar3 plugins path may
take priority over normal dependencies. Since we just updated hocon, and there seems to
be an older hocon among the rebar3 plugins, it started to break the test because older
hocon was getting loaded in the peer.
2024-07-29 09:50:25 -03:00
b3074144cc
chore: temporarily revert `NO_DOC` changes to fields with default value = false
...
These will be dealt with in follow up PRs, by allowing the parent struct to be set to a
special `disabled` value in such cases.
2024-07-29 09:50:25 -03:00
6786c9b517
refactor: improve descriptions and identifiers
...
Co-authored-by: zmstone <zmstone@gmail.com>
2024-07-29 09:45:52 -03:00
8913de10c0
Merge pull request #13527 from thalesmg/20240726-r57-multiple-froms-sql-test
...
fix(rule engine tester): fix message publish with bridge source in from clause
2024-07-29 09:37:17 -03:00
5ddd7d7a6a
test: superuser skipped all authz check
2024-07-29 17:27:36 +08:00
d7cac74bed
feat: add authz skipped trace
2024-07-29 17:27:36 +08:00
c1e2801f41
Merge remote-tracking branch 'origin/release-57' into sync-release-57-20240729-021938
2024-07-29 02:19:38 +00:00
268f887700
test(mgmt): Disable certain tests on OSS
2024-07-26 20:24:53 +02:00
1d56ac6e5e
refactor: change topic schema type
2024-07-26 14:26:21 -03:00
4e0742c66f
feat: make kafka producer freely dynamic
2024-07-26 14:25:20 -03:00
8c1302f455
test(conf_app): Remove redundand config
2024-07-26 17:25:09 +02:00
b8a2a8ea18
test(router): Skip certain tests on OSS
2024-07-26 17:25:09 +02:00
b7c424a13d
test(persmsg): Remove redundant config
2024-07-26 17:17:06 +02:00
1b6494ab9a
test(mgmt): Remove redundant config
2024-07-26 17:17:06 +02:00
41bf5cd6ca
test(otel): Remove redundant config
2024-07-26 17:17:06 +02:00
548bcceab7
test(auth): Remove redundant config
2024-07-26 17:17:06 +02:00
1beda1cd11
test(mria): Remove role from the example config
2024-07-26 17:17:06 +02:00
9da744c423
fix(mria): Reserve replicant role for EE only
2024-07-26 17:17:06 +02:00
Andrew Mayorov