6389cc207c
Add BulkGet support for SQLite and Postgres state stores ( #2704 )
...
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: Josh van Leeuwen <me@joshvanl.dev>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-03-25 02:18:43 +00:00
f2d46b4489
Fix Postgres state store hardcoding table name in Delete method ( #2708 )
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-03-25 01:09:33 +00:00
e5cbb34990
Add metadata analyzer tools ( #2696 )
...
Signed-off-by: Bernd Verst <github@bernd.dev>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
2023-03-24 18:34:36 +00:00
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
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
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
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
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
7abcff615b
Add support for Workload identity ( #2655 )
...
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-03-13 16:34:54 +00:00
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
b4cdc7a3ca
Restore Kafka CA Cert Auth without Password support, fix Jetstream pubsub issue ( #2644 )
...
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-03-07 22:47:35 -08:00
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
f2a9e30cdd
[Maintenance task] upgrade lots of libraries ( #2630 )
...
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-03-04 00:38:17 +00:00
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
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
73029dc9f0
WIP
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-27 21:28:08 +00:00
2916e53a72
WIP
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-27 21:28:08 +00:00
3a616c5678
Remove Track 1 SDK references
...
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-02-27 12:44:32 -08:00
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
970353bba5
recompile cloudflare worker
...
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-02-17 16:12:49 -08:00
3825065c03
Merge branch 'master' into newdeps
...
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-02-17 15:57:18 -08:00
f863e375cc
Updated CF worker and dependencies
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-17 21:24:23 +00:00
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
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
6d2a9874ba
Prettier
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-17 03:57:10 +00:00
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
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
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
5616866edc
Fixed panic when not using Azure AD
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-16 17:44:33 +00:00
a8957062f0
Fixed tests
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-16 01:42:05 +00:00
6f30dbf6c6
Updated Azure Event Hubs and Azure Blob Storage SDKs
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-16 00:21:56 +00:00
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
b395ecd725
Small concurrency fixes
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-14 21:07:35 +00:00
b9f33ca14c
[release-1.10] Improve lock handling and renewal for ASB messages ( fix #2532 ) ( #2533 )
...
* Improved lock renewal
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Better memory management
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Complete and abandon messages in parallel too
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* 10->20
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
---------
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-14 11:33:13 -08:00
210c8c3c59
Removed warning on ConsumerID being deprecated by Kafka ( #2525 )
...
Co-authored-by: Kushal Lahoti <kushal@Kushals-MacBook-Pro.local>
2023-02-13 10:21:47 -08:00
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
3c009dcbb8
Updated version too
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-02 19:53:39 +00:00
3049541e9c
Fix Cloudflare Queues binding
...
The name of the object was changed by Cloudflare from "Queue" to "WorkerQueue", breaking the component
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-02 19:41:13 +00:00
d2ddf87045
Compare context deadline exceeded error as strings too
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-31 18:09:21 +00:00
7047ad533d
More logging when Service Bus reconnects after publishing error
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-31 17:58:30 +00:00
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
feccffb0c8
Support PEM certificates from Azure AD
...
Fixes #2396
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-24 01:00:28 +00:00
a84ab2d0f6
Some fixes
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-23 17:39:40 +00:00
29ab4242e9
Removed unused code
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-21 20:34:44 +00:00
d986d3b6ff
More fixes
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-21 20:00:45 +00:00
1fd48dd912
Fixes
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-21 19:40:52 +00:00
232c8d813f
Working on binding
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-21 19:28:00 +00:00
857a865e4e
Moved implementation to shared package
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-21 01:14:04 +00:00
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
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
0157bf0b72
WIP
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-19 00:12:10 +00:00
7e141e75e0
revert to using map and mutex
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2023-01-18 19:23:52 +00:00
58daacbdcd
use sync.Map instead of map and mutex for active message tracking
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2023-01-18 10:20:32 +00:00
77504a8289
assign to slice rather than append
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2023-01-15 10:12:28 +00:00
c1de465e64
revert active message snapshot to use append
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2023-01-14 13:38:14 +00:00
28b82089a2
Merge branch 'master' of github.com:dapr/components-contrib into jjcollinge/asb-sessions-hotfix
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2023-01-13 18:39:58 +00:00
f6d31aba8d
Measure length after taking lock
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2023-01-13 18:36:39 +00:00
32f14568ec
Moved Unquote to utils package
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-10 17:52:38 +00:00
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
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
1c342e32d0
lint
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2023-01-05 14:25:40 +00:00
31f01013e2
Merge branch 'master' of github.com:dapr/components-contrib into jjcollinge/asb-sessions
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2023-01-05 14:17:16 +00:00
e097a04842
Feedback
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2023-01-05 14:15:00 +00:00
bea0774b4c
Fixed typo in Worker
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-29 01:09:58 +00:00
4e17e42818
CF Worker: better detection for binding type
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-29 00:28:16 +00:00
76a36a8bfd
Merge branch 'master' into jjcollinge/asb-sessions
2022-12-28 10:38:20 -08:00
ec5791492e
Merge branch 'master' into cfqueues-binding
2022-12-20 14:49:46 -08:00
2582f154bd
Add back headers metadata pass in kafka subscribe ( #2281 )
...
* Add back headers metadata pass in kafka subscribe
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update internal/component/kafka/consumer.go
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.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-12-20 11:43:52 -08:00
4b99832634
Use if not select for context check
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2022-12-20 18:11:20 +00:00
cff6d7b6b1
Merge remote-tracking branch 'upstream/master' into optimize-bulkpubres-struct
2022-12-20 23:04:19 +05:30
5051e28b9c
Address feedback
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2022-12-20 09:59:20 +00:00
b6911b67fd
Use struct for NewSubscription to simplify parameters
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2022-12-20 09:23:30 +00:00
280c35ed58
Workers KV: add TTL support
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-19 18:50:59 +00:00
adc4648174
Fixed parsing of timeout in metadata
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-19 18:41:03 +00:00
135d460b05
Configurable timeouts
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-19 17:46:54 +00:00
6aa9ccc364
Binding -> CFBinding
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-19 17:39:30 +00:00
5dda098868
feature: add context to lock&pubsub API
...
Signed-off-by: seachen <seachen@tencent.com>
2022-12-19 09:11:53 +08:00
b7817c0ee7
Merge branch 'master' into optimize-bulkpubres-struct
2022-12-17 11:05:39 +05:30
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
87c338269a
Merge branch 'master' into jjcollinge/asb-sessions
...
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-12-16 14:37:38 -08:00
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
28003fcf4f
Add cert test for roundrobin
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2022-12-16 16:45:17 +00:00
0f63ac30b5
Merge branch 'master' into optimize-bulkpubres-struct
2022-12-16 08:02:32 +05:30
69084f2d9f
Merge branch 'master' of https://github.com/dapr/components-contrib into cfqueues-binding
2022-12-15 14:19:35 -08:00
78a83c77fb
Merge branch 'master' into fix-blobstore-error-checks
2022-12-15 13:11:14 -08:00
e8353379e1
Merge branch 'master' of https://github.com/dapr/components-contrib into cfqueues-binding
2022-12-15 10:01:54 -08:00
0841b3d846
Merge branch 'master' into optimize-bulkpubres-struct
2022-12-15 23:00:34 +05:30
1ea2cff9fd
feature: add context to lock&pubsub API
...
Signed-off-by: seachen <seachen@tencent.com>
2022-12-15 09:53:32 +08:00
64a2c3aad1
Revert "revert amqp changes, eventhubs library update"
...
This reverts commit b236279d81
2022-12-14 16:19:06 -08:00
b236279d81
revert amqp changes, eventhubs library update
...
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-12-14 15:05:56 -08:00
e59dfd63c0
feature: add context to lock&pubsub API
...
Signed-off-by: seachen <seachen@tencent.com>
2022-12-14 19:37:24 +08:00
fce17f592e
Update SDKs again
...
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-12-13 12:27:40 -08:00
308f3c987c
💄
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-13 10:02:42 -08:00
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
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
47db769066
Add Cloudflare KV state store
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-13 01:52:06 +00:00
d4b0980cec
Refactored to use a shared package
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-13 00:32:55 +00:00
adc70a0143
Automatically deploy and update workers
...
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-12 22:53:35 +00:00
f57727f4b4
Add comment
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2022-12-12 21:57:44 +00:00
0db24fa04e
Update certification test
...
Signed-off-by: Joni Collinge <jonathancollinge@live.com>
2022-12-12 21:43:18 +00:00
Alessandro (Ale) Segala
Bernd Verst
Josh van Leeuwen
Vishal Kumar
Kushal Lahoti
Joni Collinge
Deepanshu Agarwal
Bernd Verst
Mukundan Sundararajan
seachen