dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
3,297 Commits 54 Branches 155 Tags 80 MiB
Commit Graph

10 Commits

Author SHA1 Message Date
Yaron Schneider 1dc20e6c69
Add schema support to apache pulsar (#2475) 
* add schema support to apache pulsar

Signed-off-by: yaron2 <schneider.yaron@live.com>

* linter and avro support

Signed-off-by: yaron2 <schneider.yaron@live.com>

* fix nit

Signed-off-by: yaron2 <schneider.yaron@live.com>

* fix go.mod

Signed-off-by: yaron2 <schneider.yaron@live.com>

* update cert test go.mod

Signed-off-by: yaron2 <schneider.yaron@live.com>

* update cert test metadata to latest

Signed-off-by: yaron2 <schneider.yaron@live.com>

* schema identifier refactor to handle edge case

Signed-off-by: yaron2 <schneider.yaron@live.com>

* fix shadow

Signed-off-by: yaron2 <schneider.yaron@live.com>

Signed-off-by: yaron2 <schneider.yaron@live.com>
 2023-01-26 13:10:58 -08:00
addjuarez e2598e56cc Add pulsar cert tests 
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
 2023-01-09 15:06:27 +00:00
Joni Collinge 382f84f30c
Add support for Azure Service Bus sessions for topics (#2346) 
* WIP: ASB sessions

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* WIP: Support ASB sessions

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Add metadata

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* remove dead code

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* lint

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Add sessionIdleTimeoutInSec md

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Support blank session IDs

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* If require sessions and no session id, set blank

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* move session config to per subscription metadata

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* add some unit tests

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* lint

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* remove auto blank session id

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* go mod tidy

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* add basic cert test

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* update comment

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* remove dead code

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* remove dead code

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Update certification test

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Add comment

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Add cert test for roundrobin

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* go mod tidy

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Update readme

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Use struct for NewSubscription to simplify parameters

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Address feedback

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Address feedback

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Only async receive

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* isTruthy on map without check

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Use if not select for context check

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Feedback

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* lint

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

Signed-off-by: Joni Collinge <jonathancollinge@live.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-06 09:59:26 -08:00
Bernd Verst d7dd4799d0 ASQ Binding: Cert Test: Add queue visibilityTimeout test 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-16 15:28:10 -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
Shivam Kumar 107713ead2 Fixing Certification tests failure (#1447) 
* Adding Remove functionality in watcher

Signed-off-by: shivam <shivamkm07@gmail.com>

* Updating MQTT test docker-compose

Signed-off-by: shivam <shivamkm07@gmail.com>

* Removing message in case of pub failure

Signed-off-by: shivam <shivamkm07@gmail.com>

* Adding MQueue_len=0

Signed-off-by: shivam <shivamkm07@gmail.com>

* Removing message in pub failure: kafka

Signed-off-by: shivam <shivamkm07@gmail.com>
 2022-03-11 09:50:21 +05:30
Dmitry Shmulevich c7adb917f3
update license to Apache v2.0 (#1406) 2022-01-04 19:53:31 -08:00
halspang 3395bb7316
Add certification tests for ASB Queue binding (#1251) 
* Add certification tests for ASB Queue binding

This commit adds certification tests for the Azure Service Bus Queue
Input/Output binding. This utilizes the new certification framework
and performs a series of tests as described in the test plan readme.

The general purpose of these tests is to serve as an integration test
and as such requires an actual Azure Service Bus connection and a
Dapr sidecar.

https://github.com/dapr/components-contrib/issues/957

* Add to github workflow and fix formatting

* Fix dependencies

Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
 2021-12-06 11:20:53 -08:00
Phil Kedy 9a3fe3f683
Kafka certification: Adding infra and network interruption tests (#1241) 
* Adding infra and network interruption tests

* Tweak

* Using multierr.Combine

* Adding consumeRetryInterval setting to Kafka pubsub component
 2021-10-27 17:41:27 -07:00
Phil Kedy 698ffb5bfe
Initial certification testing "framework" (#1204) 
* WIP

* tweaks

* Simplifying runnables

* Increase network timeout

* tweaks

* More tweaks

* Docker compose and structural tweaks

Co-authored-by: tanvigour <60332928+tanvigour@users.noreply.github.com>

* Tweak

* Working Kafka test

* Watcher ordered vs unordered

* Error simulation

* Made port explicit, removed Redis

* package.Run (better naming)

* terraform related changes

* Restructuring certification testing

* Remove copied go-sdk client package

* Fix terraform.go build issues

* Using master of go-sdk

* Using main of go-sdk

* Tweaks per PR

* Adding file headers and some tweaks per PR

* More tweaks

* More comments in Kafka test

Co-authored-by: tanvigour <60332928+tanvigour@users.noreply.github.com>
Co-authored-by: Tanvi Gour <tanvi.gour@gmail.com>
Co-authored-by: tanvigour <>
Co-authored-by: Long Dai <long.dai@intel.com>
Co-authored-by: Simon Leet <31784195+CodeMonkeyLeet@users.noreply.github.com>
 2021-10-20 10:57:47 -07:00