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

48 Commits

Author SHA1 Message Date
Gallardot 294dd75354
feat: kafka subpub and bindings support compression (#3676) 
Signed-off-by: Gallardot <gallardot@apache.org>
Co-authored-by: Josh van Leeuwen <me@joshvanl.dev>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2025-05-16 10:45:37 -07:00
Elena Kolevska 5f17025027
Adds Redis stream trimming by time(stream ID) (#3710) 
Signed-off-by: Elena Kolevska <elena@kolevska.com>
Co-authored-by: Cassie Coyle <cassie@diagrid.io>
Co-authored-by: Nelson Parente <nelson_parente@live.com.pt>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2025-05-06 10:59:30 -07:00
Josh van Leeuwen d8ac01bc76
Update go -> 1.24.1 & golangci-lint -> 1.64.6 (#3699) 
Signed-off-by: joshvanl <me@joshvanl.dev>
 2025-03-12 13:50:32 -07:00
MattCosturos 26808c927b
Recreate AEH Processor in the event of an error before retrying the processing operation (#3614) 
Signed-off-by: MattCosturos <48531957+MattCosturos@users.noreply.github.com>
Signed-off-by: Matt Costuros <mcosturos@moog.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
 2024-12-17 09:22:11 -08:00
Shivam Kumar fc8636dbba
Fix Redis EntraId Token Refresh (#3632) 
Signed-off-by: Shivam Kumar <shivamkumar@microsoft.com>
Co-authored-by: Shivam Kumar <shivamkumar@microsoft.com>
 2024-12-16 08:50:51 -08:00
Sam 72c92fb1fe
feat(postgres): add iam roles anywhere auth profile (#3604) 
Signed-off-by: Samantha Coyle <sam@diagrid.io>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2024-12-03 13:17:13 -08:00
Sam f48b4128d6
feat(kafka): iam roles anywhere + assume role auth profiles (#3606) 
Signed-off-by: Samantha Coyle <sam@diagrid.io>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2024-11-27 14:48:18 -08:00
Patrick Assuied 8c02ff33b4
Kafka Pubsub fixes: Avro serialization caching and retries (#3610) 
Signed-off-by: Patrick Assuied <patrick.assuied@elationhealth.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2024-11-26 22:02:19 +00:00
Yaron Schneider 85cbbf123a
Enable eventhubs binding to read all message properties (#3615) 
Signed-off-by: yaron2 <schneider.yaron@live.com>
 2024-11-26 11:50:50 -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
bhagya f0a99c114c
Fix metadata header value sanitization (#3581) 
Signed-off-by: Bhagya Singh Purba <bhagyasingh05@gmail.com>
Co-authored-by: bhagyapurba <bhagya.singhpurba@fyndna.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2024-11-05 22:28:38 +00:00
Seweryn Sirek 54d59d5fc4
[Bindings][BlobStorage] Update request.go - Log debug instead of warning (#3577) 
Signed-off-by: Seweryn Sirek <128463368+ssi-spyro@users.noreply.github.com>
 2024-10-25 16:33:41 -07: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
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
Patrick Assuied 9ea3fee247
Resolving a weird edge case in case of a poison pill message being retried, followed by a pod restart (#3532) 
Signed-off-by: Patrick Assuied <patrick.assuied@elationhealth.com>
 2024-09-05 08:01:58 -07:00
Patrick Assuied e5322262f6
Addressed issue in Kafka-pubsub for avro null messages (#3531) 
Signed-off-by: Patrick Assuied <patrick.assuied@elationhealth.com>
 2024-09-04 21:16:20 -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
Sam 5f3d7ea8eb
security: up dependencies to fix security vulnerabilities (#3390) 
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: Bernd Verst <github@bernd.dev>
Co-authored-by: joshvanl <me@joshvanl.dev>
 2024-06-24 14:24:10 -07:00
Elena Kolevska a385743e35
Kafka bulk publisher fix (#3445) 
Signed-off-by: Elena Kolevska <elena@kolevska.com>
 2024-06-18 06:27:27 -07:00
Sam 787b23d5d0
build: fix github wf to generate metadata bundle (#3435) 
Signed-off-by: Samantha Coyle <sam@diagrid.io>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2024-06-06 15:32:58 -07:00
Bernd Verst f23794f69b
ASB: Add support for ApplicationProperties in subscriptions (#3436) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2024-06-05 10:26:28 -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
Alessandro (Ale) Segala 93cf5cb2c9
Fixups from #3324 (#3419) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2024-05-21 10:26:21 -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
denisbchrsk 4e4aa26c9e
Kafka PubSub: Propagate partition key to DLT (#3368) 
Signed-off-by: denisbchrsk <155584191+denisbchrsk@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2024-05-15 07:23:33 -07:00
Patrick Assuied cfee998aba
Fixing bug with new Avro conversion when message values are NULL (#3388) 
Signed-off-by: Patrick Assuied <patrick.assuied@elationhealth.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2024-03-30 07:04:16 +03:00
Fabian Martinez a9548a7d68
kafka: bugfix possible nil pointer error on close (#3383) 
Signed-off-by: Fabian Martinez <46371672+famarting@users.noreply.github.com>
 2024-03-22 17:26:47 +02: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
Bernd Verst 5445cead81
Recover interrupted eventhubs subscriptions (#3344) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2024-02-08 13:11:56 -08:00
Bernd Verst 903b97d891
Azure Service Bus: enforce `autodeleteonidlesec` minimum 300 (#3340) 2024-02-07 07:50:57 -08:00
Alessandro (Ale) Segala 3b0f320025
Add ExecuteInTransaction method for db.SQL (#3309) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2024-01-16 08:27:46 -08:00
Eunice Compra e524ae7e6f
Kafka: Removed the AWS creds check from kafka metadata (#3313) 
Signed-off-by: Eunice Compra <eunicecompra@gmail.com>
Co-authored-by: Eunice Compra <eunice.compra@gmail.com>
 2024-01-10 23:03:11 +00: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
Fabian Martinez 7d39c46425
Kafka: fix context use in AWS IAM auth (#3305) 
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: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2024-01-09 15:24:00 +00:00
Alessandro (Ale) Segala 94c5618f46
Improve Multi perf on SQL state stores with 1 op only (#3300) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2024-01-04 15:48:08 +00:00
Patrick Assuied 007d0e0bd2
Kafka: Add message key and other metadata as metadata in consumer (#3289) 
Signed-off-by: Patrick Assuied <patrick.assuied@elationhealth.com>
 2024-01-03 09:55:07 -08:00
Yaron Schneider c0a21a0750
Fix Kafka consumer (#3297) 
Signed-off-by: yaron2 <schneider.yaron@live.com>
 2024-01-02 17:09:59 +00:00
Alessandro (Ale) Segala 56579c6d47
Add migration utils for SQL Server (#3280) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
 2024-01-02 17:00:17 +00: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
Alessandro (Ale) Segala 73997a2b8d
PostgreSQL state store v2 (#3250) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-12-18 13:59:30 -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
luigirende a7c64f4e8d
Add new filters type in the query of the state component (#3218) 
Signed-off-by: Luigi Rende <luigirende@gmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-12-06 20:51:27 +00: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
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