132f562e48
Updates dapr/kit to main ( #3816 )
...
Signed-off-by: joshvanl <me@joshvanl.dev>
2025-05-22 06:59:46 -07:00
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
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
4dfc9e55d5
feat(pulsar): support subscribeInitialPosition on Pulsar consumer ( #3700 )
...
Signed-off-by: ericsyh <ericshenyuhao@outlook.com>
Signed-off-by: Eric Shen <ericshenyuhao@outlook.com>
Co-authored-by: Cassie Coyle <cassie@diagrid.io>
Co-authored-by: Cassie Coyle <cassie.i.coyle@gmail.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Josh van Leeuwen <me@joshvanl.dev>
2025-04-29 11:11:53 -07:00
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
1e295a7056
fix: make sure region field is required on other components ( #3625 )
...
Signed-off-by: Samantha Coyle <sam@diagrid.io>
2024-12-06 14:00:34 -08:00
6200ea81de
style: improve clarity on aws changes ( #3623 )
...
Signed-off-by: Samantha Coyle <sam@diagrid.io>
2024-12-04 12:45:34 -08:00
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
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
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
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
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
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
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
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
b969bbfe88
Add receiverQueueSize to pulsar ( #3589 )
...
Signed-off-by: yaron2 <schneider.yaron@live.com>
2024-11-03 21:25:09 -08:00
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
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
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
9156779aa8
Merges 1.14 into master
2024-08-29 17:12:07 +02:00
e53cf3401f
Fix MQTT3 component ( #3501 )
...
Signed-off-by: mikeee <hey@mike.ee>
2024-08-02 10:37:20 -07:00
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
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
a409bc1f96
fix: drop duplicate awsRegion/region field ( #3490 )
...
Signed-off-by: Eileen Yu <eileenylj@gmail.com>
2024-07-25 09:40:08 -07:00
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
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
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
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
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
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
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
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
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
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
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
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
6413239626
PubSub Kafka: Respect Subscribe context ( #3363 )
...
Signed-off-by: joshvanl <me@joshvanl.dev>
2024-02-28 10:13:06 -08:00
86abb49ab2
Enable configurable concurrency for pulsar ( #3330 )
...
Signed-off-by: yaron2 <schneider.yaron@live.com>
2024-02-02 10:29:31 -08:00
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
a3149e5a8c
left uppercase in metadata ( #3312 )
...
Signed-off-by: Patrick Assuied <patrick.assuied@elationhealth.com>
2024-01-10 10:29:23 -08:00
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
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
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
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
323e9bfcfd
Add kafka configuration to pub/sub ( #3275 )
...
Signed-off-by: yaron2 <schneider.yaron@live.com>
2023-12-15 17:26:06 +00:00
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
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
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
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
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
Josh van Leeuwen
Gallardot
Elena Kolevska
Eric Shen
Sam
Yaron Schneider
Gustavo Chaín
Elena Kolevska
Mike Nguyen
Artur Souza
Eileen Yu
Bernd Verst
mahparaashley
Nikola Nedeljkovic
Nathan Lowry
Jake Engelberg
Arthur Poiret
denisbchrsk
Patrick Assuied
Eunice Compra
Alessandro (Ale) Segala
Fabian Martinez
syedsadath-17
Byron Ruth