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

572 Commits

Author SHA1 Message Date
halst 42583085ce
Add kitex output binding (#2563) 
Signed-off-by: liusong <liusongstep@gmail.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-03-16 16:59:03 +00:00
Andre Bossard d87f4bb5a1
RabbitMQ: Support for external authentication with SASL (#2515) 
Signed-off-by: Andre Bossard <anbossar@microsoft.com>
Signed-off-by: Andre Bossard <abossard@users.noreply.github.com>
Co-authored-by: Andre Bossard <anbossar@microsoft.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2023-03-16 16:30:54 +00:00
ItalyPaleAle c20ab76972 Merge branch 'master' of https://github.com/dapr/components-contrib into merge-release-1.10-master 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-03-15 19:25:12 +00:00
Vishal Kumar 9e30be0192
Adding GetDel support for Redis Bindings (#2662) 
Signed-off-by: Vishal Kumar <vkgkrt@gmail.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-03-14 17:57:16 +00:00
Bernd Verst 575567e30f
Add `connectionString` metadata option for MongoDB (#2659) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-03-14 16:40:17 +00:00
bingo1229 cfb4d7ecc9
Add partition support for pulsar (#2647) 
Signed-off-by: oops-oom <734819342@qq.com>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2023-03-14 16:37:31 +00:00
Shivam Kumar 997e6f49d5
Certification test for redis config store (#2431) 
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>
 2023-03-14 00:23:23 +00:00
Bernd Verst d5d6273ff2
Upgrade `azidentity` to 1.3.0-beta.4 (#2665) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-03-13 20:16:27 +00:00
Alessandro (Ale) Segala d8da5828b9
Fixed race condition in SQLite cert test (#2663) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-03-13 18:40:56 +00:00
Bernd Verst 6feae775e6
Support Increment Operation, TTL in Redis Binding (#2654) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-03-09 21:23:04 +00:00
Josh van Leeuwen 85feb7c3d7
Consolidate SQL expired date garbage collector (#2633) 
Signed-off-by: joshvanl <me@joshvanl.dev>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-03-09 16:40:58 +00:00
Alessandro (Ale) Segala a359dcaad6
Certification test for middleware.http.ratelimit (#2636) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-03-07 20:51:35 +00:00
Bernd Verst 86a39f6c37 Upgrade service bus SDK to 1.2.1 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-03-07 11:53:51 -08:00
Alessandro (Ale) Segala 050ee73d61
Remove now-unused metadata properties (#2637) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-03-06 21:52:58 +00:00
Josh van Leeuwen acb4418271
Consolidate CockroachDB and PostgreSQL into single internal implementation (#2632) 
Signed-off-by: joshvanl <me@joshvanl.dev>
 2023-03-06 21:49:49 +00:00
Bernd Verst f2a9e30cdd
[Maintenance task] upgrade lots of libraries (#2630) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-03-04 00:38:17 +00:00
Bernd Verst d6f35401af
Dapr 1.11: Support Azure CLI Credential for Azure Track 2 components (#2472) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-03-03 21:23:25 +00:00
Josh van Leeuwen 4827d5d119
Adds TTL support to the CockroachDB state. (#2618) 
Signed-off-by: joshvanl <me@joshvanl.dev>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-03-03 14:36:40 +00:00
Bernd Verst 1708951cec Add Cloud Event Protobuf to PubSub Content Types 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-03-02 14:37:18 -08:00
ItalyPaleAle 8cc74c7331 Completed the removal of the Azure SDK track 1 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-27 22:37:23 +00:00
Bernd Verst c634533a83 go mod tidy 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-02-27 12:46:17 -08:00
Bernd Verst 1c48453fef Pin dapr 1.10 in cert test 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-02-24 18:20:03 -08:00
Bernd Verst 7c005d134a Upgrade Azure Storage Queue Binding to Track2 SDK 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-02-24 15:52:03 -08:00
ItalyPaleAle a583271b3f Updated to Go 1.20 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-22 21:19:41 +00:00
joshvanl 77c209e71a Update go.mod in tests/certification/status/mongodb 
Signed-off-by: joshvanl <me@joshvanl.dev>
 2023-02-21 17:23:22 +00:00
Artur Souza 2cbe96ba98
Merge branch 'master' into state-store-ttl-mongodb 2023-02-20 19:44:26 -08:00
Bernd Verst 1b6e16fe41
Merge branch 'master' into state-store-ttl-mongodb 2023-02-17 16:34:25 -08:00
Bernd Verst 3825065c03
Merge branch 'master' into newdeps 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-02-17 15:57:18 -08:00
ItalyPaleAle 28ce086761 Updated pinned dapr/dapr in cert tests 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-17 21:29:39 +00:00
ItalyPaleAle 55b6a04805 Merge branch 'master' of https://github.com/dapr/components-contrib into newdeps 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-17 21:20:45 +00:00
ItalyPaleAle ee78d94587 Merge branch 'master' of https://github.com/dapr/components-contrib into tests-scripts 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-17 21:15:42 +00:00
Alessandro (Ale) Segala a6c37184c2
Merge branch 'master' into state-store-ttl-mongodb 2023-02-17 20:41:12 +00:00
ItalyPaleAle 2ff503a0aa Multiple fixes + updated docs 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-17 19:00:46 +00:00
Alessandro (Ale) Segala 974d2acd4e
Merge branch 'master' into state-store-ttl-mongodb 2023-02-17 17:37:01 +00:00
ItalyPaleAle 6d2a9874ba Prettier 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-17 03:57:10 +00:00
ItalyPaleAle d1a3dc8f39 Fixed SQLite cert tests 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-17 03:33:07 +00:00
ItalyPaleAle d4e4355b03 Removed mod replacement 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-17 01:16:30 +00:00
ItalyPaleAle a484d7ebc7 Merge branch 'master' of https://github.com/dapr/components-contrib into newdeps 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-16 23:35:28 +00:00
ItalyPaleAle f9cf54ca6f Merge branch 'master' of https://github.com/dapr/components-contrib into release-1.10 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-16 23:23:23 +00:00
Josh van Leeuwen d098e38d6a
Propagate context from caller to appropriate places in the code (#2474) 
* Propagates contexts to callers where appropriate.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Updates units tests with new func signature

Signed-off-by: joshvanl <me@joshvanl.dev>

* Fix linting errors

Signed-off-by: joshvanl <me@joshvanl.dev>

* Add atomic gate to alicloud rocketmq close channel.

Signed-off-by: joshvanl <me@joshvanl.dev>

* bindings/aws/kinesis use a separate ctx variable name

Signed-off-by: joshvanl <me@joshvanl.dev>

* binding/kafka: use atomic to prevent closing the channel twice

Signed-off-by: joshvanl <me@joshvanl.dev>

* bindings/mqtt3: use atomic bool to prevent close channel being closed multiple times

Signed-off-by: joshvanl <me@joshvanl.dev>

* bindings/mqtt3: use Background context for handle operations:w

Signed-off-by: joshvanl <me@joshvanl.dev>

* state/cocroachdb: add context to Ping()

Signed-off-by: joshvanl <me@joshvanl.dev>

* bindings/postgres: add comment explaining use of context.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Adds comment header to health/pinger.go

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/aws/snssqs: add waitgroup to wait for all go routines to finish
and block on Close(). Shuts down the subscription if there are no topic
handlers.

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/mqtt3: add atomic bool to prevent multiple channel closes. Add
wait group to block close on all goroutines to finish.

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/rabbitmq: fixes race conditions, uses atomic to prevent multiple
closes, add wait group to block close on all goroutines

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/redis: revert ctx passed when it could be cancelled. Add wait
group wait when closing.

Signed-off-by: joshvanl <me@joshvanl.dev>

* state/postges: pass context in init, and wait group on close.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Update all `Ping()` to `PingContext()` where possible.

Signed-off-by: joshvanl <me@joshvanl.dev>

* state/in-memory: add atomic bool to prevent closing channel multiple
times. Add wait group to block on close()

Signed-off-by: joshvanl <me@joshvanl.dev>

* state/mysql: don't use same ctx variable name

Signed-off-by: joshvanl <me@joshvanl.dev>

* Pass correct loop context to redis go routines

Signed-off-by: joshvanl <me@joshvanl.dev>

* Rename context when creating timeouts in state

Signed-off-by: joshvanl <me@joshvanl.dev>

* Remove state.Features() from requiring a context

Signed-off-by: joshvanl <me@joshvanl.dev>

* Revert wasm request handle Close func to be without context to
implement io.Closer interface. Add 5 second timeout. Add io.Closer
assertion in test.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Remove superfluous go lint vet directive

Signed-off-by: joshvanl <me@joshvanl.dev>

* Change Configuration Init function to take context

Signed-off-by: joshvanl <me@joshvanl.dev>

* Updates input binding interface to include a `Close() error` function. `Close`
blocks until all resources have been released and go routines have returned.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Change `Close() error` in input binding struct to `io.Closer` interface.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Update go.mod files to point to dapr/dapr PR https://github.com/dapr/dapr/pull/5831

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/redis: watch closeCh to shutdown worker instead of init context.

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/aws/snssqs + bindings/kubemq: ensure closeCh is caught so Close
correctly returns

Signed-off-by: joshvanl <me@joshvanl.dev>

* Close kubemq binding client on close. Ensure kafka consumer channel
cannot be closed more than once.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Tweaks

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

* Fixed cert tests

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

* binding/mqtt3: add inline Background context instead of passing to
handleMessage

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/mqtt3: remove context from createSubscriberClientOptions

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/mqtt3: Remove `ResetConnection` func

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/kafka: Don't resubscribe if Subscribe is cancelled.

Signed-off-by: joshvanl <me@joshvanl.dev>

* binding/mqtt3: don't use context to control establishing connection

Signed-off-by: joshvanl <me@joshvanl.dev>

* bindings/mqtt3: Fix linting errors

Signed-off-by: joshvanl <me@joshvanl.dev>

---------

Signed-off-by: joshvanl <me@joshvanl.dev>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2023-02-16 14:18:35 -08:00
joshvanl 1a3e267d5d Adds review comments. Filter on TTL when getting documents. Add test to 
ensure data is deleted.

Signed-off-by: joshvanl <me@joshvanl.dev>
 2023-02-16 18:18:23 +00:00
ItalyPaleAle 8686fd35b5 Updated more deps 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-16 00:32:26 +00:00
joshvanl 7402ff5cf9 Add TTL support to mongodb state store 
Signed-off-by: joshvanl <me@joshvanl.dev>
 2023-02-15 16:43:27 +00:00
Alessandro (Ale) Segala 12acf8effe
[release-1.10] Azure Service Bus: fix goroutine "explosion" after recovering from failure and many other bugs (#2523) 
* Fixed context leak

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

* Finalize messages in background

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

* More tweaks

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

* Moved a lot more code to the shared implementation package

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

* Fixed:
- Fixed: if number of messages received in bulk is greater than maxConcurrentHandlers, a deadlock happens
- Fixed: maxRetriableErrorsPerSec was not working

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

* Some refactorings

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

* Simplifications

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

* Avoid checking if topic/queue exists every time we send a message

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

* Ensuring locks are renewed for all 3 components

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

* Updated ASB SDK

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

* Improvements to closing

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

* Improvements to closing

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

* Changed context propagation

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

* Debug logs in cert tests

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

* Initial delay before renewing locks

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

* That last change was actually unnecessary

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

* Tweaks

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

* More tweaks

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

* 💄

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

---------

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-13 09:23:03 -08:00
Bernd Verst 785033b03e Move vendor neutral OSS components 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-02-09 16:20:15 -08:00
ItalyPaleAle 9920d53f93 Changed SQLite metadata parsing per review feedback 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-08 23:05:01 +00:00
ItalyPaleAle e1135f085b Improved concurrency test 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-04 18:44:27 +00:00
ItalyPaleAle 2167665c31 Fixed package name 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-04 00:52:41 +00:00
ItalyPaleAle 958b1f37c0 Added tests for concurrent access 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-04 00:30:10 +00:00
ItalyPaleAle c88cec451c Added tests for migrations 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-04 00:13:43 +00:00
ItalyPaleAle 12dbd1db6f Working on TTL tests 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-03 23:15:15 +00:00
ItalyPaleAle 3ffc7e8581 More work on cert tests 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-03 21:53:55 +00:00
ItalyPaleAle e8eec3f4c4 WIP 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-03 20:09:40 +00:00
ItalyPaleAle 37cee72884 WIP: certification test 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-03 01:41:02 +00:00
Bernd Verst cac417aa68 Use Go SDK v1.7.0 in certification tests 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-02-02 13:21:41 -08:00
Bernd Verst c7245bd800 pin 1.10.0-rc.2 in certification tests 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-02-02 12:15:33 -08:00
Bernd Verst 51d4a1f25c
Merge pull request #2386 from Sbolder/multiEnv_awsSqsSns 
fix bug multi environment on aws sqs/sns #2364
 2023-01-31 15:11:11 -08:00
Bernd Verst 608a3b0d81 Pin certification tests to v1.10.0-rc.1 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-01-31 14:15:38 -08:00
ItalyPaleAle 54cfe54c95 Fixed typo in ASB metadata property name 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-30 19:47:34 +00:00
Roberto Rojas 857c126c19
Merge branch 'master' into snssqs-cert-test-1971-disableDeleteOnRetryLimit 2023-01-26 18:47:55 -05:00
Roberto J Rojas 33cb71cf51 adds aws snssqs disableDeleteOnRetryLimit cert test 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-26 18:32:47 -05:00
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
Roberto Rojas df6ab5fb6c
Merge branch 'master' into snssqs-cert-test-1971-deadletter 2023-01-26 13:00:13 -05:00
Bernd Verst 7f7362e620
Merge branch 'master' into update-deps 2023-01-26 09:28:29 -08:00
ItalyPaleAle 76bf347533 Reverted manual changes to indirect deps and updated dapr/kit 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-26 16:18:34 +00: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
Roberto J Rojas fef60ed64a fixes as per pr review 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-25 18:45:03 -05:00
Roberto J Rojas db321fc006 aws snssqs cert test implementation changes 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-25 15:28:43 -05: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
Roberto J Rojas 2b5bd43567 updates 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-25 11:39:35 -05:00
Roberto J Rojas c7730b007f aws snssqs updates cert test readme 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-24 22:08:02 -05:00
Roberto J Rojas 347692db94 Merge branch 'master' into snssqs-cert-test-1971-deadletter 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-24 21:59:14 -05:00
Roberto J Rojas 06663032c2 adds aws snssqs dead letter cert test 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-24 21:57:00 -05:00
Roberto J Rojas e8e0fd7f6c adds aws snssqs dead letter cert test 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-24 21:56:35 -05:00
Bernd Verst 4d8d1d810c modtidy 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-01-23 16:25:37 -08:00
Bernd Verst a1d0458e4b Upgrade dependencies again 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-01-23 16:11:33 -08:00
Roberto J Rojas 709c8b9bda merge from master 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-23 17:51:43 -05:00
Roberto J Rojas 7b28a31ad0 merge with master 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-23 15:25:28 -05:00
Roberto J Rojas b90fad40ba starts SQS deadletter cert test 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-23 15:19:03 -05:00
ItalyPaleAle 06b86a0fae And more 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-23 20:15:41 +00:00
ItalyPaleAle f224709ec7 More fixes to cert tests 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-23 20:09:36 +00:00
ItalyPaleAle e14ec8dc6b Merge branch 'eventhubs-track2' of https://github.com/ItalyPaleAle/dapr-components-contrib into eventhubs-track2 2023-01-23 19:22:28 +00:00
ItalyPaleAle caf0c1ad05 Fixes to cert tests 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-23 19:22:24 +00:00
Bernd Verst 1219568cc1
Merge branch 'master' into eventhubs-track2 2023-01-23 11:09:19 -08:00
ItalyPaleAle a84ab2d0f6 Some fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-23 17:39:40 +00:00
ItalyPaleAle 5ad0388de3 Fixed pubsub cert test 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-23 16:56:42 +00:00
ItalyPaleAle 29ab4242e9 Removed unused code 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-21 20:34:44 +00:00
ItalyPaleAle d986d3b6ff More fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-21 20:00:45 +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
Roberto J Rojas d6b5a3220f fixes FIFO bugs 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-21 12:55:49 -05:00
Roberto J Rojas ff3250e3ce Merge branch 'master' into snssqs-cert-test-1971-fifo 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-20 22:25:19 -05:00
Roberto J Rojas 555f9485ae adds SNS/SQS fifo certification test 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-20 22:24:20 -05:00
ItalyPaleAle d8e1afb8ae Tweaks to tests 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-21 00:12:07 +00:00
ItalyPaleAle 4aeb055ac0 More cert test fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 23:18:16 +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
Alessandro (Ale) Segala 27cf836b8c
Merge branch 'master' into eventhubs-track2 2023-01-20 11:03:24 -08: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 9729c155c1 Retry failed messages + other fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 00:47:24 +00:00
Bernd Verst 9fd9543fd4
Merge branch 'master' into pulsarTests 2023-01-19 16:26:03 -08:00
Roberto J Rojas c156bd5337 Merge branch 'master' into snssqs-cert-test-1339-message-visibility 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-19 17:41:22 -05:00
Roberto J Rojas 79edc550d6 adds message visibility timeout certification test 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-19 17:36:22 -05: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
Alessandro (Ale) Segala fe8479f2d9
bindings.localstorage fixes (#2449) 
* bindings.localstorage: enforcements on rootPath

Also includes ability to disallow certain root paths such as /var/run/secrets

Fixes #2444

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

* Fixed tests on Windows

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

* Fixed tests on Windows pt 2

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

* 💄

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

* Fixes #2374

- Close file descriptor after reading a file
- Report a more specific error if the file doesn't exist

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

* Updated cert tests

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

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-18 15:27:22 -08:00
Bernd Verst 624bb4adaf Addresses UUID CVE in Apache Dubbo Binding 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-01-18 09:57:15 -08:00
addjuarez 8f634e6143 mod tidy 
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
 2023-01-18 01:44:09 +00:00
addjuarez c8c5fe1350
Merge branch 'master' into pulsarTests 
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
 2023-01-17 18:13:25 -06:00
Bernd Verst 20a872bfdd Update SDKs to their latest minor versions 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-01-13 15:26:02 -08:00
addjuarez 869ed1019b mod tidy 
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
 2023-01-13 19:26:45 +00:00
addjuarez 82bcb8cede
Merge branch 'master' into pulsarTests 2023-01-13 13:25:39 -06:00
addjuarez 29d543599b Add deliverAt Test 
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
 2023-01-13 19:15:46 +00: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
Bernd Verst cfa2f662f0 modtidy-all 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-01-12 18:11:39 -08:00
Alessandro (Ale) Segala 6f68f17b22
Merge branch 'master' into s3-fix 2023-01-12 17:55:15 -08:00
ItalyPaleAle 9eaccaf01f Merge branch 'master' of https://github.com/dapr/components-contrib into s3-fix 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-12 15:16:47 -08:00
Roberto J Rojas 53789885c5 changes for conformance and certification tests 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-12 16:15:34 -05:00
Roberto J Rojas c18fe85d46 changes for conformance and certification tests 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-12 15:47:02 -05:00
addjuarez 329d84c552 fix go mod 
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
 2023-01-12 18:39:33 +00:00
addjuarez 3bd4c1ddcb
Merge branch 'master' into pulsarTests 2023-01-12 11:06:54 -06:00
Bernd Verst ec3ede5fbb
Merge branch 'master' into aws-dynamodb-cert-tests-1539 2023-01-12 08:59:18 -08:00
Deepanshu Agarwal 70171fc0e1 Set runtime Running to true for cert tests 
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
 2023-01-12 17:46:20 +05:30
Deepanshu Agarwal bb7a2ec60e drop dapr runtime fork replace 
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
 2023-01-12 16:38:29 +05:30
addjuarez baa25a33c4 typo 
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
 2023-01-12 06:32:28 +00:00
addjuarez 81a4375dfb refactor 
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
 2023-01-12 06:24:55 +00:00
Roberto J Rojas 0be8350b0d adds partition key cert test 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-11 20:42:53 -05:00
addjuarez 646aaa802c mod tidy again 
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
 2023-01-11 22:03:09 +00:00
addjuarez 0d9fab9bf1 Merge branch 'pulsarTests' of https://github.com/addjuarez/components-contrib into pulsarTests 2023-01-11 21:52:55 +00:00
addjuarez 7d82d6ba51 mod tidy 
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
 2023-01-11 21:52:19 +00:00
Roberto J Rojas bd0d235547 go mod tidy 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-11 13:37:51 -05:00
Roberto Rojas 91d7e75c6d
Merge branch 'master' into aws-dynamodb-cert-tests-1539 2023-01-10 18:22:28 -05:00
ItalyPaleAle 2634e85e81 Merge branch 'master' of https://github.com/dapr/components-contrib into s3-fix 2023-01-10 14:47:10 -08:00
Bernd Verst 69652317fd
Merge branch 'master' into pulsarTests 2023-01-10 14:23:54 -08:00
ItalyPaleAle 80dbd4f878 Misc improvements and fixes to S3 binding 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-10 18:14:01 +00:00
ItalyPaleAle e948bef04a ⚙️🧹 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-10 18:10:25 +00:00
ItalyPaleAle 02d478785b Merge branch 'master' of https://github.com/dapr/components-contrib into fix-2422 2023-01-10 17:44:39 +00:00
ItalyPaleAle d6bb5a7232 ⚙️🧹 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-10 17:44:37 +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
Bernd Verst 627e09ca4f
Merge branch 'master' into pulsarTests 2023-01-09 17:24:27 -08:00
addjuarez 31c7a8bbbf mod tidy 
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
 2023-01-09 15:22:56 +00: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
Bernd Verst 4a600d1bf2
Merge branch 'master' into berndverst-patch-6 2023-01-08 18:50:00 -08:00
Roberto Rojas 88593fff0e
AWS SNS/SQS PubSub Certification Tests - Exiting Queue/Topics tests (#2416) 
* adds exiting queue/topic tests

Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>

* fixes as per PR review

Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>

Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-01-06 18:59:40 -08:00
Bernd Verst a637faea22
Fix State Azure Blob cert test 
State Azure Blob Cert test: AAD test was not actually using AAD

Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-01-06 16:15:08 -08:00
Roberto Rojas d47921f0f9
Merge branch 'master' into aws-dynamodb-cert-tests-1539 2023-01-06 18:26:37 -05: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
Roberto J Rojas e4719d7d7a Merge branch 'master' into aws-pubsub-cert-tests-1339 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-05 11:32:40 -05:00
Bernd Verst be093538f7
Merge branch 'master' into master 2023-01-04 14:35:59 -08:00