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

569 Commits

Author SHA1 Message Date
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
Yaron Schneider c687bf0fd8
Merge branch 'master' into multiEnv_awsSqsSns 2023-01-16 09:15:19 -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
Yaron Schneider ead15aee01
Merge branch 'master' into multiEnv_awsSqsSns 2023-01-05 05:54:04 -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
Bernd Verst ebe5511b32
Merge branch 'master' into multiEnv_awsSqsSns 2022-12-29 14:17:12 -08: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
Davide Boldrin 27427f202b fix bug multi environment on aws sqs/sns #2364 
Signed-off-by: Davide Boldrin <davi1994@hotmail.it>

Signed-off-by: Davide Boldrin <d.boldrin@crif.com>
 2022-12-23 09:25:02 +01:00
TKTheTechie a5dfcb80fa Allowing anonymous connections 
Updating rule to allow an anonymous connection without credentials

Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:22 -05:00
TKTheTechie 57c2324670 Refactoring package names 
Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:22 -05:00
TKTheTechie 338bc03e9e Update amqp.go 
Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:22 -05:00
TKTheTechie d7f4933bbb Update amqp.go 
Support topic subscriptions

Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:21 -05:00
TKTheTechie 619c35693e Adding conformance tests 
Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:21 -05:00
TKTheTechie 2039a30de7 AMQP Plugin 
Initial cut of the AMQP 1.0 Plugin

Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:21 -05:00
Mukundan Sundararajan cff6d7b6b1 Merge remote-tracking branch 'upstream/master' into optimize-bulkpubres-struct 2022-12-20 23:04:19 +05:30
mecoding1 6237f4eada
Fix lint issues for eventhubs_integration_test.go 
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-12-20 18:56:10 +05:30
mecoding1 64b1a599ca
Fix lint issues across the file 
Fix lint issues across the file

Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-12-20 12:37:41 +05:30
Bernd Verst 8b3672c91e
Merge branch 'master' into feat/rabbitmq-tls 2022-12-19 15:31:47 -08:00
Bernd Verst a7d1e9e250
Merge branch 'master' into master 2022-12-19 15:02:32 -08:00
ItalyPaleAle fc00023206 Small naming fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-12-19 22:03:53 +00:00
mecoding1 0f6aedfd1c
Fix linting issue 
Fix linting issue

Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-12-19 14:44:04 +05:30
seachen 5dda098868 feature: add context to lock&pubsub API 
Signed-off-by: seachen <seachen@tencent.com>
 2022-12-19 09:11:53 +08:00
Mukundan Sundararajan b7817c0ee7 Merge branch 'master' into optimize-bulkpubres-struct 2022-12-17 11:05:39 +05:30
Bernd Verst 3e08736911
Add support for Redis 7 in all Dapr Components (#2228) 
* Add support for Redis 7

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

* Add Redis 7 to conformance tests

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

* automatically detect redis version, make redis7 state conformant

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

* Additions for REDIS without JSON support

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

* Return helpful query API error when missing redis-json

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

* Change Redis 7 port for conformance test

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

* Fix nil reference

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

* Update Redis7 port

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

* Enable ContextTimeoutEnabled for Redis v9 client

Co-Authored-By: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Add timeouts, address code review

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

* Add another timeout

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

* Redis: so much more context

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

* modtidy

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

* fix issue from latest merge

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

* modtidy

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

* Add generic redis nil error

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

* fix redis version check

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

* upgrade redis v9 client

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

* Remove flaky redis v7 pubsub conformance test

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

* modtidy

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

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-12-16 14:12:11 -08:00
Bernd Verst 16e1be02d1
Merge branch 'master' into master 2022-12-16 11:54:51 -08:00
Mukundan Sundararajan 0841b3d846 Merge branch 'master' into optimize-bulkpubres-struct 2022-12-15 23:00:34 +05:30
seachen 1ea2cff9fd feature: add context to lock&pubsub API 
Signed-off-by: seachen <seachen@tencent.com>
 2022-12-15 09:53:32 +08:00
Bernd Verst 64a2c3aad1 Revert "revert amqp changes, eventhubs library update" 
This reverts commit b236279d81.
 2022-12-14 16:19:06 -08:00
Tomasz Pietrek 72bd117e7e
Rework JetStream delivery policy (#2315) 
* Rework JetStream delivery policy

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>

* Add missing deliver policies to error

Co-authored-by: Piotr Piotrowski <piotrpiotrowski94@gmail.com>
Signed-off-by: Tomasz Pietrek <melgaer@gmail.com>
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>

* Rearrange imports

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
Signed-off-by: Tomasz Pietrek <melgaer@gmail.com>
Co-authored-by: Piotr Piotrowski <piotrpiotrowski94@gmail.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2022-12-14 15:56:07 -08:00
Yaron Schneider 0b0deea39e
Merge branch 'master' into feat/rabbitmq-tls 2022-12-14 14:34:51 -08:00
seachen e59dfd63c0 feature: add context to lock&pubsub API 
Signed-off-by: seachen <seachen@tencent.com>
 2022-12-14 19:37:24 +08:00
Mukundan Sundararajan 4b1bb38820 Merge branch 'master' into optimize-bulkpubres-struct 2022-12-14 10:52:40 +05:30
Mukundan Sundararajan ace0d1a03c changed to failed entries for bulk publish response 
Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
 2022-12-13 16:22:45 +05:30
Mukundan Sundararajan 72695529f6 optimize bulk pub response to contain only failed entries 
Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
 2022-12-13 11:49:04 +05:30
spike 6254982cd7 Raise error if protocol does not match connection string 
Signed-off-by: spike <hello@spike.wiki>
 2022-12-06 22:27:54 +08:00
Tomasz Pietrek 9df618959e Fix formatting 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2022-12-05 17:56:02 +01:00
Tomasz Pietrek d2e3a7e533 Test ack policies metadata 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2022-12-05 17:47:35 +01:00
Tomasz Pietrek 0e80570949 Fix typo 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2022-12-05 15:57:14 +01:00
Tomasz Pietrek 3a8a9a0ef6 Fix error handling in Ack 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2022-12-05 14:33:12 +01:00
Tomasz Pietrek 0463c2cf8b Adopt handler to work properly with each ack policy in NATS 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2022-12-05 14:19:13 +01:00
Tomasz Pietrek 7ec2b8608f Add ack policy to NATS pub/sub 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2022-12-05 14:15:00 +01:00
Bernd Verst f656319740
Merge branch 'master' into feat/rabbitmq-tls 2022-12-02 13:54:50 -08:00
Tomasz Pietrek 86cf34ef8f
Add missing filter subject in Jetstream pubsub (#2312) 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
 2022-11-30 10:46:15 -08:00
thielepaul 47b0d73676
Add mqtt retained information to pubsub message metadata (#2299) 
Signed-off-by: Paul Thiele <thielepaul@gmail.com>

Signed-off-by: Paul Thiele <thielepaul@gmail.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
 2022-11-29 10:06:20 -08:00
Deepanshu Agarwal a6289ccff2 Ack Retained Message too 
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
 2022-11-24 18:36:44 +05:30
mecoding1 71d7acb506
Fix lint issue for eventshub.go 
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-23 10:48:59 +05:30
mecoding1 a410556364
Fix lint issue for eventshub.go 
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-23 09:59:49 +05:30
mecoding1 94ae646a03
Add requireAllProperties metadata to the subscribe request. 
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-23 09:57:03 +05:30
mecoding1 093b6aa525 Add custom application properties to tests/certification/pubsub/azure/eventhubs/send-iot-device-events.sh 
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-22 12:48:19 +00:00
mecoding1 20a004b6a7 Asserting that added custom application property is received 
Asserting that added custom application property is received

Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-22 12:48:19 +00:00
mecoding1 3b6712c68f Fix lint issues. 
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-22 12:48:19 +00:00
mecoding1 9e51ac90e4 Update eventHubs.go for lint fix ST1023: 
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-22 12:48:19 +00:00
mecoding1 a669c4733b Updating eventshub.go, to ensure receiving custom properties from IoT Hub 
Currently, we can receive only the system properties from iot hub. Done changes should allow the retrieval of all custom properties.
It is based on metadata key : requireAllProperties.

By default it is false, if true , looks into the , Properties of Event struct to retrieve the custom properties.

Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-22 12:48:19 +00:00
Armin Schlegel 0bbc8c42d6 jetstream pubsub now supports token based auth (#2295) 
Signed-off-by: Armin Schlegel <armin.schlegel@gmx.de>

Signed-off-by: Armin Schlegel <armin.schlegel@gmx.de>
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-22 12:48:19 +00:00
spike 17bc6e14b5 Merge branch 'feat/rabbitmq-tls' of git-spike:anoymouscoder/components-contrib into feat/rabbitmq-tls 2022-11-20 15:34:07 +08:00
spike 55a06c40c4 Optimize code according to lint 
Signed-off-by: spike <hello@spike.wiki>
 2022-11-20 15:33:53 +08:00
Bernd Verst 237d963e45
Merge branch 'master' into feat/rabbitmq-tls 2022-11-18 13:51:42 -08:00
Armin Schlegel 103624468f
jetstream pubsub now supports token based auth (#2295) 
Signed-off-by: Armin Schlegel <armin.schlegel@gmx.de>

Signed-off-by: Armin Schlegel <armin.schlegel@gmx.de>
 2022-11-17 23:28:18 -08:00
Bernd Verst f5ab3d93eb
Merge branch 'master' into feat/rabbitmq-tls 2022-11-17 12:47:56 -08:00
ItalyPaleAle 1e728597b4 Misc refactorings 
- Removed `state.DeleteWithOptions` and `state.SetWithOptions` which were useless at this point (likely a leftover from when there were retries)
- Some improvements in etag handling in postgres
- Other minor refactorings

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-11-17 16:29:29 +00:00
spike 6937857bf8 Change error message and comment 
Signed-off-by: spike <hello@spike.wiki>
 2022-11-13 15:34:01 +08:00
spike 1d9f3358e4 Add rabbitmq tls metadata 
Signed-off-by: spike <hello@spike.wiki>
 2022-11-13 15:17:50 +08:00
Bernd Verst 462e2faadc Upgrade linter and fix linter issues 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-11 13:19:57 -08:00
Taction 9870c5e33b
Add pubsub rabbitmq TTL support (#2093) 
* Add pubsub rabbitmq TTL support

Signed-off-by: zhangchao <zchao9100@gmail.com>

* fix review: remove queue level ttl, both ttl is handled when publishing, to make message ttl has priority over queue level ttl

Signed-off-by: zhangchao <zchao9100@gmail.com>

* add rabbitmq ttl certificate test

Signed-off-by: zhangchao <zchao9100@gmail.com>

* fix lint

Signed-off-by: zhangchao <zchao9100@gmail.com>

* fix ttl certificate test precreate topic

Signed-off-by: zhangchao <zchao9100@gmail.com>

* tiny fix tests

Signed-off-by: zhangchao <zchao9100@gmail.com>

Signed-off-by: zhangchao <zchao9100@gmail.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-11 11:34:33 -08:00
Bernd Verst e5a2266fa8 Address lint issues 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-10 12:23:04 -08:00
Bernd Verst 9a8bcc5fa5
Merge branch 'master' into explicitly-add-consumer 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-10 12:05:51 -08:00
jinjianfeng-chn 875abcda56
Add rocketmq configuration items. Add orderly message. (#2198) 
* Add rocketmq configuration items. Add orderly message. Change the version of rocketmq-client-go to v2.1.0.

Signed-off-by: jinjianfeng-chn <feng081212@163.com>

* modtidy

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

Signed-off-by: jinjianfeng-chn <feng081212@163.com>
Signed-off-by: Bernd Verst <4535280+berndverst@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-11-10 11:54:40 -08:00
yaron2 1f2c987c86 linter 
Signed-off-by: yaron2 <schneider.yaron@live.com>
 2022-11-10 10:32:24 -08:00
yaron2 beaa223bc2 fix deletion of sqs queue regression 
Signed-off-by: yaron2 <schneider.yaron@live.com>
 2022-11-10 10:08:35 -08:00
Nick ce87730a73
pubsub jetstream: set Nats-Msg-Id for message deduplication (#2200) (#2202) 
Signed-off-by: NickLarsenNZ <nick@aptiv.co.nz>

Signed-off-by: NickLarsenNZ <nick@aptiv.co.nz>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-08 19:49:34 -08:00
Bernd Verst 6df7f09927 Fix linter issues, update test config, rebase upstream 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-02 15:15:45 -07:00
Bernd Verst bfc482d3e4 Merge remote-tracking branch 'upstream/master' into kubemq-io/master 2022-11-02 15:14:33 -07:00
Bernd Verst d562e37a67
Merge branch 'master' into pubsub 2022-10-31 16:16:27 -07:00
Alessandro (Ale) Segala 6b0183244f
Add note that pubsub.hazelcast is deprecated (#2240) 
See #1808

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

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-10-31 13:32:54 -07:00
Alessandro (Ale) Segala e715c169b5
Merge branch 'master' into explicitly-add-consumer 2022-10-31 13:27:27 -07:00
Tomasz Pietrek 54cb93c786 Cleanup the opts 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2022-10-31 21:07:36 +01:00
Tomasz Pietrek 83d7d09ab8 Explicitly use AddConsumer 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2022-10-31 20:11:17 +01:00
Tomasz Pietrek e04a44895f Cleanup debugs 2022-10-31 16:43:38 +01:00
Tomasz Pietrek efe706a41d wip on binding by name 2022-10-31 12:52:38 +01:00
Bernd Verst 0819efca5a fix typo in comment 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-10-27 20:37:35 -07:00
Bernd Verst 47a46673cd PubSub: Fall back to 'consumerID' when group not present 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-10-27 14:08:37 -07:00
Alessandro (Ale) Segala 04242ce38a
New PubSub component: Azure Service Bus Queues (#2211) 
* Implementation for Azure Service Bus Queue pubsub component

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

* Fixed syntax errors in unused files

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

* Moved components to subfolders and enabled conf tests

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

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-10-24 14:07:23 -07:00
Lior Nabat 2e3a46e04d Update - Add new PubSub component - KubeMQ Kubernetes message broker 
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
 2022-10-23 08:21:08 +03:00
lior.nabat@kubemq.io 04f4f697fd Add new PubSub component - KubeMQ Kubernetes message broker 
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
 2022-10-22 22:30:16 +03:00
Lior Nabat bed3d69a6f Add new PubSub component - KubeMQ Kubernetes message broker 2022-10-22 18:51:11 +03:00
shivam bbae625746 Fix linter error 
Signed-off-by: shivam <shivamkm07@gmail.com>
 2022-10-21 15:06:26 +05:30
shivam 8533feb87f Upgrade mqtt component to upstream 
Signed-off-by: shivam <shivamkm07@gmail.com>
 2022-10-21 14:39:46 +05:30
ItalyPaleAle 254a2141ad Moved sender handling to common implementation too 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-10-19 21:01:15 +00:00
ItalyPaleAle 8013d96ad6 More tweaks 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-10-19 20:39:56 +00:00
ItalyPaleAle 065ef86ee5 Moved client creation to common implementation 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-10-19 20:34:10 +00:00
ItalyPaleAle 7ecfb6edd0 Moved code to add metadata to ASB messages to shared impl too 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-10-19 20:08:07 +00:00
ItalyPaleAle 8bce0d5200 Moved metadata to impl package 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-10-19 19:47:26 +00:00
ItalyPaleAle 0057a31b88 Moved errors 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-10-18 21:51:17 +00:00
Dapr Bot 961aa9da72
Merge branch 'master' into merge19intomaster 2022-10-14 13:56:59 -07:00
Bernd Verst 0f0aaf4e9b Merge remote-tracking branch 'upstream/master' into merge19intomaster 2022-10-14 12:16:57 -07:00
ItalyPaleAle 4de7a2fc9d The people demand defers 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-10-12 18:46:38 +00:00
ItalyPaleAle 047f3948c5 Fix for handling "context deadline exceeded" on ASB publishing 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-10-12 18:18:33 +00:00
Tomasz Pietrek 954164216e Fix another lint error 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2022-10-12 11:50:49 +02:00
Tomasz Pietrek 7a3746b33a Fix lint errors 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2022-10-12 11:44:00 +02:00
Tomasz Pietrek 84742aa1a8 Add more JetStream options 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2022-10-12 11:23:03 +02:00
ItalyPaleAle 3bc20a1de5 Merge branch 'master' into merge-1.9 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-10-11 20:26:35 +00:00
Alessandro (Ale) Segala ef74e7f8b6
Azure Service Bus: consider receiving 0 messages as an error that requires reconnecting (#2169) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-10-11 12:57:06 -07:00
Bernd Verst f137bc7373 rabbitmq: use ctx for publishing 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-10-10 14:37:21 -07:00
Deepanshu Agarwal f74b4d648d Update EntryID to EntryId 
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
 2022-09-29 15:49:45 +05:30
Shubham Sharma d29c0d6200
Add ctx to BulkPublish API (#2134) 
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
 2022-09-28 09:55:47 -07:00
deepanshuagarwal bcd101abad
Keys rename (#2135) 
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
 2022-09-28 09:52:59 -07:00
Mukundan Sundararajan fbde4c706b
Merge branch 'master' into feature/pubsub-batching 2022-09-27 08:15:37 +05:30
Yash Nisar ad5397ea25
Add time to CloudEvent automatically if not present (#2123) 
Closes https://github.com/dapr/dapr/issues/5137

Signed-off-by: Yash Nisar <yashnisar@microsoft.com>

Signed-off-by: Yash Nisar <yashnisar@microsoft.com>
 2022-09-26 14:44:57 -07:00
Mukundan Sundararajan 803c0591c2
Merge branch 'master' into feature/pubsub-batching 2022-09-25 12:35:33 +05:30
Mario Reggiori b0d267317d
Add individual connection arguments to pubsub.rabbitmq metadata (#2129) 
Signed-off-by: Mario Reggiori <git@marioreggiori.com>

Signed-off-by: Mario Reggiori <git@marioreggiori.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
 2022-09-23 23:37:09 -07:00
ItalyPaleAle 4724a38a01 MQTT: Add metadata options "producerID" 
Fixes dapr/dapr#5235

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-09-23 18:46:27 +00:00
Shubham Sharma cd206609ce
Use request metadata instead of component metadata (#2119) 
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
 2022-09-23 10:49:39 -07:00
Shubham Sharma 4f406a597f
Add bulk subscribe support to Azure Service Bus (#2100) 
* Initial implementation

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* ✅

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Add tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Add comment

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor messages.go and add tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update message tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor servicebus.go logic

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor handleAsync

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor ReceiveAndBlock

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update binding

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Review comments addressed

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Lint

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update metadata name

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update activeMessagesChan logic for concurrency control

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Fix tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update metadata name

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Use request metadata instead of component metadata

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Review comments addressed

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Fix merge issue with metadata

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Remove unused metadata key

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Fix merge issue with metadata

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Lint!!!

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
 2022-09-23 10:49:06 -07:00
Shubham Sharma b298b65cfe
Add bulk publish support to Azure Service Bus (#2106) 
* Initial implementation

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Some improvements

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor and add tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Lint

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Use request metadata instead of component metadata

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Remove unused method

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Review comments addressed

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Doc comments

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
 2022-09-23 09:57:00 -07:00
deepanshuagarwal 8500da577c
Conf test for Bulk Subscribe and Kafka fixes (#2113) 
* Conf test for Bulk Sub and Kafka Fixes

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

* Fix linting

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

* Incorporating comments

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

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
 2022-09-23 09:54:21 -07:00
Mukundan Sundararajan e1697ba115 Merge branch 'master' into feature/pubsub-batching 2022-09-23 06:47:47 +05:30
mandarj123 e7be027c28
Update mqtt.go 
Signed-off-by: mandarj123 <mandar.jogalekar@capgemini.com>
 2022-09-22 10:02:08 +05:30
mandarj123 7ea805a83e
Update mqtt.go 
remove mandatory "-producer" to clientId

Signed-off-by: mandarj123 <mandar.jogalekar@capgemini.com>
 2022-09-21 16:53:53 +05:30
Mukundan Sundararajan a45f7db8b2 add bulkpublish-conf-test 
Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
 2022-09-21 11:46:46 +05:30