e4fd878998
feat(ft): add API
2023-02-06 01:49:06 +02:00
af4360f5c5
Merge pull request #9900 from keynslug/file-transfer
...
test(ft): add some basic assembler tests
2023-02-03 19:41:35 +02:00
9a56c34c8d
feat(ft): add fs storage bpapi and use it in assembler
2023-02-03 18:48:50 +03:00
c11e251902
feat(ft-fs): allow to list all transfers in storage
...
This is rather simplistic and thus, temporary solution.
2023-02-03 17:04:27 +03:00
19cd66198b
feat(ft-fs): make `list` / `read` more generic
...
And usable in wider contexts as a consequence, for example querying and
fetching resulting files from remote nodes.
2023-02-03 14:37:02 +03:00
3bb08fe945
fix(ft-fs): put fragments into separate directories
...
In order to avoid potential filename collisions.
2023-02-03 13:59:05 +03:00
6b5ef45084
refactor(ft): bring back userdata to filemeta schema
2023-02-03 12:39:55 +03:00
73405772cd
feat(ft): removed replicated data
2023-02-03 00:45:44 +02:00
ac5fcfe9f1
feat(ft): add config & backend behaviour
2023-02-03 00:31:55 +02:00
f9078e8401
fix(ft-fs): add missing `read_segment/5` + fix atomic write
2023-02-03 00:31:55 +02:00
5dae423f1e
fix(ft-asm): follow proper `segment` fragment type
2023-02-03 00:31:55 +02:00
d2bb574921
fix(ft-asm): ensure module follows statem behaviour
2023-02-03 00:31:55 +02:00
37d8930341
test(ft): add some basic assembler tests
2023-02-03 00:31:55 +02:00
3967c9c5b2
feat(ft): improve robustness of asynchronous acks
...
* add auto ack after timeout
* add fin file transfer packet registration to avoid
duplication and multiple acks
2023-02-03 00:31:55 +02:00
8f544041e4
tie file transfer frontend and backend together
2023-02-03 00:31:55 +02:00
ac6e9292dd
feat(ft): introduce simple filesystem storage backend + assembler
2023-02-03 00:31:55 +02:00
2258285edf
add file transfer app and bootstrap replicated ft data structure
2023-02-03 00:31:51 +02:00
63987bf6d4
add basic hooks
2023-02-01 20:10:20 +02:00
3d59be6ab6
Merge pull request #9871 from lafirest/fix/authz_rules
...
feat(authz): allow the placeholder to be anywhere in the topic for authz rules
2023-02-01 00:12:06 +08:00
9f4c36ecbc
chore: bump version && update changes
2023-01-31 23:30:22 +08:00
c034cbf6de
feat(authz): allow the placeholder to be anywhere in the topic for authz rules
2023-01-31 23:30:12 +08:00
ade5316419
Merge pull request #9802 from sstrigler/EMQX-8469-enable-proxy-protocol-support-in-emqx-dashboard-schema
...
feat: support HAProxy protocol for dashboard API
2023-01-31 14:19:56 +01:00
1bbae31268
chore: mv for v5.0.16 release
2023-01-31 08:59:46 +01:00
3ce6cbcd6a
chore: bump vsn
2023-01-30 18:09:10 +01:00
0b1483040a
test: add actual test for haproxy
2023-01-30 18:07:06 +01:00
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
63adbe31a0
chore: update changes
2023-01-30 18:28:08 +08:00
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
3bdffca488
fix: the exclusive topics aren't removed when the session has already been cleaned
2023-01-30 18:17:00 +08:00
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
f64cb693ae
Merge remote-tracking branch 'origin/master' into 0126-merge-release-50-to-master
2023-01-26 14:17:28 +01:00
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
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
908ac8d948
fix: speed up banned test cases
2023-01-26 13:04:55 +08:00
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
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
feb0238911
fix(influxdb): ensure client is stopped before returning error
2023-01-24 20:35:02 +01:00
2416aeebc7
build: allow user-specified image tag for make docker build
2023-01-24 20:35:02 +01:00
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
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
424d6ed34b
test: improve start.sh script for influxdb tests
2023-01-24 14:42:52 +01:00
21e933e9bb
test: add rule to influx-bridge.conf and add newlines
2023-01-24 14:37:15 +01:00
7603ab490b
fix(emqx_ee_connector): fix passing of influxdb ssl opts
2023-01-24 14:30:40 +01:00
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
fbfd4a2565
test: use EMQX_IMAGE_TAG for influx test script
2023-01-24 14:13:03 +01:00
28718edbfd
chore: bump application VSNs
2023-01-24 14:12:34 +01:00
9fc586f670
test: add influx docker test certs
2023-01-24 13:58:37 +01:00
502b826396
test: add influxdb docker test files
2023-01-24 13:58:37 +01:00
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
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
Ilya Averyanov