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 79 MiB
Commit Graph

255 Commits

Author SHA1 Message Date
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 2ff503a0aa Multiple fixes + updated docs 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-17 19:00:46 +00:00
joshvanl db56a28581 Don't case extra allocations. Revert 70s state wait for ttl deletion 
Signed-off-by: joshvanl <me@joshvanl.dev>
 2023-02-17 17:46:15 +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 64d3fbc998 Merge branch 'master' of https://github.com/dapr/components-contrib into tests-scripts 2023-02-17 01:11:51 +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
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
ItalyPaleAle 643a2abff2 Removed go.uber.org/atomic and github.com/pkg/errors 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-15 19:56:20 +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
ItalyPaleAle 5cb6f4d2d7 WIP 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-14 23:33:17 +00:00
ItalyPaleAle 6f71753c13 New SQLite 3 state store 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-24 17:39:11 -08:00
ItalyPaleAle bd64c60629 A few more tweaks 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-23 18:05:20 +00:00
ItalyPaleAle a84ab2d0f6 Some fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-23 17:39:40 +00:00
ItalyPaleAle 1fd48dd912 Fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-21 19:40:52 +00:00
ItalyPaleAle 232c8d813f Working on binding 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-21 19:28:00 +00:00
ItalyPaleAle 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
Roberto J Rojas ebc818116f adds conformance tests 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-01-11 18:57:54 -05: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
shivam c0504b422f Removing operation from Updatevent 
Signed-off-by: shivam <shivamkm07@gmail.com>
 2023-01-09 20:43:41 +05:30
shivam e9d9449a2c Handling non-existing key scenario in get 
Signed-off-by: shivam <shivamkm07@gmail.com>
 2023-01-09 10:47:13 +05:30
shivam 256cd8915e Fix linter errors 
Signed-off-by: shivam <shivamkm07@gmail.com>
 2023-01-09 10:47:13 +05:30
shivam bc1b84883b Fix linter errors 
Signed-off-by: shivam <shivamkm07@gmail.com>
 2023-01-09 10:47:13 +05:30
shivam 4d2332aee6 Adding delete scenario in conformance test 
Signed-off-by: shivam <shivamkm07@gmail.com>
 2023-01-09 10:47:13 +05:30
shivam 5ddb9dbba9 Add more scenarios 
Signed-off-by: shivam <shivamkm07@gmail.com>
 2023-01-09 10:47:13 +05:30
shivam 4aff123b46 Adding Redis 7 support 
Signed-off-by: shivam <shivamkm07@gmail.com>
 2023-01-09 10:47:13 +05:30
shivam d5d45350ac Formatting Changes/Comments 
Signed-off-by: shivam <shivamkm07@gmail.com>
 2023-01-09 10:47:13 +05:30
shivam a23607fed2 Adding wait for subscribe to complete 
Signed-off-by: shivam <shivamkm07@gmail.com>
 2023-01-09 10:47:13 +05:30
shivam c662fd2e5b Init config conformance framework 
Signed-off-by: shivam <shivamkm07@gmail.com>
 2023-01-09 10:47:13 +05:30
Bernd Verst 3efab74b51
Merge branch 'master' into postgres-pgx 2022-12-29 12:34:21 -08:00
Bernd Verst 9845a76288 Merge remote-tracking branch 'upstream/master' into solacese/master 2022-12-28 17:39:08 -08:00
Bernd Verst df5197959a Add random docs string to trigger workflow 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-12-27 17:21:33 -08:00
Bernd Verst 216d9802f5
Update tests/conformance/README.md 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-12-27 15:52:55 -08:00
Dapr Bot 31b0ab842e
Merge branch 'master' into certInfrastructure 2022-12-27 14:27:19 -08:00
ItalyPaleAle 4b5d6ceb38 Update & Fix Actions: 
- Correct the path for the cloudflare.workerskv config file
- Update all Actions to newer versions to avoid warnings about Node.js 12 being deprecated soon
- Removed the deprecated Azure/get-keyvault-secrets action

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-12-27 19:48:59 +00:00
Bernd Verst 18de3427d4
Merge branch 'master' into certInfrastructure 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-12-22 16:08:13 -08:00
Alessandro (Ale) Segala ae48594e7e
Merge branch 'master' into postgres-pgx 2022-12-22 15:39:08 -08:00
TKTheTechie 57c2324670 Refactoring package names 
Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:22 -05:00
TKTheTechie 619c35693e Adding conformance tests 
Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:21 -05:00
Alessandro (Ale) Segala ec5791492e
Merge branch 'master' into cfqueues-binding 2022-12-20 14:49:46 -08:00
ItalyPaleAle 80b1bb14b7 Changed postgres state store to use pgx instead of db/sql 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-12-20 22:45:38 +00:00
addjuarez 79857d2044
Merge branch 'master' into certInfrastructure 2022-12-20 13:40:18 -06:00
Mukundan Sundararajan cff6d7b6b1 Merge remote-tracking branch 'upstream/master' into optimize-bulkpubres-struct 2022-12-20 23:04:19 +05:30
addjuarez f1dd26960c Use timestamp 
Signed-off-by: addjuarez <addiajuarez@gmail.com>
 2022-12-19 18:28:37 -06:00
Bernd Verst af1d2036d6
Merge branch 'master' into certInfrastructure 2022-12-19 14:48:05 -08:00
addjuarez 22ed300301 Add readme 
Signed-off-by: addjuarez <addiajuarez@gmail.com>
 2022-12-19 16:46:37 -06:00
Alessandro (Ale) Segala bb42483ff0
Merge branch 'master' into feature/pubsub_20221214 2022-12-19 14:05:43 -08:00
addjuarez 256959cb45 Readd docker snssqs test 
Signed-off-by: addjuarez <addiajuarez@gmail.com>
 2022-12-19 13:55:50 -06:00
Yaron Schneider 9a93c67b27
Merge branch 'master' into certInfrastructure 2022-12-19 10:00:24 -08:00
Mukundan Sundararajan 5ad884d924
Merge branch 'master' into optimize-bulkpubres-struct 2022-12-19 23:10:12 +05:30
ItalyPaleAle 2446a698cb Renamed KV -> Workers KV to be consistent with branding 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-12-19 17:35:53 +00:00
ItalyPaleAle d50ad603be Merge branch 'master' of https://github.com/dapr/components-contrib into cfqueues-binding 2022-12-19 17:33:19 +00:00
Marcos Candeia d680006c33
Allow bindings conformance tests for uninitialized components (#2348) 
Signed-off-by: Marcos Candeia <marrcooos@gmail.com>

Signed-off-by: Marcos Candeia <marrcooos@gmail.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-12-19 09:26:24 -08:00
addjuarez c096a8586f Merge branch 'master' into certInfrastructure 2022-12-18 20:35:48 -06:00
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 adc7bd8ca5
Merge branch 'master' into cfqueues-binding 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-12-16 14:46:03 -08:00
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
addjuarez fb9e0bdbf1
Merge branch 'master' into certInfrastructure 2022-12-15 13:49:01 -06:00
addjuarez dfd00d4152 rework comformance 
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
 2022-12-15 19:48:09 +00: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
ItalyPaleAle ab10db95dd 💄 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-12-14 01:33:04 +00:00
ItalyPaleAle 717bfcf23a Enabled conf tests for state.cloudflare.kv 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-12-14 00:34:09 +00:00
ItalyPaleAle a1c863d7fd Small fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-12-13 10:11:36 -08:00
Mukundan Sundararajan 2b61b61dad use slices contains function from import 
Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
 2022-12-13 21:23:06 +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
1046102779 2dd7433a59 feature: add context to state API 
Signed-off-by: 1046102779 <seachen@tencent.com>
 2022-12-08 15:56:51 +08:00
Sarthak Sharma 0e0cf8fe58
Add certification tests for Cron Binding (#2191) 
* fix typos

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add basic tests

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* update tests

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add Readme

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* update mod file

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add entry in workflow

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add conformance test

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add conformance tests to workflow

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* use watcher to assert

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* update readme

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* fix linting

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* Apply suggestions from code review

Co-authored-by: Shubham Sharma <shubhash@microsoft.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* change to dapr/go-sdk from hunter007/dapr-go-sdk

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* fix cron delete operation

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add check if cron not triggered after delete

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* update README

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* parameterise application and assertions

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* use mock clock for cron

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* change cron to input only binding

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add forked cron library to internal/cron

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* use cron internal fork for binding

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* resolve comments

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* resolve comments

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add test matrix to test various schedules

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add cron init unit tests

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* resolve comments

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* fix linting

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* fix linting

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* go modtidy all

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* go modtidy

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* move cron fork to dapr/kit

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* use pinned v0.0.3 for dapr/kit

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.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: Shubham Sharma <shubhash@microsoft.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
 2022-12-02 02:30:01 -08:00
Alessandro (Ale) Segala bd76503d27
Merge branch 'master' into ttl-conf-tests 2022-11-21 21:56:37 -08:00
Alessandro (Ale) Segala 4dde34c2d1
Fix state.in-memory and enable conformance tests (#2303) 
* Fix state.in-memory and enable conf tests

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

* Fixed unit tests

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>
 2022-11-21 21:53:51 -08:00
ItalyPaleAle 4d4b98d339 Add conformance test for TTL in state stores 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-11-22 04:33:47 +00:00
Ryan Lettieri deb647c241 Updating workflows request struct 
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
 2022-11-14 12:39:35 -07:00
Ryan Lettieri 4ebe7ea400
Merge branch 'dapr:master' into master 2022-11-14 10:10:02 -07:00
Ryan Lettieri 9d39e9ee87 Adding in optional parameter for a namespace into temporal 
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
 2022-11-12 11:04:32 -07:00
KubeMQ adb840bb84
Merge branch 'dapr:master' into master 2022-11-11 23:34:39 +02: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
Lior Nabat a47d8f87dd Adding KubeMQ Binding - Queue 
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
 2022-11-11 16:03:25 +02:00
Bernd Verst bfc482d3e4 Merge remote-tracking branch 'upstream/master' into kubemq-io/master 2022-11-02 15:14:33 -07:00
1046102779 5a350f1dd6 Merge branch 'master' into feature/state_context1021 2022-11-01 09:23:57 +08:00
ItalyPaleAle c4b63b3975 Run conf tests for state.mysql against MariaDB too 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-10-31 19:48:11 +00:00
Ryan Lettieri 79ba329b3e Fixed typo for workflows test function 
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
 2022-10-24 21:55:34 -06:00
1046102779 b42d9ab730 feature: add context to state API 
Signed-off-by: 1046102779 <seachen@tencent.com>
 2022-10-25 07:26:56 +08: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 bed3d69a6f Add new PubSub component - KubeMQ Kubernetes message broker 2022-10-22 18:51:11 +03:00
Bernd Verst 98742f7b1b
Merge branch 'master' into workflow-dev 2022-10-24 14:35:40 -07:00
Ryan Lettieri d7ef6d41bc Updating responses from workflows building block to be more generic 
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
 2022-10-21 23:58:48 -06:00
1046102779 08f665cb83 feature: add context to state API 
Signed-off-by: 1046102779 <seachen@tencent.com>
 2022-10-21 21:05:47 +08:00
1046102779 5a367b401a feature: add context to state API 
Signed-off-by: 1046102779 <seachen@tencent.com>
 2022-10-21 17:25:14 +08:00
Ryan Lettieri 21cbd928e8 Merged in changes from master into workflows 
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
 2022-10-10 09:44:27 -06: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
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
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
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
Mukundan Sundararajan db0ace71bc address review comments 
Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
 2022-09-22 13:30:56 +05:30
Mukundan Sundararajan fffb91aed6 fix skipping bulk publish scenario 
Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
 2022-09-21 14:06:07 +05:30
Mukundan Sundararajan 0f185d9e38 add conf test for bulk publish 
Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
 2022-09-21 12:10:51 +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
Dapr Bot 7fced084f8
Merge branch 'master' into workflow-dev 2022-09-14 15:31:59 -07:00