yuanbiao/emqx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
20,433 Commits 393 Branches 684 Tags 74 MiB
dependabot/github_actions/actions-d8a5788e1a
Commit Graph

645 Commits

Author SHA1 Message Date
JimMoen
9143d5994d
feat: refactor MS SQL Server bridge to connector and action 2024-03-04 17:13:21 +08:00
zhongwencool
d56fb22208
Merge pull request #12595 from thalesmg/kafka-consumer-source-m-20240223 
feat: migrate kafka consumer bridge to source + connector
 2024-03-01 10:11:16 +08:00
zhongwencool
7f1b4cef27 feat: pulsar bridge v2 2024-02-29 16:23:37 +08:00
Thales Macedo Garitezi
6b9844ae82 feat: migrate kafka consumer bridge to source + connector 
Fixes https://emqx.atlassian.net/browse/EMQX-11848
 2024-02-27 17:52:33 -03:00
zhongwencool
54c542c795 chore: rename _probe_ to t_probe_ 2024-02-27 17:57:15 +08:00
zhongwencool
c67f2130f2 fix: check connector and bridge_v2 with the right schema 2024-02-27 17:57:10 +08:00
Zaiming (Stone) Shi
2adfefe297 docs: stop generating schema doc for 'bridges' root 2024-02-23 14:51:57 +01:00
Zaiming (Stone) Shi
46877e979b chore: update copyright-year 2024-02-23 08:21:06 +01:00
Kjell Winblad
6561d989d6 feat: refactor DynamoDB bridge to connector and action 
Fixes:
https://emqx.atlassian.net/browse/EMQX-11456
 2024-02-21 14:58:48 +01:00
Thales Macedo Garitezi
4118fcfdc6
Merge pull request #12486 from thalesmg/gcp-consumer-source-m-20240205 
feat: convert `gcp_pubsub_consumer` to connector/source
 2024-02-21 10:06:26 -03:00
zhongwencool
ee02079661
Merge pull request #12548 from zhongwencool/fix-rabbitmq-source-crash 
fix: bridge_v1 http api crash when create rabbitmq source
 2024-02-21 16:34:43 +08:00
zhongwencool
2a7a662c03 fix: bridge_v1 http api crash when create rabbitmq source 2024-02-21 15:30:05 +08:00
Thales Macedo Garitezi
d469f4158e chore: bump app vsns 2024-02-20 16:53:57 -03:00
Kjell Winblad
86c85f3b45
Merge pull request #12512 from kjellwinblad/kjell/refactor/hstreamdb/EMQX-11458 
feat: refactor HStreamDB bridge to connector and action
 2024-02-20 13:30:29 +01:00
Thales Macedo Garitezi
146d89bd89 feat: convert gcp_pubsub_consumer to connector/source 
Fixes https://emqx.atlassian.net/browse/EMQX-11471
 2024-02-19 17:54:26 -03:00
Thales Macedo Garitezi
11e4a295ed fix: use connector type for constructing resource id 2024-02-19 14:42:35 -03:00
Thales Macedo Garitezi
9a32895a1a feat: convert gcp_pubsub_consumer to connector/source 
Fixes https://emqx.atlassian.net/browse/EMQX-11471
 2024-02-19 14:42:35 -03:00
Shawn
8ae0e78786 refactor: split clickhouse bridges to actions and connectors 2024-02-18 10:01:53 +08:00
Zaiming (Stone) Shi
f57f617ba3 refactor(schema): ensure roots/0 and namespace/0 for all schema modules 2024-02-16 11:35:32 +01:00
Kjell Winblad
a153d758c3 feat: refactor HStreamDB bridge to connector and action 
This commit also upgrades the hstreamdb_erl driver library and change
the action/bridge to use the new hstreamdb_erl.

Much of the code for the new API is copied from:
be1a1604dd/lib-ee/emqx_rule_actions/src/emqx_backend_hstreamdb_actions.erl

Fixes:
https://emqx.atlassian.net/browse/EMQX-11458
 2024-02-14 17:34:35 +01:00
Kjell Winblad
366827390e
Merge pull request #12488 from kjellwinblad/kjell/refactor/rocketmq_bridge/EMQX-11467 
feat: refactor RocketMQ bridge to connector and action
 2024-02-13 16:19:21 +01:00
Andrew Mayorov
802c760406
feat(s3): introduce S3 connector and action 
This is a trivial connector based on `emqx_s3` and simple action
that maps each incoming event into an S3 object upload. Due to
current `emqx_s3` limitation this bridge is compatible with
backends providing S3 API with path-style bucket access.
 2024-02-09 14:16:32 +01:00
Kjell Winblad
e284a83f73 feat: refactor RocketMQ bridge to connector and action 
Fixes:
https://emqx.atlassian.net/browse/EMQX-11467
 2024-02-08 16:21:58 +01:00
zhongwencool
b444c82a42 feat: rabbitmq bridge v2 integration 2024-02-06 07:57:12 +08:00
Thales Macedo Garitezi
76d242df9b fix(bridge_v2_api): avoid calling nodes that do not support minimum bpapi 
Fixes https://emqx.atlassian.net/browse/EMQX-11834
 2024-02-02 17:36:08 -03:00
Kjell Winblad
fa0baf2f38
Merge pull request #12439 from kjellwinblad/kjell/refactor/oracle_bridge/EMQX-11464 
feat: refactor Oracle bridge to connector and action
 2024-02-02 10:53:15 +01:00
firest
dfad020c49 feat(tdengine): improve the TDengine bridge to v2 style 2024-02-01 23:14:24 +08:00
Kjell Winblad
a4272c71dc feat: refactor Oracle bridge to connector and action 
Fixes:
https://emqx.atlassian.net/browse/EMQX-11464
 2024-02-01 16:03:05 +01:00
Serge Tupchii
2d693402c5 refactor: split greptimedb bridge to actions and connectors 2024-01-26 11:01:53 +02:00
Kjell Winblad
5bf37cbe0a
Merge pull request #12376 from kjellwinblad/kjell/kinesis 
feat: refactor kinesis bridge to connector and action
 2024-01-25 14:58:40 +01:00
Shawn
6a21766ce3 refactor: split cassandra bridges to actions and connectors 2024-01-25 16:01:44 +08:00
firest
dad8a32e0b feat(opents): improve the OpentsDB bridge to v2 style 2024-01-25 16:01:43 +08:00
JimMoen
a752119d05
fix(prom_di): use bridge_v2 metrics api 2024-01-25 09:22:22 +08:00
Kjell Winblad
fa842736d2 feat: refactor kinesis bridge to connector and action 
Fixes:
https://emqx.atlassian.net/browse/EMQX-11461
 2024-01-24 18:31:03 +01:00
Thales Macedo Garitezi
67c9e9c8fc fix(actions_api): reset metrics on all nodes 
Fixes https://emqx.atlassian.net/browse/EMQX-11796
 2024-01-23 10:40:02 -03:00
Xinyu Liu
aafb683ec7
Merge pull request #12330 from emqx/bridge-v2-cassandra 
refactor: split cassandra bridges to actions and connectors
 2024-01-23 14:45:32 +08:00
firest
e337e1dc40 feat(opents): improve the OpentsDB bridge to v2 style 2024-01-22 20:45:10 +08:00
Shawn
b32c0fb0d8 refactor: split cassandra bridges to actions and connectors 2024-01-22 10:16:46 +08:00
Serge Tupchii
dc15d37dcc perf(emqx_bridge/connector): load and unload bridges/connectors in parallel 
This should reduce app start/stop time, when a large number of bridges/connectors are not healthy.
 2024-01-19 21:44:31 +02:00
Serge Tupchii
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
Thales Macedo Garitezi
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
Thales Macedo Garitezi
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
Thales Macedo Garitezi
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
Thales Macedo Garitezi
a8f9e5676f docs(mqtt_bridge): add API examples 2024-01-16 10:42:52 -03:00
Kjell Winblad
60fab6ee45 refactor: attempt to improve function names 2024-01-16 10:42:52 -03:00
Kjell Winblad
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
Thales Macedo Garitezi
440a543a85 docs: fix typo 2024-01-16 10:42:52 -03:00
Thales Macedo Garitezi
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
Thales Macedo Garitezi
cc24fe6e93 feat(mqtt_consumer): add support for rule engine FROM 2024-01-16 10:42:52 -03:00
Thales Macedo Garitezi
28de7c89c7 feat: add /sources* HTTP APIs 2024-01-16 10:42:52 -03:00