dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
2,675 Commits 55 Branches 159 Tags 84 MiB
Commit Graph

480 Commits

Author SHA1 Message Date
ItalyPaleAle 8365df0f07 Fix flaky RabbitMQ certification tests 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-26 22:09:35 +00:00
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
Bernd Verst 7f7362e620
Merge branch 'master' into update-deps 2023-01-26 09:28:29 -08:00
ItalyPaleAle fd5768032f 💄 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-26 01:24:47 +00:00
ItalyPaleAle cabfd3c570 Updated dependencies 
Most notable: `github.com/hashicorp/golang-lru` to `/v2`

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-26 01:10:48 +00:00
ItalyPaleAle dbf8426993 Updated mqtt binding too 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-25 23:47:30 +00:00
ItalyPaleAle 0148329c6c Added "unsubscribeOnClose" 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-25 20:22:11 +00:00
ItalyPaleAle 5a741da8b0 Some changes and fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-25 19:33:20 +00:00
ItalyPaleAle 2421567997 Refactored pubsub.mqtt to better handle subscribptions and fix bugs 
- Uses a single connection for consumer and publisher
- Avoids reconnecting when the list of subscriptions changes
- Fixes re-subscribing after a connection is dropped

Fixes #2229
Fixes #2350

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-25 05:36:38 +00:00
ItalyPaleAle 232c8d813f Working on binding 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-21 19:28:00 +00:00
ItalyPaleAle 857a865e4e Moved implementation to shared package 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-21 01:14:04 +00:00
ItalyPaleAle ab7f9aa509 💄 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 23:20:58 +00:00
ItalyPaleAle a0251482c2 Create the storage container if it doesn't exist (to preserve compatibility with old SDK's behavior) 
Also fixes to tests

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 23:09:48 +00:00
ItalyPaleAle c76526c805 Fixed unit tests 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 21:34:55 +00:00
ItalyPaleAle 827c949c99 Address review comments 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 21:34:03 +00:00
ItalyPaleAle d97dac3b98 Fixes for Azure AD auth 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 20:37:59 +00:00
ItalyPaleAle c83919a49d Removed vendored conn library 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 19:34:01 +00:00
ItalyPaleAle 0649d5fae9 Updated tests 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 19:00:15 +00:00
ItalyPaleAle 462d7a95be Remove old file 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 18:10:40 +00:00
ItalyPaleAle 7153e75549 Do not.... crash twice 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 17:53:38 +00:00
ItalyPaleAle 2c98c8ef25 💄 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 17:50:05 +00:00
ItalyPaleAle fcfcbe9d87 Handle smooth upgrade from Track 1 SDKs 
(If you consider crashing Dapr on purpose "smooth" 🤣)

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 17:46:38 +00:00
ItalyPaleAle 8d679f06f9 Working on upgrading from track1 SDKs 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 16:59:27 +00:00
ItalyPaleAle 01e7d4167b Do not retry forever by default 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 04:24:35 +00:00
ItalyPaleAle 885fb5a2d4 Re-implemented BulkPublish 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 04:15:18 +00:00
ItalyPaleAle 9729c155c1 Retry failed messages + other fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 00:47:24 +00:00
ItalyPaleAle c10173b29f Added entity management 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 00:18:22 +00:00
ItalyPaleAle 4c12f40534 WIP 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-19 22:33:50 +00:00
ItalyPaleAle 445f2e4940 Receiving events 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-19 21:36:20 +00:00
ItalyPaleAle 093669e8a8 WIP 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-19 20:12:00 +00:00
ItalyPaleAle 48dd1dabef Working on subscribing 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-19 01:27:48 +00:00
ItalyPaleAle 130afe5c1a Merge branch 'master' of https://github.com/dapr/components-contrib into eventhubs-track2 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-19 00:13:26 +00:00
ItalyPaleAle 0157bf0b72 WIP 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-19 00:12:10 +00:00
Shivam Kumar fd7dfe63ef
Fix mqtt pubsub: remove republishing when application is unhealthy (#2446) 
* Remove re-publishing in case of failures

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

* Remove maxRetriableErrorsPerSec field in metadata

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

* Remove backoffmaxretries from cert test

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

* go mod changes

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

* Testing higher value of timeout

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

* Testing even higher value of timeout

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

* Testing even higher value of timeout

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

* Resetting timeout

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

* Removing mosquitto from pubsub conformance

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

* Update pubsub/mqtt3/metadata.go

Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Bernd Verst <github@bernd.dev>

Signed-off-by: shivam <shivamkm07@gmail.com>
Signed-off-by: Shivam Kumar <shivamkm07@gmail.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
 2023-01-18 15:53:45 -08:00
ItalyPaleAle 2afca71c2a Renamed mqtt components to mqtt3 
Fixes #2359

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-13 09:51:30 -08:00
Tomasz Pietrek 766b2df2fe
Fix heartbeat typo (#2430) 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
Co-authored-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
 2023-01-12 11:21:05 -08:00
ItalyPaleAle 9ef0bb9441 mapstructure fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-10 20:41:50 +00:00
ItalyPaleAle eaa74d77d9 Metadata parsing 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-10 18:51:50 +00:00
Deepanshu Agarwal b2d8e6013b
Add bulkSubscribe request params to SubscribeRequest (#2405) 
* Add bulkSubscribe configuration params

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

* Replace dapr/dapr package to run cert tests

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

* Change bulkSubscribe param types

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

* Update latest dapr/dapr fork

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

* Update correct dapr/dapr version

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

* change BulkSubscribeRequest to Config

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

* Update dapr/dapr version for cert

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

* Update with latest dapr fork

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

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
 2023-01-10 09:30:25 -08: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 54b5f7471c
Merge branch 'master' into master 2023-01-04 15:10:10 -08:00
spike e61e170c7c
Use message's retain property to cover meta's (#2377) 
* Use message's retain property to cover meta's

Signed-off-by: spike <hello@spike.wiki>

* Add test cases for mqtt publish method

Signed-off-by: spike <hello@spike.wiki>

* Fix lint issues

Signed-off-by: spike <hello@spike.wiki>

* Fix lint issues

Signed-off-by: spike <hello@spike.wiki>

* Close channels individually

Signed-off-by: spike <hello@spike.wiki>

Signed-off-by: spike <hello@spike.wiki>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
 2023-01-04 15:05:25 -08:00
Bernd Verst d56057a649
Merge branch 'master' into master 2023-01-04 14:40:37 -08:00
Bernd Verst be093538f7
Merge branch 'master' into master 2023-01-04 14:35:59 -08:00
Tomasz Pietrek 97ad52c692 Make domain and prefix setup cleaner 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2023-01-04 10:48:32 +01:00
Tomasz Pietrek 94894c465b Add domain and apiPrefix for JetStream 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2023-01-04 09:18:35 +01:00
TKTheTechie 5cd02e8c78 Update of amqp go library 
Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-28 23:28:25 -05:00
Bernd Verst 9845a76288 Merge remote-tracking branch 'upstream/master' into solacese/master 2022-12-28 17:39:08 -08:00
Bernd Verst e794fb9529
Merge branch 'master' into master 2022-12-28 16:42:34 -08:00
TKTheTechie 9c28641594 Fixing linting issues, conformance infrastructure 
* Fixing linting issues
* Adding infrastructure to .github/workflows
* Fixing conformance tests config to account for default anonymous config on the event broker

Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-23 08:58:41 -05:00