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

591 Commits

Author SHA1 Message Date
Zaiming (Stone) Shi
a4bc15cfa1 Merge remote-tracking branch 'origin/master' into 0502-merge-release-50-back-to-master 2023-05-02 18:59:31 +02:00
Zaiming (Stone) Shi
d5f5f35787 Merge remote-tracking branch 'origin/release-50' into 0502-merge-release-50-back-to-master 2023-05-02 18:08:04 +02:00
Andrew Mayorov
90cf1ade74
chore: bump application versions 
* emqx_connector 0.1.22
* emqx_bridge_gcp_pubsub 0.1.1
* emqx_bridge_kafka 0.1.2
* emqx_bridge_pulsar 0.1.1
* emqx_ee_connector 0.1.12
 2023-05-02 17:29:22 +03:00
Andrew Mayorov
4575167607
feat(resource): drop manager_id() type 2023-05-02 17:29:20 +03:00
Andrew Mayorov
aaef95b1da
feat(resman): stop adding uniqueness to manager ids 
Before this change, a separate `manager_id` / `instance_id` was used
as resource manager id, which made connector interface somewhat
inconsistent: part of function calls to connector implementation
used instance id as first argument while the rest used resource id
itself.
 2023-05-02 17:28:26 +03:00
Zaiming (Stone) Shi
57cc854a4a test(bridge): fix bridge map type filed converters 
now the converters on map type fields only work at the wrapping map
level but not the values
 2023-04-30 10:45:11 +02:00
Zaiming (Stone) Shi
b58d3e8f94
Merge pull request #10529 from zmstone/0426-ensure-buffer-worker-monitors-cassandra-conn-pid 
0426 ensure buffer worker monitors cassandra conn pid
 2023-04-27 22:54:30 +02:00
Paulo Zulato
dd90b2f498 feat(oracle): Oracle Database integration 2023-04-27 13:07:20 -03:00
Thales Macedo Garitezi
567413389c
Merge pull request #10519 from thalesmg/fix-flaky-res-test-v50 
test(resource): fix flaky test
 2023-04-27 09:33:40 -03:00
zhongwencool
1f0148a819
Merge pull request #10524 from lafirest/fix/rocketmq_sensitive 
fix(rocketmq): keep sensitive data safe in rocketmq logs and state
 2023-04-27 10:16:05 +08:00
Zaiming (Stone) Shi
a8b000f062 refactor(sqlserver): support only sync mode at connector level 2023-04-26 20:44:56 +02:00
Ivan Dyachkov
b76025f541 chore: merge upstream/release-50 2023-04-26 18:01:33 +02:00
Zaiming (Stone) Shi
c83d630c97 fix(cassandra): ensure async calls return connection pid 
so the buffer worker can monitor it and perform retries
if the connection restarted
 2023-04-26 14:33:37 +02:00
firest
9eccfa5cdf fix(dynamo): fix test case errors 2023-04-26 17:03:01 +08:00
firest
6706fd90e1 fix(rocketmq): keep sensitive data safe in rocketmq logs and state 2023-04-26 16:10:35 +08:00
firest
e467e082f0 fix(dynamo): remove all async callbacks of the Dynamo connector 2023-04-26 14:47:22 +08:00
Zhongwen Deng
bc1bdae55d chore: reslove confilt for sync release-50 to master 2023-04-26 11:50:44 +08:00
zhongwencool
9d893b49eb
Merge branch 'master' into sync-release-50-to-master 2023-04-26 10:54:46 +08:00
Thales Macedo Garitezi
79cf5cad19
Merge pull request #10378 from thalesmg/pulsar-producer-e50 
feat: implement Pulsar Producer bridge (e5.0)
 2023-04-25 18:01:43 -03:00
Thales Macedo Garitezi
687509886e test: rm unused var warning 2023-04-25 17:37:20 -03:00
lafirest
dc452deaf0
Merge pull request #10506 from lafirest/fix/dynamo_default_port 
fix(dynamo): use correct default port for different schemas
 2023-04-25 18:26:44 +08:00
firest
3bb50a5751 fix(rocketmq): fix that the update of ACL info not working 2023-04-25 16:55:03 +08:00
firest
33c27ac2ac fix(dynamo): use correct default port for different schemas 2023-04-25 10:50:44 +08:00
Thales Macedo Garitezi
99f3965f4e feat(schema_registry): use rocksdb as table type for protobuf cache 2023-04-24 14:24:42 -03:00
Thales Macedo Garitezi
377b143325 refactor: split parse_server into smaller functions, improve return type to use map 2023-04-24 14:17:29 -03:00
Thales Macedo Garitezi
ad4be08bb2 feat: implement Pulsar Producer bridge (e5.0) 
Fixes https://emqx.atlassian.net/browse/EMQX-8398
 2023-04-24 10:28:26 -03:00
firest
7ce04358c4 fix(Dynamo): fix DynamoDB bridge status check error 2023-04-24 17:28:33 +08:00
JianBo He
2b0106e047
Merge pull request #10485 from JimMoen/fix-mssql-bridge-default 
fix: use default health check timeout for sqlserver
 2023-04-23 18:20:10 +08:00
JimMoen
d505b65ba8
fix: use default health check timeout for sqlserver 2023-04-23 15:47:19 +08:00
JimMoen
4e7472090b
fix: refine default sql and driver name for mssql bridge 2023-04-23 15:47:18 +08:00
firest
5ad5d7ee8d fix(opents): adjust code structure 2023-04-23 14:28:14 +08:00
lafirest
6ef032026f
Merge pull request #10471 from lafirest/fix/dynamo_bridge 
fix(dynamo): separate the implementation of connector and client of Dynamo bridge
 2023-04-23 14:25:23 +08:00
firest
932a327952 chore: make spellcheck and xref happy 2023-04-23 11:22:56 +08:00
firest
0b46acda87 test(opents): add test cases for OpenTSDB 2023-04-23 11:03:20 +08:00
firest
d826b0921d fix(dynamo): separate the implementation of connector and client of Dynamo bridge 2023-04-23 10:57:36 +08:00
firest
5074825075 feat(opents): OpenTSDB integration 2023-04-23 09:56:24 +08:00
JianBo He
b270623c46 chore: rename cassandra_impl to cassandra_connector 2023-04-21 16:49:25 +08:00
firest
7704995279 fix(rocketmq): expose the driver parameter sync_timeout into the RocketMQ bridge configuration 2023-04-21 15:10:25 +08:00
JianBo He
5cc28a7b45 chore: fix mix.exs checking 2023-04-21 14:46:09 +08:00
JianBo He
bdce32e713 refactor(cassandra): move cassandra bridge into its own app 2023-04-21 14:45:38 +08:00
JianBo He
6532cfb337
Merge pull request #10452 from thalesmg/refactor-gcp-pubsub-bridge-v50 
refactor(gcp_pubsub): move GCP PubSub Bridge to its own app
 2023-04-21 14:42:00 +08:00
lafirest
48402d0476
Merge pull request #10461 from lafirest/fix/dynamo_db_svrs 
fix(rocketmq): allow setting multiple addresses in RocketMQ bridge
 2023-04-21 14:37:37 +08:00
firest
f602900a53 fix(rocketmq): fix that the status check of RocketMQ bridge may not accurate 2023-04-21 13:35:29 +08:00
firest
d865998a63 fix(rocketmq): fix test cases 2023-04-21 11:02:14 +08:00
firest
21473e7ca5 fix(dynamo): fix field name errors 2023-04-20 18:16:04 +08:00
firest
6e12abff39 fix(rocketmq): allow setting multiple addresses in RocketMQ bridge 2023-04-20 17:58:12 +08:00
Zaiming (Stone) Shi
415830a0a2 Merge remote-tracking branch 'origin/release-50' into 0420-sync-release-50-to-masteer 2023-04-20 11:03:39 +02:00
Kjell Winblad
7d3367467a
Merge pull request #10408 from kjellwinblad/kjell/rule_engine/add_missing_mongo_date_functions/EMQX-9244 
feat: add mongo_date functions to the rule engine
 2023-04-20 09:46:45 +02:00
Thales Macedo Garitezi
a9bd91fcff refactor(gcp_pubsub): move GCP PubSub Bridge to its own app 
Fixes https://emqx.atlassian.net/browse/EMQX-9536

Note: since GCP PubSub is not shared by any authn/authz backend,
there's no need to separate its connector into another app.
 2023-04-19 13:24:32 -03:00
firest
e89f4d4565 fix(dynamo): fix terminology erros 
- Changed `username` to `aws_access_key_id`
- Changed `password` to `aws_secret_access_key`
 2023-04-19 16:26:42 +08:00