dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
3,388 Commits 55 Branches 159 Tags 84 MiB
Commit Graph

596 Commits

Author SHA1 Message Date
Gustavo Chaín 1137759a9b
snssqs: fix consumer starvation (#3478) 
Signed-off-by: Gustavo Chain <me@qustavo.cc>
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: Bernd Verst <github@bernd.dev>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2024-11-25 19:33:22 -08:00
Elena Kolevska 2aea31969f
Fixes `subscribeType` metadata field not being respected for Pulsar pub sub (#3603) 
Signed-off-by: Elena Kolevska <elena@kolevska.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
 2024-11-22 09:39:41 -08:00
Sam e2b27d3538
fix(aws): update close if aws auth provider is nil (#3607) 
Signed-off-by: Samantha Coyle <sam@diagrid.io>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2024-11-20 09:24:49 -08:00
Yaron Schneider 1a6a75a1ce
Enable in order processing of eventhubs messages (#3605) 
Signed-off-by: yaron2 <schneider.yaron@live.com>
 2024-11-18 13:18:20 -08:00
Sam a00a853556
feat(iam auth): allow iam roles anywhere auth profile (#3591) 
Signed-off-by: Samantha Coyle <sam@diagrid.io>
Signed-off-by: Sam <sam@diagrid.io>
 2024-11-14 12:04:56 -07:00
Yaron Schneider b969bbfe88
Add receiverQueueSize to pulsar (#3589) 
Signed-off-by: yaron2 <schneider.yaron@live.com>
 2024-11-03 21:25:09 -08:00
Elena Kolevska dae321130c
Merge 1.14 into master (#3579) 
Signed-off-by: Samantha Coyle <sam@diagrid.io>
Signed-off-by: Elena Kolevska <elena@kolevska.com>
Signed-off-by: yaron2 <schneider.yaron@live.com>
Signed-off-by: Artur Souza <asouza.pro@gmail.com>
Signed-off-by: Anton Troshin <anton@diagrid.io>
Co-authored-by: Sam <sam@diagrid.io>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: yaron2 <schneider.yaron@live.com>
Co-authored-by: Anton Troshin <troll.sic@gmail.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2024-10-24 16:52:48 -07:00
Sam 28d46f6720
fix(redis): make auth profiles consistent for username/pwd (#3565) 
Signed-off-by: Samantha Coyle <sam@diagrid.io>
 2024-10-14 13:46:51 -07:00
Josh van Leeuwen be7c19b742
Interfaces: Update all component interfaces to implement io.Closer (#3542) 
Signed-off-by: joshvanl <me@joshvanl.dev>
 2024-09-19 08:53:22 -07:00
Elena Kolevska 9156779aa8 Merges 1.14 into master 2024-08-29 17:12:07 +02:00
Mike Nguyen e53cf3401f
Fix MQTT3 component (#3501) 
Signed-off-by: mikeee <hey@mike.ee>
 2024-08-02 10:37:20 -07:00
Artur Souza 12d7c2ba4f
Fix init in sqssns + Docker Compose update (#3498) 
Signed-off-by: Artur Souza <asouza.pro@gmail.com>
 2024-08-01 15:43:27 -07:00
Artur Souza bffaeeb31f
Fix AWS sns/sqs panic (#3497) 
Signed-off-by: yaron2 <schneider.yaron@live.com>
Signed-off-by: Artur Souza <asouza.pro@gmail.com>
Co-authored-by: yaron2 <schneider.yaron@live.com>
 2024-08-01 12:00:53 -07:00
Eileen Yu a409bc1f96
fix: drop duplicate awsRegion/region field (#3490) 
Signed-off-by: Eileen Yu <eileenylj@gmail.com>
 2024-07-25 09:40:08 -07:00
Bernd Verst 273bea12ef
[Release 1.14] Cherry Pick of 3470 - Azure Auth for all Redis Components (#3471) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2024-07-01 17:38:29 -07:00
Bernd Verst b656b0d5d5
Adds EntraID auth support to all Redis Components (#3470) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2024-07-01 17:20:29 -07:00
mahparaashley 1375f081c6
Add configurable ackDeadline to GCP Pub/Sub component (#3422) 
Signed-off-by: mashley@rechargeapps.com <mashley@rechargeapps.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: mashley@rechargeapps.com <mashley@rechargeapps.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2024-06-26 12:59:44 -07:00
Nikola Nedeljkovic d09ffe13e0
change topicArns to map safe for concurrent access (#3459) 
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2024-06-24 10:51:18 -07:00
Nathan Lowry 864baaad3d
Support configurable MaxOutstanding* and NumGoroutines settings for GCP PubSub component (#3442) 
Signed-off-by: Nathan Lowry <nathandl@gmail.com>
 2024-06-21 13:02:29 -07:00
Jake Engelberg 499f66ff73
fix: pubsub.solace.amqp metadata.yaml name/title fix (#3452) 
Signed-off-by: Jake Engelberg <jake@diagrid.io>
 2024-06-20 14:00:31 -07:00
Arthur Poiret 51e0c79dd4
Add RabbitMQ single active consumer argument (#3437) 
Signed-off-by: Arthur Poiret <dropsnorz@gmail.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2024-06-17 16:12:27 -07:00
Elena Kolevska f0be1a2d28
Redis private certificates (#3429) 
Signed-off-by: Elena Kolevska <elena@kolevska.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2024-06-04 09:55:12 -07:00
Sam eb82293623
feat(aws iam): support aws iam auth for postgresql components (#3324) 
Signed-off-by: Samantha Coyle <sam@diagrid.io>
Signed-off-by: Bernd Verst <github@bernd.dev>
Signed-off-by: joshvanl <me@joshvanl.dev>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
Co-authored-by: joshvanl <me@joshvanl.dev>
 2024-05-16 15:45:57 -07:00
Sam 70fd16ab19
fix: metadata capitalization (#3413) 
Signed-off-by: Bernd Verst <github@bernd.dev>
Signed-off-by: Samantha Coyle <sam@diagrid.io>
Co-authored-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2024-05-16 12:58:15 -07:00
denisbchrsk b9c12df7d4
Kafka: Add support to configure heartbeat interval and session timeout to kafka's consumer (#3375) 
Signed-off-by: denisbchrsk <155584191+denisbchrsk@users.noreply.github.com>
 2024-03-21 20:31:09 +00:00
Sam 85252beeef
feat(kafka): add producer config capabilities for connections (#3371) 
Signed-off-by: Samantha Coyle <sam@diagrid.io>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2024-03-21 09:11:47 -07:00
Josh van Leeuwen 6413239626
PubSub Kafka: Respect Subscribe context (#3363) 
Signed-off-by: joshvanl <me@joshvanl.dev>
 2024-02-28 10:13:06 -08:00
Yaron Schneider 86abb49ab2
Enable configurable concurrency for pulsar (#3330) 
Signed-off-by: yaron2 <schneider.yaron@live.com>
 2024-02-02 10:29:31 -08:00
Artur Souza 0c687df973
FIX: Redis to handle event metadata. (#3320) 
Signed-off-by: Artur Souza <asouza.pro@gmail.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2024-01-25 12:25:24 -08:00
Patrick Assuied a3149e5a8c
left uppercase in metadata (#3312) 
Signed-off-by: Patrick Assuied <patrick.assuied@elationhealth.com>
 2024-01-10 10:29:23 -08:00
Eunice Compra 85722a4e88
Kafka: Support for AWS IAM role auth (#3310) 
Signed-off-by: Eunice Compra <eunicecompra@gmail.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Fabian Martinez <46371672+famarting@users.noreply.github.com>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Eunice Compra <eunice.compra@gmail.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Fabian Martinez <46371672+famarting@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2024-01-10 04:11:32 +00:00
Patrick Assuied 419f03fc02
Avro Schema registry kafka pubsub implementation (#3292) 
Signed-off-by: Patrick Assuied <patrick.assuied@elationhealth.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2024-01-10 01:08:05 +00:00
Alessandro (Ale) Segala c47907d1a5
Chore: use a single package for all Feature structs (#3278) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2024-01-08 09:07:10 -08:00
Fabian Martinez 1aa44e925c
Kafka: fix "awsiam" auth type name (#3286) 
Signed-off-by: Fabian Martinez <46371672+famarting@users.noreply.github.com>
 2023-12-22 09:32:16 -08:00
Yaron Schneider 323e9bfcfd
Add kafka configuration to pub/sub (#3275) 
Signed-off-by: yaron2 <schneider.yaron@live.com>
 2023-12-15 17:26:06 +00:00
Fabian Martinez 7c80133fc8
kafka aws iam auth profile (#3240) 
Signed-off-by: Fabian Martinez <46371672+famarting@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2023-12-12 16:49:26 +00:00
syedsadath-17 8dfa4b663e
GCP Pubsub: cache topics (#3241) 
Signed-off-by: sadath-12 <sadathsadu2002@gmail.com>
Signed-off-by: syedsadath-17 <90619459+sadath-12@users.noreply.github.com>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.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-12-06 11:49:49 -08:00
syedsadath-17 ca00355413
chore: solace-amqp metadata.yaml (#3243) 
Signed-off-by: syedsadath-17 <90619459+sadath-12@users.noreply.github.com>
Signed-off-by: sadath-12 <sadathsadu2002@gmail.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-11-30 21:47:58 -08:00
Byron Ruth 36a055ebd8
[pubsub/jetstream] Add missing concurrencyMode support for queue-based handler (#3232) 
Signed-off-by: Byron Ruth <byron@nats.io>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2023-11-28 20:24:34 -08:00
Bernd Verst 9095b0e7e7
Switch to Go 1.21, Updates linter, updates workflows, adds sarama 1.42.1 (#3251) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-11-28 18:13:09 -08:00
Bernd Verst c10f59ea49 Redis: recover subscription if group or stream deleted (#3221) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-11-14 12:52:15 -08:00
Alessandro (Ale) Segala 934e86c4f7
Rename folder "internal" to "common" (#3225) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-11-14 11:36:38 -08:00
Byron Ruth dd8d2ba185
[pubsub/jetstream] Add support for concurrencyMode (#3222) 
Signed-off-by: Byron Ruth <byron@nats.io>
 2023-11-13 20:33:48 +00:00
Alessandro (Ale) Segala f4e73b0e65
Update dapr/kit (#3205) 
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-11-02 16:20:56 -07:00
Amit Mor 7fd5524c58
FIx SQS: Error during Dapr Shutdown and Message Polling Behavior Issue (AWS) (#3174) 
Signed-off-by: Amit Mor <amit.mor@hotmail.com>
Signed-off-by: Amit Mor <amitm@at-bay.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-11-01 09:42:22 -07:00
Josh van Leeuwen d47d1a7aad
pubsub/rabbitmq: return error if reconnect errors in Init (#3198) 
Signed-off-by: joshvanl <me@joshvanl.dev>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-10-27 10:38:43 -07:00
ItalyPaleAle 515be48b8e Merge remote-tracking branch 'upstream/release-1.12' 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-10-09 10:24:24 -07:00
Elena Kolevska 5384d54bcd
Fixes GCP components failing to authenticate (#3169) 
Signed-off-by: Elena Kolevska <elena@kolevska.com>
 2023-10-09 08:25:09 -07:00
Alessandro (Ale) Segala 75078a3e17
Remove deprecated NATS Streaming PubSub Component (#3150) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-09-26 13:09:28 -07:00
Alessandro (Ale) Segala 2cb3c1cce1
Enhance Kafka pubsub OIDC auth support to support oauthbearer.extensions (#3124) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Abhinav Mishra <abhinav.mishra@pearson.com>
 2023-09-12 18:09:56 +00:00