dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
3,297 Commits 54 Branches 155 Tags 80 MiB
Commit Graph

569 Commits

Author SHA1 Message Date
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
Roberto Rojas 304ad6b515
[Bindings Kafka] Adds Component Metadata Schema (#3068) 
Signed-off-by: robertojrojas <robertojrojas@gmail.com>
Signed-off-by: Roberto Rojas <robertojrojas@gmail.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Tiago Alves Macambira <tmacam@burocrata.org>
 2023-09-12 08:21:31 -07:00
Roberto Rojas 32b1b301b5
[PubSub MQTT3] Adds Component Metadata Schema (#3070) 
Signed-off-by: robertojrojas <robertojrojas@gmail.com>
Signed-off-by: Roberto Rojas <robertojrojas@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>
Co-authored-by: Tiago Alves Macambira <tmacam@burocrata.org>
 2023-09-12 05:48:56 -07:00
Roberto Rojas f074240c0a
[PubSub RabbitMQ] Adds Component Metadata Schema (#3069) 
Signed-off-by: robertojrojas <robertojrojas@gmail.com>
Signed-off-by: Roberto Rojas <robertojrojas@gmail.com>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Tiago Alves Macambira <tmacam@burocrata.org>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2023-09-12 05:44:51 -07:00
Taction 0c2ce324b2
Rabbitmq pubsub add client name (#2933) 
Signed-off-by: zhangchao <zchao9100@gmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-09-05 15:14:17 -07:00
Bernd Verst 247b08a70c
Jetstream pubsub: Use AckWait time for Retry delay (#3102) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-08-24 17:48:30 -07:00
Roberto Rojas 681e81f1bf
[PubSub GCP] Fixes Metadata Name typo (#3096) 
Signed-off-by: robertojrojas <robertojrojas@gmail.com>
 2023-08-22 07:58:10 -07:00
Shivam Kumar 7a5397f05a
bulk subscribe support in azure eventhubs (#3011) 2023-08-14 23:36:28 -07:00
Alessandro (Ale) Segala 80a16418c8
Fixed a large number of errors in metadata.yaml (#3081) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-08-14 18:42:57 -07:00
Roberto Rojas 01646b8833
[GCP PubSub] Adds Component Metadata Schema (#3057) 
Signed-off-by: robertojrojas <robertojrojas@gmail.com>
Signed-off-by: Roberto Rojas <robertojrojas@gmail.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
 2023-08-14 21:06:47 +00:00
Yaron Schneider 5d6ee65d26
Retain cloudevent trace fields (#3080) 
Signed-off-by: yaron2 <schneider.yaron@live.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-08-14 13:40:14 -07:00
Alessandro (Ale) Segala d16fd9ac63
Add deprecation warning to NATS Streaming component (#3043) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-08-10 17:27:58 -07:00
Roberto Rojas 9fdad8f3f7
[PubSub Pulsar] Adds Component Metadata Schema (#3071) 
Signed-off-by: robertojrojas <robertojrojas@gmail.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
 2023-08-10 21:28:53 +00:00
Álvaro Aguilar-Tablada Espinosa e10d5b7e86
[RabbitMQ pub/sub] Allow quorum queues (#2816) 
Signed-off-by: Bernd Verst <github@bernd.dev>
Signed-off-by: Alvaro Aguilar <alvaro.aguilar@scrm.lidl>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Álvaro Aguilar <95039001@lidl.de>
Signed-off-by: Álvaro Aguilar <alvaroteleco@hotmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Álvaro Aguilar <95039001@lidl.de>
 2023-08-07 06:28:58 -07:00
Josh van Leeuwen 7937d34bb7
Pubsub pulsar authentication ~OIDC~ OAuth2 (#3026) 
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>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-08-02 17:17:55 -07:00
Alessandro (Ale) Segala c43af14d31 Revert "Adds OIDC authentication support for pubsub Apache Pulsar (#3023)" 
This reverts commit af5bacebf4.
 2023-08-01 12:03:04 -07:00
Josh van Leeuwen af5bacebf4
Adds OIDC authentication support for pubsub Apache Pulsar (#3023) 
Signed-off-by: joshvanl <me@joshvanl.dev>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2023-08-01 11:38:33 -07:00
Roberto Rojas 69df184f51
[AWS PubSub SNSSQS] Adds Component Metadata Schema (#2905) 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
Signed-off-by: Roberto Rojas <robertojrojas@gmail.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2023-08-01 06:31:01 +00:00
Yaron Schneider 76b8480ff9
Add consumer proto schema validation for pulsar (#3014) 
Signed-off-by: yaron2 <schneider.yaron@live.com>
Signed-off-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2023-07-25 18:12:47 +00:00
Alessandro (Ale) Segala c75005582b
Add metadata.yaml for in-memory state store (#2991) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-07-24 16:02:39 -07:00
Alessandro (Ale) Segala ec05809ee6
[Metadata] Update validator and some other fixes (#2984) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-07-17 22:17:22 +00:00
Alessandro (Ale) Segala cef854fab6
Some linting in metadata.yaml files (#2977) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-07-11 01:53:58 +00:00
Jack Robertson 3bfa20bda1
rabbitmq pub/sub: add queue name to subscription request metadata (#2962) 
Signed-off-by: Jack Robertson <jcrobertson97@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-07-07 21:24:25 +00:00
Roberto Rojas e52df95532
[Redis State] Component Metadata Schema: sets redisPassword to sensitive (#2934) 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
 2023-06-24 11:29:57 -07:00
Arturo Trenard ef4780beaa
Pubsub pluggable component bulkpublish (#2931) 
Signed-off-by: arturo <jarturotrenard@gmail.com>
Signed-off-by: arturo <ajt@ptytechnologies.com>
Signed-off-by: Arturo Trenard <jarturotrenard@gmail.com>
Co-authored-by: arturo <ajt@ptytechnologies.com>
 2023-06-22 15:14:18 +00:00
spike 2576a3150d
Fix rabbitmq exchange declare (#2836) 
Signed-off-by: Bernd Verst <github@bernd.dev>
Signed-off-by: spike <hello@spike.wiki>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-05-22 18:44:27 -07:00
Byron Ruth 54673a0f58
Add JetStream pubsub unit tests (#2845) 
Signed-off-by: Byron Ruth <byron@nats.io>
 2023-05-17 16:56:08 -07:00
Byron Ruth d2cad27b3f
[jetstream] Fix setting omitted QueueGroupName on ConsumerConfig (#2835) 
Signed-off-by: Byron Ruth <byron@nats.io>
 2023-05-16 17:56:18 -07:00