Commit Graph

3297 Commits

Author SHA1 Message Date
Alessandro (Ale) Segala 921248462d
Updated Twilio components (#1830)
Ensure output binding propagates context (requires updated SDK)

Spin-off from PR adding contexts to input bindings

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2022-06-30 16:39:22 -07:00
Alessandro (Ale) Segala 07c88b13d6
Improvements to bindings.dingtalk.webhook (#1821)
* Improvements to bindings.dingtalk.webhook

Spin-off from PR adding contexts to input bindings

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Should not have been added

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2022-06-30 16:17:56 -07:00
Alessandro (Ale) Segala 2305dfb609
Improvements to DynamoDB binding (#1823)
Ensure context propagation in PutItem and other minor changes

Spin-off from PR adding contexts to input bindings

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2022-06-30 15:44:15 -07:00
Bernd Verst 1dc059482f
Merge pull request #1826 from ItalyPaleAle/bc-blobstorage
Small improvements to blobstorage binding
2022-06-30 15:26:55 -07:00
Dapr Bot 7916719f9d
Merge branch 'master' into bc-blobstorage 2022-06-30 15:08:10 -07:00
Bernd Verst ae44a9acd9
Merge pull request #1836 from berndverst/master
Actually let all contrib maintainers use automerge label
2022-06-30 14:58:11 -07:00
Bernd Verst a11d664cfa Actually let all contrib maintainers use automerge label
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-06-30 14:43:35 -07:00
Bernd Verst c2daea0807
Merge pull request #1798 from ItalyPaleAle/pubsub-no-builtin-retries
Disable built-in retries in pubsub subscribe
2022-06-30 14:32:05 -07:00
Alessandro (Ale) Segala db2e5f5952
Merge branch 'master' into pubsub-no-builtin-retries 2022-06-30 14:15:48 -07:00
Bernd Verst c52b99508f
Merge pull request #1819 from 1046102779/context
typo: modify package context
2022-06-30 14:15:06 -07:00
Bernd Verst a77e0370bc
Merge branch 'master' into pubsub-no-builtin-retries 2022-06-30 14:13:18 -07:00
Alessandro (Ale) Segala 17fe582d8c
Merge branch 'master' into context 2022-06-30 13:25:06 -07:00
Bernd Verst 027d7b7436
Merge pull request #1822 from ItalyPaleAle/bc-dubbo
Ensure context is propagated in Dubbo input binding
2022-06-30 09:23:56 -07:00
Alessandro (Ale) Segala 86878928f1
Merge branch 'master' into pubsub-no-builtin-retries 2022-06-29 23:59:54 -07:00
ItalyPaleAle 14a9103bec Improvements to blobstorage binding
Spin-off from PR adding contexts to input bindings

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-06-29 19:55:02 +00:00
ItalyPaleAle bb828b84c6 Ensure context is propagated in Dubbo input binding
Spin-off from PR adding contexts to input bindings

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-06-29 19:31:32 +00:00
1046102779 1bf2bdb753 typo: modify package context
Signed-off-by: 1046102779 <seachen@tencent.com>
2022-06-29 12:57:24 +08:00
1046102779 7d3d7d26ec Merge branch 'master' into state/oci/objectstorage 2022-06-29 12:56:10 +08:00
yellow chicks 7033c8f266
optimize: move logger from api to struct (#1818)
Signed-off-by: 1046102779 <seachen@tencent.com>
2022-06-28 19:30:13 -07:00
1046102779 5cd205bcb7 optimize: move logger from api to struct
Signed-off-by: 1046102779 <seachen@tencent.com>
2022-06-29 10:02:53 +08:00
ItalyPaleAle b58464ad1c Make RabbitMQ retry more than once
Also updated tests to remove unused options and add more logging

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-06-27 22:31:31 +00:00
ItalyPaleAle 476b95990f Pulsar: do not disconnect in case of error processing message
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-06-27 21:29:54 +00:00
Alessandro (Ale) Segala c3f8b78e0d
Merge branch 'master' into pubsub-no-builtin-retries 2022-06-27 14:13:01 -07:00
ItalyPaleAle a942b05b4a Added redeliveryDelay to pubsub.pulsar
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-06-27 21:12:34 +00:00
tanvigour 1eb8fd92f4
Azure Table Storage Certification tests (#1816)
* Azure Table Storage Certification tests

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* use env variable instead

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* address feedback

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* Add the component to certification workflow and fix the service url

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* Fix all the errors

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* Fix all errors

Signed-off-by: tanvigour <tanvi.gour@gmail.com>
2022-06-27 14:01:50 -07:00
ItalyPaleAle 0c40dccd07 pubsub.mqtt: re-enqueue messages when they fail
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-06-27 20:47:16 +00:00
ItalyPaleAle be2fed6b3a MQTT: re-set "retain" to false as default
Support for "retain" is currently broken

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-06-27 20:36:15 +00:00
Bernd Verst 8974eca74c Fix MQTT metadata test
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-06-27 20:36:15 +00:00
Alessandro (Ale) Segala f55dedbbe9 More sane defaults for default values in MQTT metadata (#1810)
Fixes #1809

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-06-27 20:36:15 +00:00
ItalyPaleAle a021fb5f9d Track out-of-order messages only on first retry
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-06-27 20:36:15 +00:00
ItalyPaleAle 6cf1afc264 Re-add built-in retries to pubsub.hazelcast
See: https://github.com/dapr/components-contrib/issues/1808
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-06-27 20:36:15 +00:00
ItalyPaleAle 35034aa877 Disable built-in retries in pubsub components
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-06-27 20:36:15 +00:00
seeflood 8f04d5d15d
must have `redisHost` (#1814)
Signed-off-by: seeflood <349895584@qq.com>
2022-06-23 17:06:20 -07:00
Sky Ao cfdba5ee1d
change some parameters to wait for kafka ready (#1806)
Signed-off-by: Sky Ao <aoxiaojian@gmail.com>
2022-06-21 09:12:33 -07:00
Sky Ao 0b2e48a4da
Fix kafka binding consumer rebalance (#1804)
* improve log of kafkaf components cert test

Signed-off-by: Sky Ao <aoxiaojian@gmail.com>

* add close() method to kafka binding component to fix the consumer rebalance bug

Signed-off-by: Sky Ao <aoxiaojian@gmail.com>

Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-06-21 06:56:09 -07:00
shiling02404 6d0636ebab
add id when registering services to consul (#1802) 2022-06-21 06:41:07 -07:00
Bernd Verst ccf6111892
Do not continue workflow on error (#1803)
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-06-20 21:14:22 -07:00
Bernd Verst 7bc20c6cde
Update certification workflow (#1801) 2022-06-20 17:01:04 -07:00
tanvigour 55a3d7f7d4
Complete Eventhubs bindings certification test (#1716)
* Complete Eventhubs bindings certification test

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* check if single test point runs all good

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* check if single test point runs all good

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* increase the sleep time to fix timeout

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* increase the sleep time to fix timeout

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* increase sleep for all other testpoints too

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* test behavior of single partition test

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* delete eventhub and container afer run

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* delete eventhub and container afer run

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* delete eventhub and container afer run

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* test reconnection in one test point only

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* test reconnection in one test point only

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* test reconnection in one test point only

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* test reconnection in one test point only

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* test reconnection in one test point only

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* delete the container after every test run for cleanup

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* run service principal test

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* Go mod tidy-all

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* revert back changes to last clean state

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* add unique consumer id per component yaml

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* remove consumer id from singlepartition test component yaml

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* remove repetitive test case, test service principal case

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* remove repetitive test case, test service principal case

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* test iothub

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* test iothub

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* run service principal test

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* run service principal test

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* run service principal test

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* run service principal test

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* add connection string to eventhub service principal yaml

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* use a particular partition

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* enable iothub test

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* enable iothub test

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* enable iothub test

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* final cleanup and test run

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* final cleanup and test run

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* final cleanup and test run

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* add test plan readme

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* rollback the bicep change that is not needed

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* make sure through test that a specific partition receives specific data

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* clean the container between two partiton assertions

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* put back partition id in yaml

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* add same level of partition testing for both partitions

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

* address feedback

Signed-off-by: tanvigour <tanvi.gour@gmail.com>

Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-06-20 14:46:49 -07:00
Bernd Verst 9d7f4867b4
Infra changes for Azure Table Storage Certification tests (#1795)
Signed-off-by: GitHub <noreply@github.com>

Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
2022-06-20 10:03:37 -07:00
Sky Ao d6dd10e19d
improve log of kafkaf components cert test (#1800)
Signed-off-by: Sky Ao <aoxiaojian@gmail.com>
2022-06-20 09:49:09 -07:00
Bernd Verst 55888c0d22
update imports for Fossa and Certification test (#1796)
* update imports for Fossa and Certification test

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* modtidy

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-06-17 15:51:22 -07:00
Alessandro (Ale) Segala a08988c25e
Shared implementation for Azure Service Bus subscriptions for binding and pubsub (#1791)
* Moved ASB subscription code to a shared package

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Moved ASBQ binding to use the shared ASB implementation

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Updating Azure Service Bus SDK version

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-06-17 15:12:15 -07:00
Bernd Verst f25b26fc0c
Upgrade to Azure Table Storage Track 2 SDK in State Store and add CosmosDB Table API support (#1792)
* Upgrade to Azure Table Storage Track 2 SDK in State Store

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* make modtidy-all

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* don't panic

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* fix error parsing

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Adds support for empty rowKeys again

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Pin aztables v1.0.1

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Add support for Cosmos DB Table API

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Add Azure Table Storage CosmosDB conformance test

Signed-off-by: GitHub <noreply@github.com>

* Address code review

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Create Table Storage State store subtests

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Address linter issue

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* context instead of ctx

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* load state store in conf tests

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* use cosmosDB mode in cosmosDB test

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Add Azure AD support for Table Storage

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* remove shadow declaration

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* make accountKey optional

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Add options to skip table creation

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-06-17 14:04:53 -07:00
Yaron Schneider 4727ea8b33
add json tags to lock requests/responses (#1788)
Signed-off-by: yaron2 <schneider.yaron@live.com>
2022-06-14 14:36:10 -07:00
Christian Kaps 6f159394b7
Update to Camunda Platform 8 (#1787)
Signed-off-by: Christian Kaps <ck-github@mohiva.com>

Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-06-14 10:01:41 -07:00
deepanshuagarwal a0ef46265b
Adding Pinger interface and Removing mandatory nature of Ping fuction (#1784)
* add `Pinger` interface.

Signed-off-by: chanyong.moon <dev.chanyongmoon@gmail.com>

* Convert Ping fuction to optional

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Removing unrequired Ping implementations

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Addressing comments

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

Co-authored-by: chanyong.moon <dev.chanyongmoon@gmail.com>
2022-06-14 08:27:54 -07:00
Bernd Verst 83a76d556a
Upgrade Apache Dubbo again - pin to Dapr support branch (#1786) 2022-06-13 19:10:51 -07:00
Loong Dai 419e296d35
middleware: add wasm basic (#1747)
* middleware: add wasm basic

Signed-off-by: Loong <loong.dai@intel.com>

* Update middleware/http/wasm/basic/basic.go

* Update middleware/http/wasm/basic/basic.go

Co-authored-by: Taction <zchao9100@gmail.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-06-13 12:18:06 -07:00
Yaron Schneider 8728f8a4c9
add file upload to s3 (#1785)
Signed-off-by: yaron2 <schneider.yaron@live.com>
2022-06-13 11:48:50 -07:00