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

20859 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
zmstone
4f71c97854 docs: add changelog for PR #12750 2024-03-23 10:16:02 +01:00
zmstone
c75840306b fix: restrict client_attr key and value string format 
The keys and values are used to render templates for
authz rules, such as topic names, and SQL statements etc.
 2024-03-23 10:16:02 +01:00
zmstone
9ec99fef4a feat: allow client_attr used in authz rules 2024-03-23 10:16:02 +01:00
zmstone
e5816f5a13 refactor: rename attr to client_attr 
client_attr is unique enough for all contexts
so the name can be unified from external responses
to internal template rendering, and rule-engine template rendering
 2024-03-23 10:16:02 +01:00
zmstone
cc4805b1ac feat: extract attrs field from http and jwt auth response 2024-03-23 10:16:02 +01:00
zmstone
f9d51484cc feat: introuce attrs field in clientinfo 
the 'attrs' field is to be used as extra attributes extracted
from various client properties
for example, HTTP auth result can return an extra client_attributes
field in the result which will get merged into the original
attrs field in clientinfo
 2024-03-23 10:16:02 +01:00
Thales Macedo Garitezi
303d0ed81b test: attempt to fix flaky test 2024-03-22 16:29:00 -03:00
SergeTupchiy
70378052dd
Merge pull request #12769 from SergeTupchiy/EMQX-12058-handle-client-shutdown-errors 
fix:(emqx_mgmt): handle client shutdown errors in call_client
 2024-03-22 17:43:57 +02:00
Ivan Dyachkov
0210f83f06 chore: update changelog 2024-03-22 16:36:45 +01:00
Andrew Mayorov
cbc84900b2
chore: update bpapi versions dump 2024-03-22 16:24:52 +01:00
Ivan Dyachkov
9986de49d1 chore: make dyalizer happy 2024-03-22 16:16:49 +01:00
Ivan Dyachkov
be1886fb91 chore: make dyalizer happy and update changelog 2024-03-22 15:56:44 +01:00
Serge Tupchii
ed0b5ac939 fix(emqx_mgmt): handle client shutdown errors in call_client 
The client process may be shutdown normally during/shortly before the call.
 2024-03-22 16:47:02 +02:00
Andrew Mayorov
a0f500d1d0
chore: add changelog entry 2024-03-22 15:21:03 +01:00
Andrew Mayorov
b81a11b790
chore(routing): mark function that is now an RPC target 2024-03-22 15:14:53 +01:00
Andrew Mayorov
ba276d807f
fix(routing): add heuristic for routing schema in empty cluster 
When the cluster is empty but comprised of different versions of EMQX,
try to additionally ask the cluster nodes for the routing schema in use,
to be able to make more informed decisions.
 2024-03-22 15:14:32 +01:00
Thales Macedo Garitezi
1218176e09
Merge pull request #12767 from thalesmg/fix-older-kafka-migration-r56-20240322 
fix(kafka_producer): handle ancient v1 config when migrating to actions
 2024-03-22 11:01:48 -03:00
Thales Macedo Garitezi
bc5775a988 fix(kafka_producer): handle ancient v1 config when migrating to actions 
Fixes https://emqx.atlassian.net/browse/EMQX-12064
 2024-03-22 09:45:27 -03:00
SergeTupchiy
8e979d511c
Merge pull request #12766 from SergeTupchiy/EMQX-12058-improve-force-shutdown-error-reason 
chore: rename `message_queue_too_long` to `mailbox_overflow`
 2024-03-22 14:32:06 +02:00
Serge Tupchii
d2a1a7f7cf chore: rename message_queue_too_long error reason to mailbox_overflow 
`mailbox_overflow` is consistent with the corresponding config parameter:
 'force_shutdown.max_mailbox_size'
 2024-03-22 12:20:20 +02:00
JimMoen
42faffc320
refactor: uniform shared_sub table macros 2024-03-22 18:03:13 +08:00
SergeTupchiy
c2ace30318
Merge pull request #12763 from SergeTupchiy/EMQX-1206-ds-mqueue-inflight-api-not-implemented 
fix: return not_implemented error for mqueue/inflight msgs queries
 2024-03-22 11:43:53 +02:00
zhongwencool
45eedbb9c6 fix: bpapi undef on old node 2024-03-22 17:02:09 +08:00
Kjell Winblad
2b684c7bcc fix(emqx_connector_info): refactoring based on thalesmg's comments 2024-03-22 09:29:26 +01:00
Serge Tupchii
5d77e1b01e fix: return not_implemented error for mqueue/inflight msgs queries 2024-03-22 10:02:31 +02:00
JimMoen
9b085b5797
fix(api_schema): removed metrics schema in api spec 
- Followup [PR#6622](https://github.com/emqx/emqx/pull/6622).
 2024-03-22 10:57:14 +08:00
Thales Macedo Garitezi
23ad37f566
Merge pull request #12762 from thalesmg/ds-fix-sync-egress-reply-m-20240321 
fix(ds): add caller to pending replies before flushing and reply failures to sync callers
 2024-03-21 16:42:42 -03:00
Thales Macedo Garitezi
cfd4a1297f
Merge pull request #12761 from thalesmg/test-fix-flaky-dash-mon-m-20240321 
test: fix flaky test
 2024-03-21 16:04:08 -03:00
Thales Macedo Garitezi
e17f663fa5
Merge pull request #12749 from thalesmg/mv-followup1-m-20240320 
Follow up features and fixes for message validation - part 1
 2024-03-21 16:03:49 -03:00
Thales Macedo Garitezi
796c04e7a8 test: fix flaky test 
We should emit the trace event before replying to callers.

Example failure:

https://github.com/emqx/emqx/actions/runs/8378977952/job/22946318696#step:6:182

```
 =CRITICAL REPORT==== 21-Mar-2024::17:45:37.676024 ===
"check stage" failed: error
{assertMatch,[{module,emqx_ds_storage_bitfield_lts_SUITE},
              {line,270},
              {expression,"? of_kind ( emqx_ds_replication_layer_egress_flush , Trace )"},
              {pattern,"[ # { batch := [ _ , _ , _ ] } ]"},
              {value,[]}]}
Stacktrace: [{emqx_ds_storage_bitfield_lts_SUITE,
                 '-t_atomic_store_batch/1-fun-1-',1,
                 [{file,
                      "/__w/emqx/emqx/apps/emqx_durable_storage/test/emqx_ds_storage_bitfield_lts_SUITE.erl"},
                  {line,270}]},
             {emqx_ds_storage_bitfield_lts_SUITE,t_atomic_store_batch,1,
                 [{file,
                      "/__w/emqx/emqx/apps/emqx_durable_storage/test/emqx_ds_storage_bitfield_lts_SUITE.erl"},
                  {line,249}]}]
```
 2024-03-21 15:47:29 -03:00
Ivan Dyachkov
dda630ccbd
Merge pull request #12760 from id/0321-cut-5.6.0-rc.3 
5.6.0-rc.3
 2024-03-21 19:43:13 +01:00
Thales Macedo Garitezi
68af211130 fix(ds): reply sync callers after raft store failure 2024-03-21 15:40:21 -03:00
Thales Macedo Garitezi
70737a437a fix(ds): add caller to pending replies before flushing 2024-03-21 14:39:21 -03:00
Ivan Dyachkov
93c80bc912 chore: 5.6.0-rc.3 2024-03-21 18:10:59 +01:00
Thales Macedo Garitezi
fa7ec231e3 test: fix flaky test 2024-03-21 14:07:09 -03:00
SergeTupchiy
e2a2295c99
Merge pull request #12759 from SergeTupchiy/EMQX-11808-remove-uploaded-invalid-backups 
fix(emqx_mgmt_data_backup): remove invalid uploaded backup files
 2024-03-21 18:58:48 +02:00
Thales Macedo Garitezi
00aa7b5621 feat: create new message.validation_failed hookpoint and rule engine event 2024-03-21 13:46:27 -03:00
Thales Macedo Garitezi
7d7c6685d4
Merge pull request #12753 from thalesmg/test-flaky-retry-m-20240321 
test: attempt to stabilize flaky test
 2024-03-21 13:43:51 -03:00
Ivan Dyachkov
c39f6a8265
Merge pull request #12754 from Kinplemelon/kinple/upgrade-dashboard 
chore(dashboard): bump dashboard version to v1.8.0 & e1.6.0
 2024-03-21 17:40:49 +01:00
Thales Macedo Garitezi
8ffd1304a5
Merge pull request #12755 from thalesmg/fix-kafka-probe-buffer-disk-m-20240321 
fix(kafka-based bridges): avoid trying to get raw config for replayq dir
 2024-03-21 13:39:33 -03:00
Andrew Mayorov
25c07425a3
Merge pull request #12757 from keynslug/fix/EMQX-12050/topics-api-count 
fix(topics-api): respond with correct totals to paged queries
 2024-03-21 16:52:35 +01:00
Serge Tupchii
40eccb10d6 fix(emqx_mgmt_data_backup): remove an uploaded backup file if it's not valid 2024-03-21 17:36:39 +02:00
Kjell Winblad
4bfc51c052 refactor(emqx_connector_info): improve documentation and type specs 2024-03-21 16:08:31 +01:00
Andrew Mayorov
7d6fde5960
fix(topics-api): respond with correct totals to paged queries 2024-03-21 16:02:16 +01:00
Thales Macedo Garitezi
e837791f94 fix(kafka-based bridges): avoid trying to get raw config for replayq dir 
Fixes https://emqx.atlassian.net/browse/EMQX-12049
 2024-03-21 11:49:00 -03:00
ieQu1
34c3c4e892
Merge pull request #12474 from ieQu1/dev/ds-rest-api 
feat(sessds): Expose relevant durable session info in the REST API
 2024-03-21 15:28:07 +01:00
Kinplemelon
c45ed4e028 chore(dashboard): bump dashboard version to v1.8.0 & e1.6.0 2024-03-21 22:05:33 +08:00
Thales Macedo Garitezi
64399b6861 test: attempt to stabilize flaky test 2024-03-21 11:04:14 -03:00
Kjell Winblad
89befa580e refactor(emqx_connector_info): remove code that is no longer needed 2024-03-21 11:58:54 +01:00
ieQu1
cada944350
feat(sessds): Expose relevant durable session info in the REST API 2024-03-21 10:37:04 +01:00