yuanbiao/emqx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
13,101 Commits 393 Branches 684 Tags 74 MiB
9f4c36ecbc
Commit Graph

13101 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
firest
9f4c36ecbc chore: bump version && update changes 2023-01-31 23:30:22 +08:00
firest
c034cbf6de feat(authz): allow the placeholder to be anywhere in the topic for authz rules 2023-01-31 23:30:12 +08:00
lafirest
e288424924
Merge pull request #9864 from lafirest/fix/exclusive-unsub-5.0 
fix: the exclusive topics aren't removed when the session has already been cleaned
 2023-01-31 00:33:45 +08:00
firest
63adbe31a0 chore: update changes 2023-01-30 18:28:08 +08:00
lafirest
3e6cc40525
Merge pull request #9843 from lafirest/fix/speed_up_test 
fix: speed up banned test cases
 2023-01-30 18:17:27 +08:00
firest
3bdffca488 fix: the exclusive topics aren't removed when the session has already been cleaned 2023-01-30 18:17:00 +08:00
Zaiming (Stone) Shi
c32d40765e
Merge pull request #9844 from zmstone/0126-merge-release-50-to-master 
0126 merge release 50 to master
 2023-01-27 10:42:56 +01:00
Zaiming (Stone) Shi
f64cb693ae Merge remote-tracking branch 'origin/master' into 0126-merge-release-50-to-master 2023-01-26 14:17:28 +01:00
Zaiming (Stone) Shi
bafc430184
Merge pull request #9837 from zmstone/0123-fix-resource-worker-leak-influxdb 
0123 fix resource worker leak influxdb
 2023-01-26 09:14:38 +01:00
Zaiming (Stone) Shi
854ea79798
Merge pull request #9816 from zmstone/0119-fix-kafka-rule-counters 
0119 fix kafka rule counters
 2023-01-26 09:11:05 +01:00
firest
908ac8d948 fix: speed up banned test cases 2023-01-26 13:04:55 +08:00
Ivan Dyachkov
df17142387
Merge pull request #9836 from id/ci-build-ubuntu22.04-packages 
ci: build ubuntu 22.04 packages
 2023-01-25 09:19:58 +01:00
Zaiming (Stone) Shi
5fdf7fd24c fix(kafka): use async callback to bump success counters 
some telemetry events from wolff are discarded:

* dropped:
    this is double counted in wolff,
    we now only subscribe to the dropped_queue_full event
* retried_failed:
    it has different meanings in wolff,
    in wolff, it means it's the 2nd (or onward) produce attempt
    in EMQX, it means it's eventually failed after some retries

* retried_success
    since we are going to handle the success counters in callbac
    this having this reported from wolff will only make things
    harder to understand

* failed
    wolff never fails (unelss drop which is a different counter)
 2023-01-24 21:12:36 +01:00
Zaiming (Stone) Shi
feb0238911 fix(influxdb): ensure client is stopped before returning error 2023-01-24 20:35:02 +01:00
Zaiming (Stone) Shi
2416aeebc7 build: allow user-specified image tag for make docker build 2023-01-24 20:35:02 +01:00
Zaiming (Stone) Shi
6175076f6f
Merge pull request #9835 from olcai/add-influxdb-test-files 
fix: add influxdb test files and fixes
 2023-01-24 17:02:23 +01:00
Zaiming (Stone) Shi
e5b65087af
Merge pull request #9834 from zmstone/0123-fix-idle_timeout-infinity 
fix(emqx_connection): crash when idle_timeout is set to infinity
 2023-01-24 16:05:09 +01:00
Erik Timan
424d6ed34b test: improve start.sh script for influxdb tests 2023-01-24 14:42:52 +01:00
Erik Timan
21e933e9bb test: add rule to influx-bridge.conf and add newlines 2023-01-24 14:37:15 +01:00
Erik Timan
7603ab490b fix(emqx_ee_connector): fix passing of influxdb ssl opts 2023-01-24 14:30:40 +01:00
Erik Timan
9d20431257 fix(emqx_resource): fix crash while flushing queue 
We used next_event for flushing the queue in emqx_resource, but this
leads to a crash. We now call flush_worker/1 instead.
 2023-01-24 14:13:35 +01:00
Erik Timan
fbfd4a2565 test: use EMQX_IMAGE_TAG for influx test script 2023-01-24 14:13:03 +01:00
Erik Timan
28718edbfd chore: bump application VSNs 2023-01-24 14:12:34 +01:00
Erik Timan
9fc586f670 test: add influx docker test certs 2023-01-24 13:58:37 +01:00
Erik Timan
502b826396 test: add influxdb docker test files 2023-01-24 13:58:37 +01:00
Zaiming (Stone) Shi
8fde169abb
Merge pull request #9821 from thalesmg/buffer-worker-expiry-v50 
feat(buffer_worker): add expiration time to requests
 2023-01-24 13:54:04 +01:00
Zaiming (Stone) Shi
ec21e36207
Merge pull request #9833 from zmstone/0123-chore-sync-release-50-to-master 
0123 chore sync release 50 to master
 2023-01-24 10:56:18 +01:00
Zaiming (Stone) Shi
7575120ea6 test: use snabbkaffe retry macro 2023-01-24 10:54:20 +01:00
Zaiming (Stone) Shi
140cda2f13 fix(emqx_connection): crash when idle_timeout is set to infinity 2023-01-24 10:14:35 +01:00
Zaiming (Stone) Shi
a0100c0a4e chore: bump app versions 2023-01-23 16:20:21 +01:00
Zaiming (Stone) Shi
a83ed2fe94 Merge remote-tracking branch 'origin/master' into 0123-chore-sync-release-50-to-master 2023-01-23 16:20:01 +01:00
Ivan Dyachkov
e68ee4c2ff ci: build ubuntu 22.04 packages 2023-01-23 13:30:00 +01:00
Zaiming (Stone) Shi
92797d7260 chore: Generate changelog for v5.0.15 2023-01-20 17:00:55 +01:00
Zaiming (Stone) Shi
da4ef73377
Merge pull request #9825 from zmstone/release-v5.0.15 
chore: prepare for v5.0.15 release
 2023-01-20 17:00:29 +01:00
Zaiming (Stone) Shi
727100e094 chore: prepare for v5.0.15 release 2023-01-20 16:42:01 +01:00
Thales Macedo Garitezi
ca4a262b75 refactor: re-organize dealing with unrecoverable errors 2023-01-20 12:00:17 -03:00
Thales Macedo Garitezi
6fa6c679bb feat(buffer_worker): add expiration time to requests 
With this, we avoid performing work or replying to callers that are no
longer waiting on a result.

Also introduces two new counters:

- `dropped.expired` :: happens when a request expires before being
  sent downstream
- `late_reply` :: when a response is receive from downstream, but the
  caller is no longer for a reply because the request has expired, and
  the caller might even have retried it.
 2023-01-20 11:36:52 -03:00
Zaiming (Stone) Shi
cd093b6b9f
Merge pull request #9778 from kjellwinblad/kjell/fix/kafka_atom_leak/EMQX-8739 
fix: atom leak when doing Kafka bridge dry-run
 2023-01-20 12:49:41 +01:00
Zaiming (Stone) Shi
ec5b6204d3
Merge pull request #9823 from zmstone/0120-upgrade-ce-dashboard-to-v1.1.6 
0120 upgrade ce dashboard to v1.1.6
 2023-01-20 12:35:57 +01:00
Kjell Winblad
8c52264c41 fix: atom leak when doing Kafka bridge dry-run 
A new atom was created every time one did a dry run of a Kafka bridge
(that is, clicking the Test button in the settings dialog for the
bridge).

After this fix, we will only create a new atom when a bridge with a new
name is created. This should be acceptable as bridges with new names are
created relatively rarely and it seems to be useful to have an unique
atom for every Wolff producer.

Fixes: https://emqx.atlassian.net/browse/EMQX-8739
 2023-01-20 11:50:20 +01:00
Zaiming (Stone) Shi
57607ca0ce chore: prepare for v5.0.15 release 2023-01-20 11:20:34 +01:00
Zaiming (Stone) Shi
34c1ebbe48 chore: upgrade to dashboard v1.1.6 2023-01-20 11:20:34 +01:00
Zaiming (Stone) Shi
0363f12f2f
Merge pull request #9331 from 1995parham/master 
Correct `internalmqtt` port configuration in chart
 2023-01-20 11:16:39 +01:00
Zaiming (Stone) Shi
b4c618e0eb
Merge pull request #9811 from Rory-Z/chore/update-serviceaccount 
feat(helm): user can define service account by userself
 2023-01-20 11:13:43 +01:00
Zaiming (Stone) Shi
1c3e055b13
Merge pull request #9822 from JimMoen/fix-schema-typo 
chore: i18n typo fix
 2023-01-20 11:11:18 +01:00
Zaiming (Stone) Shi
2d502ac994
Merge pull request #9820 from zmstone/0119-merge-master-to-release-50 
0119 merge master to release 50
 2023-01-20 10:57:34 +01:00
JimMoen
16f45a60fd
chore: i18n typo fix 2023-01-20 11:50:01 +08:00
Thales Macedo Garitezi
a6ad97e6a5
Merge pull request #9807 from thalesmg/buffer-worker-rename-v50 
buffer work refactoring follow up (part 1)
 2023-01-19 14:17:10 -03:00
Zaiming (Stone) Shi
abe7a69696 Merge remote-tracking branch 'origin/master' into release-50 2023-01-19 17:51:38 +01:00
Thales Macedo Garitezi
258c7cbf7d
Merge pull request #9817 from thalesmg/fix-jwt-worker-clause-re50 
fix(jwt_worker): handle exceptions when decoding jwk from pem
 2023-01-19 13:14:52 -03:00