Commit Graph

572 Commits

Author SHA1 Message Date
Alessandro (Ale) Segala d7fc4d4a8e
Updated pinned runtime version in cert tests (#2911)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-06-13 09:42:13 -07:00
Josh van Leeuwen 8f8a56a0b9
sqlserver: return ttlExpiryTime in GetResponse (#2896)
Signed-off-by: joshvanl <me@joshvanl.dev>
2023-06-12 12:15:29 -07:00
ItalyPaleAle ce926db071 Merge branch 'release-1.11' 2023-06-12 12:07:56 -07:00
Josh van Leeuwen dfc28528b5
dynamodb: return ttlExpiryTime in GetResponse (#2899)
Signed-off-by: joshvanl <me@joshvanl.dev>
2023-06-08 15:32:59 +00:00
Josh van Leeuwen 69a1c01801
mysql: return ttlExpiryTime in GetResponse (#2871)
Signed-off-by: joshvanl <me@joshvanl.dev>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
2023-06-07 20:45:24 +00:00
Josh van Leeuwen 85be43ad5c
memached: if tllInSeconds larger than 30 days, convert to unix timestamp (#2892)
Signed-off-by: joshvanl <me@joshvanl.dev>
2023-06-06 09:19:32 -07:00
Josh van Leeuwen 06defdcc22
memached: if tllInSeconds larger than 30 days, convert to unix timestamp (#2890)
Signed-off-by: joshvanl <me@joshvanl.dev>
2023-06-06 15:45:11 +00:00
Bernd Verst f27ece3add
[Release-1.11] Upgrade Mongo dependency due to retraction (#2886)
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-06-06 08:44:05 -07:00
Josh van Leeuwen ff06ae6b33
MongoDB return ttlExpiryTime in GetResponse (#2888)
Signed-off-by: joshvanl <me@joshvanl.dev>
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-06-06 15:18:06 +00:00
Josh van Leeuwen 1963726043
Postgresql + cockroachDB return `ttlExpiryTime` in `GetResponse` (#2864)
Signed-off-by: joshvanl <me@joshvanl.dev>
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-06-06 15:14:18 +00:00
Bernd Verst f6bcb109a2
[Release 1.11] Update dapr/kit to `0.11.1` (#2885)
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-06-05 12:24:55 -07:00
Bernd Verst 92b830b085
Merge branch 'master' into merge-release1.11-master 2023-05-25 12:34:51 -05:00
Bernd Verst d467890cf8 Merge remote-tracking branch 'upstream/master' into merge-release1.11-master 2023-05-25 10:33:12 -07:00
Josh van Leeuwen cb89219916
crypto: propagate context to pubkey cache getKeyFn (#2828)
Signed-off-by: joshvanl <me@joshvanl.dev>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-05-25 17:21:33 +00:00
Bernd Verst 8e714b19d6
[Release 1.11] Update dapr/kit to 0.11.0 (#2859)
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-05-25 09:55:59 -07:00
Bernd Verst 98467330c1 Pin 1.11.0-rc.4 in cert tests
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-05-24 22:16:59 -07:00
Bernd Verst ac20c0a703 Merge remote-tracking branch 'upstream/master' into merge-release-1.11-rc4-into-master 2023-05-17 18:27:42 -07:00
Alessandro (Ale) Segala e30d140479
Remove native/transactional BulkSet/BulkDelete from state stores (#2834)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-05-17 14:56:34 -07:00
Bernd Verst eabeadf044
Add Kafka Binding SASL Password cert test (#2831)
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-05-17 00:38:24 +00:00
Bernd Verst 13c00583a4 upgrade EventHubs and ServiceBus management SDKs
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-05-10 14:25:27 -07:00
Bernd Verst 009548d820 Upgrade Azure SDKs
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-05-10 13:43:17 -07:00
Bernd Verst c5f5a10f77 Upgrade Azure SDKs
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-05-10 13:23:09 -07:00
Andre Bossard 9f4086fbb0
RabbitMQ Bindings: Support for mTLS and external authentication with SASL (#2656)
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: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-05-03 22:07:50 +00:00
Shivam Kumar 7d24bfa000
Update Go SDK version in certification tests (#2825)
Signed-off-by: Shivam Kumar <shivamkm07@gmail.com>
2023-05-02 16:09:20 +00:00
Bernd Verst a2ebc41daf
Add CosmosDB capability header and update Azure SDKs (#2824)
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-05-02 01:29:40 +00:00
Chris Gillum 22abcf8a90
Point certification tests to latest dapr/dapr (#2823)
Signed-off-by: Chris Gillum <cgillum@microsoft.com>
2023-05-01 18:04:05 +00:00
Yaron Schneider a1bf2ea00a
Add Apache Pulsar e2e encryption (#2812)
Signed-off-by: yaron2 <schneider.yaron@live.com>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2023-04-28 18:19:15 +00:00
Roberto Rojas 181f3ad039
[AWS DynamoDB] Transaction Support (#2809)
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
Signed-off-by: roberto <roberto@diagrid.io>
Co-authored-by: roberto <roberto@diagrid.io>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2023-04-27 23:13:20 +00:00
Roberto Rojas 33934396a2
AWS S3 Bindings Certification Tests (#2536)
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2023-04-27 22:17:01 +00:00
Roberto Rojas e099a548fb
GCP Firestore - Certification Tests (#2754)
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-04-26 22:12:56 +00:00
Ryan Lettieri 180b6e1084
Addition of Purge for workflow (#2729)
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
2023-04-25 21:48:46 +00:00
Chris Gillum 3fbaad8544
Workflow management API cleanup / breaking changes for v1.11 (#2751)
Signed-off-by: Chris Gillum <cgillum@microsoft.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-04-24 16:02:59 -07:00
Roberto Rojas 413eee94db
GCP PubSub - Certification Tests (#2689)
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-04-24 22:23:34 +00:00
Alessandro (Ale) Segala 7bfd0f37a9
crypto.jwks: use jwkscache from dapr/kit (#2789)
Signed-off-by: joshvanl <me@joshvanl.dev>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: joshvanl <me@joshvanl.dev>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-04-24 11:53:59 -07:00
Bernd Verst a7ac906757
Fix Redis metadata parsing and reporting (#2803)
Signed-off-by: Bernd Verst <github@bernd.dev>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Tiago Alves Macambira <tmacam@burocrata.org>
2023-04-23 06:28:22 +00:00
Alessandro (Ale) Segala 6b0dedf772
state.sqlserver: Add support for Azure AD auth (+ metadata.yaml) (#2790)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2023-04-19 17:26:24 +00:00
Shivam Kumar ac54dae002
Certification test for Postgres config store (#2744)
Signed-off-by: Shivam Kumar <shivamkm07@gmail.com>
2023-04-18 21:39:34 +00:00
Bernd Verst 6b59f2908d
fix postgres error handling for upsert with etag (#2778)
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-04-13 19:36:24 +00:00
Alessandro (Ale) Segala 4f94da95cf
Refactor state store bulk operations (#2747)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-04-07 19:19:47 +00:00
Alessandro (Ale) Segala 3938c3e7c0
Cert tests: use a single go.mod for all certification tests (#2748)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-04-04 12:28:11 -07:00
Alessandro (Ale) Segala a9be2a6db7
Crypto components: add methods that return the list of supported algorithms (#2735)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-04-03 16:15:24 +00:00
Shivam Kumar 8df219b8bb
Merge conformance and certification coverage report (#2681)
Signed-off-by: Shivam Kumar <shivamkm07@gmail.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-03-31 17:41:33 +00:00
Alessandro (Ale) Segala 297c97ca95
Remove pgx/stdlib import (#2725)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-03-30 16:17:09 -07:00
Deepanshu Agarwal d6ce7bb5c3
Add MySQL TTL and Cleanup (#2641)
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-03-30 15:45:57 -07:00
Alessandro (Ale) Segala 029040c6a9
Fix inconsistency with TTL and Etags in SQL databases + fix SQL Server cert tests (#2688)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-03-25 02:34:30 +00:00
Alessandro (Ale) Segala 3cd727a562
Crypto building block: core parts (#2690)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-03-23 00:51:27 +00:00
Josh van Leeuwen 76e33137d9
Adds TTL support to SQL Server using SQL Cleanup Strategy (#2682)
Signed-off-by: joshvanl <me@joshvanl.dev>
2023-03-20 20:04:17 +00:00
Ryan Lettieri 7e9b5a8b46
Creation of request and interface method for Workflow raise event (#2667)
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
Co-authored-by: Ryan Lettieri <ryanLettieri@microsoft.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2023-03-17 21:15:47 +00:00
Yaron Schneider 0e83c4adc5
Add priority queue support to rabbitmq pub/sub (#2680)
Signed-off-by: yaron2 <schneider.yaron@live.com>
2023-03-17 13:00:49 +00:00
Alessandro (Ale) Segala a8415d82b8
Certification tests + fixes for Bearer HTTP Middleware (#2673)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-03-16 20:40:24 +00:00
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