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
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
b2f2af6871
Merge pull request #13523 from lafirest/fix/oidc
...
fix(oidc): fixed update and callback errors for OIDC
2024-07-26 21:09:11 +08:00
3fae704903
fix(rule engine tester): fix message publish with bridge source in from clause
...
Fixes https://emqx.atlassian.net/browse/EMQX-12762
2024-07-26 09:27:16 -03:00
49b24a3049
fix(oidc): fixed update and callback errors for OIDC
2024-07-26 15:41:22 +08:00
7bf70aaab6
feat(scram): supports ACL rules in `scram_restapi` backend
2024-07-26 14:30:28 +08:00
df1f4fad70
feat(kafka producer): allow dynamic topics from pre-configured topics
...
Fixes https://emqx.atlassian.net/browse/EMQX-12656
2024-07-25 15:33:12 -03:00
39b8cb1789
Merge pull request #13487 from thalesmg/20240715-m-refactor-cluster-link-api
...
feat(cluster link): refactor http api, add status and metrics
2024-07-25 14:51:36 -03:00
33eccb35da
chore: update wolff -> 3.0.2
2024-07-25 14:30:50 -03:00
7631420eef
test: add test case to cover ldap search timeout
2024-07-25 18:43:37 +02:00
8f94e9684c
fix: handle ldap seqrch error
2024-07-25 18:42:09 +02:00
03821c7b49
fix(cluster link metrics): route count metric is cluster-wide
2024-07-25 13:12:08 -03:00
6da71200f3
refactor: improve bookkeeping api
2024-07-25 13:12:08 -03:00
6dbf015c93
refactor: demote hidden config to hardcoded value
2024-07-25 13:12:08 -03:00
30259284d1
chore: namespace metrics by type
2024-07-25 13:12:08 -03:00
87e4e2340d
refactor: better metric and error fold
2024-07-25 13:12:08 -03:00
1925ed2f55
Merge pull request #13507 from lafirest/feat/env_func
...
feat(variform): add a builtin function to get env vars
2024-07-25 22:46:50 +08:00
a45f817f0e
Merge pull request #13515 from lafirest/fix/exclusive
...
fix(exclusive): allow the same client to resubscribe to an existing exclusive topic
2024-07-25 21:26:08 +08:00
79020b2436
feat(variform): add a builtin function to get env vars
2024-07-25 18:50:53 +08:00
141d8144e4
fix(scram): change the name from `scram_http` to `scram_restapi`
2024-07-25 17:01:49 +08:00
117c8197d7
fix(exclusive): allow the same client to resubscribe to an existing exclusive topic
2024-07-25 09:40:15 +08:00
b283a8c1ff
Merge pull request #13505 from thalesmg/20240722-m-rule-conn-deps-part-2
...
feat(rule engine api): add filters options for action and source ids
2024-07-24 16:52:47 -03:00
c728b98e79
Merge pull request #13510 from thalesmg/20240723-r57-fix-jwt-about-to-expire-check
...
fix(jwt): fix grace period for renewal check
2024-07-24 16:52:35 -03:00
dda73651c5
fix(cluster link metrics): use periodic full table scan and gauge to count routes
2024-07-24 16:46:04 -03:00
c31e28153f
Merge pull request #13513 from id/20240724-sync-release-57
...
sync release-57
2024-07-24 20:12:06 +02:00
7829838dc5
feat(cluster link api): add forwarding resource metrics to response
2024-07-24 14:53:57 -03:00
80e035f115
feat(rule engine api): add filters options for action and source ids
...
Fixes https://emqx.atlassian.net/browse/EMQX-12654 (requirement 2)
2024-07-24 13:32:50 -03:00
34f5a886ce
refactor(cluster link api): return erpc errors in status and metrics responses
2024-07-24 12:07:34 -03:00
79db2e6d7f
test: fix flaky test
2024-07-24 11:17:00 -03:00
3e4eeddb78
fix: add missing `resource_type` callback implementations
2024-07-24 10:53:33 -03:00
d2da311416
fix(resource): create undocumented callback
...
Created by https://github.com/emqx/emqx/pull/13449 but not added as a callback.
2024-07-24 10:53:33 -03:00
76e51fa532
fix: correctly use maybe match clause
2024-07-24 10:17:45 -03:00
82bb876de0
docs: improve descriptions
...
Co-authored-by: Andrew Mayorov <encube.ul@gmail.com>
2024-07-24 10:15:01 -03:00
2d507146ab
refactor: change style of case clause
2024-07-24 10:13:48 -03:00
216a6abed9
refactor: rename CRUD functions
2024-07-24 10:11:03 -03:00
ca2d4ad2a0
refactor: move metrics logic to separate module
2024-07-24 10:04:27 -03:00
9a950571d8
Merge pull request #13492 from thalesmg/20240718-m-rules-conn-deps
...
feat: return dependent entities in connectors/actions/sources API
2024-07-24 09:16:00 -03:00
9e65e0d048
Merge pull request #13503 from thalesmg/20240722-r57-resource-manager-hc-interval-startup
...
fix(connector resource): use configuration `resource_opts` for health check interval when starting up
2024-07-24 09:15:47 -03:00
b010efb647
fix(ds): Improve logic of skipstream LTS layout
...
Iterators:
Previously it used timestamp of the next message as a reference. This
won't work well for the upcoming beamformer/beamsplitter feature. This
commit changes the logic so iterators store timestamp of the last seen
message.
Cooked batches:
Cooked batches no longer store index entries. Creation of indexes has
been delegated to commit callback.
2024-07-24 10:32:06 +02:00
606d829256
Merge remote-tracking branch 'upstream/release-57' into 20240724-sync-release-57
2024-07-24 10:28:00 +02:00
c7a7658c7a
Merge pull request #13449 from zhongwencool/resource-log
...
feat: add group/type to resource slog
2024-07-24 14:34:25 +08:00
4d7535df2d
chore: use pgsqsl replace postgresql
2024-07-24 13:49:31 +08:00
8a344a8646
Merge pull request #13504 from lafirest/feat/scram-http
...
feat(authn): added a HTTP backend for the authentication mechanism scram
2024-07-24 10:28:57 +08:00
7374123c5c
fix(jwt): fix grace period for renewal check
2024-07-23 17:25:29 -03:00
9c0f1df8a3
Merge pull request #13506 from thalesmg/20240722-m-peername-sys-events
...
feat: add `peername` to rule events that already have `peerhost`
2024-07-23 09:38:57 -03:00
e7d07ea17c
feat: add resource_type to emqx_resource behaviour
2024-07-23 18:24:28 +08:00
878b218692
feat(authn): added a HTTP backend for the authentication mechanism scram
2024-07-23 16:07:32 +08:00
e74a921d33
chore: compile error
2024-07-23 15:14:42 +08:00
2a58a36e37
chore: add resource tag for log
2024-07-23 15:14:42 +08:00
2bb062d3a3
chore: create_local/5 for emqx_resource_proto_v1
2024-07-23 15:14:42 +08:00
f29988ed8e
chore: add tag to resouce log
2024-07-23 15:14:42 +08:00
e148d903e8
feat: log resource_id
2024-07-23 15:14:42 +08:00
0a04b1ad6e
feat: add group/type to resource slog
2024-07-23 15:14:41 +08:00
cba3f532f8
feat: don't record dry_run log
2024-07-23 15:14:41 +08:00
7bb7b10a31
Merge pull request #13114 from emqx/emqx-relup-gen
...
feat: generate relup tarball, add relup APIs
2024-07-23 15:00:52 +08:00
439abe430b
refactor: remove relup revert callback functions
2024-07-23 11:45:55 +08:00
99e6613713
test(rule events): add test cases for `schema.validation_failed` and `message.transformation_failed` events
2024-07-22 16:31:48 -03:00
d9832252d8
refactor: add namespace to avoid clashes with operations or other resources
2024-07-22 16:04:19 -03:00
6a5849488c
feat(cluster link): add metrics
...
Fixes https://emqx.atlassian.net/browse/EMQX-12627
2024-07-22 16:04:19 -03:00
07cb147d38
fix(cluster link schema): username is not required
2024-07-22 16:04:19 -03:00
ba3cbe02e3
feat(cluster link api): add status to responses
...
Fixes https://emqx.atlassian.net/browse/EMQX-12627
2024-07-22 16:04:19 -03:00
0b1f0db73c
chore(cluster link): refactor HTTP API for CRUD operations
...
Fixes https://emqx.atlassian.net/browse/EMQX-12627
2024-07-22 16:04:19 -03:00
7ca5205f3f
feat: add `peername` to rule events that already have `peerhost`
...
Fixes https://emqx.atlassian.net/browse/EMQX-12342
2024-07-22 16:01:30 -03:00
69f5b6fa6c
chore: hide `enable` fields from docgen
...
Fixes https://emqx.atlassian.net/browse/EMQX-12730
2024-07-22 13:26:53 -03:00
8ae54ac325
fix(connector resource): use configuration `resource_opts` for health check interval when starting up
...
Fixes https://emqx.atlassian.net/browse/EMQX-12738
2024-07-22 11:34:10 -03:00
220fbe8a0a
test: fix flaky test
2024-07-22 09:44:51 -03:00
a2bed1efb8
Merge pull request #13480 from zhongwencool/rule-engine-log-tag
...
feat: Rule engine log tag
2024-07-22 16:47:13 +08:00
Ilya Averyanov