d3a6870097
feat(emqx_utils): add pforeach/2,3
2024-01-19 21:44:31 +02:00
a6568dec75
perf(emqx_bridge/connector): apply post config bridge/connector changes in parallel
...
This can greatly improve the performance when many bridges/connectors are being changed,
e.g. when a backup file is being imported.
Fixes: EMQX-11751
2024-01-19 21:44:31 +02:00
54457b7093
feat(emqx_utils): allow `infinity` timeout in `pmap/3`
2024-01-19 19:34:04 +02:00
a40a13b786
Merge pull request #12357 from thalesmg/fix-bridge-bpapi-interval-r55-20240119
...
fix(bridge_api): explicitly state bpapi version ranges
2024-01-19 13:08:44 -03:00
57074015c6
feat(ds): allow customizing the data directory
...
The storage expectations for the RocksDB DB may be different from our usual data
directory. Also, it may consume a lot more storage than other data.
This allows customizing the data directory for the builtin DS storage backend.
Note: if the cluster was already initialized using a directory path, changing that config
will have no effect. This path is currently persisted in mnesia and used when reopening
the DB.
2024-01-19 13:07:24 -03:00
270eb81f8e
Merge pull request #12356 from thalesmg/fix-mqtt-ingress-pub-local-r55-20240119
...
fix(mqtt_source): don't attempt local publish when legacy config is absent
2024-01-19 13:06:44 -03:00
d22092e3da
fix(mqtt_source): don't attempt local publish when legacy config is absent
...
Fixes https://emqx.atlassian.net/browse/EMQX-11765
2024-01-19 10:54:05 -03:00
e369c1b971
docs(mqtt_source): fix example qos
2024-01-19 10:54:05 -03:00
4068258c78
fix(bridge_api): explicitly state bpapi version ranges
...
Fixes https://emqx.atlassian.net/browse/EMQX-11767
The currently supported version for a node may not be available at the time it's probed.
2024-01-19 10:20:57 -03:00
8c978ccbf3
Merge pull request #12346 from id/0117-ci-bump-actions-versions
...
ci: bump actions versions
2024-01-19 10:32:02 +01:00
7895191379
Merge pull request #12352 from zmstone/0118-sync-release-55
...
Sync `release-55` to `master`
2024-01-19 06:45:33 +00:00
7d14a13b7b
Merge remote-tracking branch 'origin/release-55'
2024-01-18 14:36:30 +01:00
a10f338703
Merge pull request #12341 from thalesmg/dot-gitignore-m-20240116
...
ci(dev): add `.git/` to `.gitignore`
2024-01-18 09:46:22 -03:00
e219c3eda1
Merge pull request #12166 from kjellwinblad/kjell/mqtt_conn_action_3/EMQX-11489
...
feat: refactor MQTT bridge to source, action, and connector
2024-01-18 09:28:14 -03:00
3be3677005
Merge pull request #12347 from savonarola/0117-render-valid-mqtt-messages-from-rules
...
fix(mqtt_bridge): render valid messages from incomplete rule data
2024-01-18 14:24:05 +02:00
6b462a9100
Merge pull request #12349 from zmstone/0118-fix-authz-cache-excludes-type
...
0118 fix authz cache excludes type
2024-01-18 10:32:38 +00:00
1b432eadd8
Merge pull request #12348 from emqx/elasticsearch-e550
...
Elasticsearch e550
2024-01-18 18:06:48 +08:00
4d1aa97020
Merge pull request #12350 from zhongwencool/fix-typo
...
chore: fix typos
2024-01-18 17:49:28 +08:00
5b064e399f
chore: improve http connector logs format
2024-01-18 17:29:23 +08:00
dae835635c
fix: don't crash in http SUITE
2024-01-18 16:45:46 +08:00
59797cfea7
feat: es's update support doc_as_upsert
2024-01-18 16:44:56 +08:00
91368a57ff
test: add es docker CI test
2024-01-18 16:44:56 +08:00
7f5fe91905
fix: es's action is atom not binary
2024-01-18 16:44:56 +08:00
7802d6e018
chore: fix typos
2024-01-18 16:35:57 +08:00
556092b7d0
feat(authz/prometheus): add authz cache_miss counter
2024-01-18 09:01:17 +01:00
85b6a3454c
fix(authz): use binary() type instead of string() for cache.excludes
2024-01-18 09:01:17 +01:00
6d6242c27a
Merge pull request #12335 from lafirest/fix/type_clause
...
fix(iotdb): enhances type checking when converting value
2024-01-18 11:28:40 +08:00
ad52cf588b
Merge pull request #12342 from lafirest/fix/sysk
...
fix(sysk): fix a update issue for the Syskeeper forwarder
2024-01-18 11:28:21 +08:00
74bf4042c5
fix(mqtt_bridge): render valid messages from incomplete rule data
2024-01-17 23:13:55 +03:00
0a0bf3123b
ci: bump actions versions
2024-01-17 15:18:03 +01:00
b2af7fdd70
fix(sysk): fix a update issue for the Syskeeper forwarder
2024-01-17 12:51:10 +08:00
238ecc68cf
fix(iotdb): enhances type checking when converting value
2024-01-17 12:00:15 +08:00
6a0c54b40e
ci(dev): add `.git/` to `.gitignore`
...
For some reason, some tools like [ripgrep](https://github.com/BurntSushi/ripgrep ) will
search `.git` when using the `-.`/`--hidden` flag, even when not using `--no-ignore-vcs`.
This leads to several unwanted results.
2024-01-16 17:31:28 -03:00
4fa906731d
Merge pull request #12333 from zmstone/0116-add-tags-for-action-and-connectors
...
feat: add 'tags' field for action and connector
2024-01-16 18:56:57 +00:00
23c0dc58fb
Merge pull request #12337 from SergeTupchiy/refactor-emqx-cm-test-flush
...
test(emqx_cm_SUITE): use one helper function `emqx_pool:flush_async_tasks/1`
2024-01-16 20:15:16 +02:00
80e82db282
test(emqx_cm_SUITE): use one helper function: `emqx_pool:flush_async_tasks/1`
2024-01-16 19:42:37 +02:00
ed78f2488b
Merge pull request #12336 from SergeTupchiy/EMQX-11743-dedicated-channel-cleanup-pool
...
perf(emqx_cm): use a dedicated pool for channel cleanup
2024-01-16 19:38:15 +02:00
b472b56883
perf(emqx_cm): use a dedicated pool for channel cleanup
...
This is to isolate channels cleanup from other async tasks (like routes cleanup),
as channels cleanup can be quite slow under high network latency conditions.
Fixes: EMQX-11743
2024-01-16 19:08:02 +02:00
01d52e37c4
fix: resource tag type should be binary string
...
Co-authored-by: Thales Macedo Garitezi <thalesmg@gmail.com>
2024-01-16 17:35:22 +01:00
1a02e8edba
Merge pull request #12334 from zmstone/0116-fix-authz-logging
...
0116 fix authz logging
2024-01-16 16:33:15 +00:00
2a41cad54f
fix(sources): remote irrelevant `resource_opts` fields for sources
...
Since they don't use buffer workers, they shouldn't have buffer-related sub-fields.
2024-01-16 11:29:35 -03:00
a8f9e5676f
docs(mqtt_bridge): add API examples
2024-01-16 10:42:52 -03:00
60fab6ee45
refactor: attempt to improve function names
2024-01-16 10:42:52 -03:00
c6cd3adccb
refactor: fix type upgrade calls and move compatiblitly logic
...
Some bridge V1 to V2 calls were wrong but did not seem to cause issues
(perhaps due to locking test coverage). This commit also move
compatibility logic from the API module to the emqx_bridge_v2 module
where most of the compatibility logic exists.
2024-01-16 10:42:52 -03:00
440a543a85
docs: fix typo
2024-01-16 10:42:52 -03:00
938429f351
chore(mqtt_bridge): change schema to remote `remote` sub-fields and hide `local`
...
`local` is still needed for backwards compatibility
2024-01-16 10:42:52 -03:00
007af20a30
test(bridge_v2_api): adapt more tests to sources
2024-01-16 10:42:52 -03:00
fc88a1ed1e
test(sources_api): add some tests to cover `/sources` HTTP API
...
Also fixes a bug with `DELETE /sources/:id`
2024-01-16 10:42:52 -03:00
8f304d3456
test(bridge_v2_api): refactor suite to use CT matrix
2024-01-16 10:42:52 -03:00
cc24fe6e93
feat(mqtt_consumer): add support for rule engine `FROM`
2024-01-16 10:42:52 -03:00
Serge Tupchii