Commit Graph

3297 Commits

Author SHA1 Message Date
Bernd Verst 2ba9556b8d
Merge branch 'master' into fix-kafka-metadata 2022-09-16 17:27:13 -07:00
Bernd Verst b49719c940
Merge pull request #2092 from dapr/dependabot/go_modules/github.com/open-policy-agent/opa-0.43.1
Bump github.com/open-policy-agent/opa from 0.42.0 to 0.43.1
2022-09-16 17:24:29 -07:00
Ryan Lettieri 831f3d0dd2 Make mod tidy error
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
2022-09-16 15:09:53 -06:00
Ryan Lettieri aa0228becd Cleaning up transactional code in cosmosdb statestore
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
2022-09-16 15:04:30 -06:00
ItalyPaleAle 8e31adf493 Merge branch 'Cosmosdb_track2' of https://github.com/RyanLettieri/components-contrib into Cosmosdb_track2 2022-09-16 21:00:16 +00:00
Alessandro (Ale) Segala 31a8be18da
Merge branch 'master' into Cosmosdb_track2 2022-09-16 13:49:29 -07:00
ItalyPaleAle 3c2e82a0e7 💄
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-09-16 20:49:14 +00:00
ItalyPaleAle cec34b9a95 💄
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-09-16 20:44:40 +00:00
Bernd Verst b8be7ecf5b
Merge branch 'master' into workflow-dev 2022-09-16 13:36:13 -07:00
Bernd Verst f4a149763f make modtidy-all
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-16 13:34:28 -07:00
ItalyPaleAle 0ed1a8acf0 Misc fixes
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-09-16 20:32:02 +00:00
ItalyPaleAle fd881e20f7 Use dapr/kit/ptr instead of old ptr
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-09-16 19:41:48 +00:00
Ryan Lettieri 79c039c08d Using helper method to grab partition key or default to empty string
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
2022-09-16 12:44:06 -06:00
dependabot[bot] 7391f9628c
Bump github.com/open-policy-agent/opa from 0.42.0 to 0.43.1
Bumps [github.com/open-policy-agent/opa](https://github.com/open-policy-agent/opa) from 0.42.0 to 0.43.1.
- [Release notes](https://github.com/open-policy-agent/opa/releases)
- [Changelog](https://github.com/open-policy-agent/opa/blob/main/CHANGELOG.md)
- [Commits](https://github.com/open-policy-agent/opa/compare/v0.42.0...v0.43.1)

---
updated-dependencies:
- dependency-name: github.com/open-policy-agent/opa
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>
2022-09-16 17:53:37 +00:00
Deepanshu Agarwal 3656a495fc Incorporating comments
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-16 23:03:58 +05:30
Deepanshu Agarwal 217505fd16 Move common costants to common utils
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-16 22:22:54 +05:30
Deepanshu Agarwal d602e0ab0c Move constants to utils
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-16 22:07:38 +05:30
Deepanshu Agarwal 55ad67d510 When UUID could not be generated
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-16 21:44:37 +05:30
Shubham Sharma 313aa9ece1 Add comment
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
2022-09-16 20:11:55 +05:30
Deepanshu Agarwal 2f70a0529b Merge branch 'ps_batch_c_kafka' of github.com:DeepanshuA/components-contrib into ps_batch_c_kafka 2022-09-16 20:06:54 +05:30
Deepanshu Agarwal 81898d5ee5 Config Per Topic and using maxAwaitDuration
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-16 20:04:32 +05:30
Shubham Sharma f7e9d25a5c Return correctly
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
2022-09-16 18:26:09 +05:30
Shubham Sharma c81eefcc46 Add bulk publish for event hub
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
2022-09-16 17:51:23 +05:30
akhilac1 c3d9e844a7 fixed SQL injection review comments
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-16 14:08:15 +05:30
akhilac1 3935f058db fixed errors identified during functional testing
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-16 14:08:15 +05:30
akhilac1 1e5c5a4ba8 fixed errors identified during functional testing
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-16 14:08:15 +05:30
akhilac1 584c80a667 fixing lint errors
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-16 14:08:15 +05:30
akhilac1 cf413bf8fc updating review comments
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-16 14:08:15 +05:30
akhilac1 ddc130640e Support for Postgres configuration store
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-16 14:08:15 +05:30
akhilac1 e870792595 Support Postgres config store
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-16 14:08:15 +05:30
akhilac1 cb22194e69 Support Postgres as configuration store #4551
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-16 14:08:15 +05:30
akhilac1 79617ca87c Merge branch 'postgresql_config_store' of https://github.com/akhilac1/components-contrib into postgresql_config_store 2022-09-16 12:06:53 +05:30
akhilac1 4788ac86aa fixed SQL injection review comments
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-16 12:06:13 +05:30
Deepanshu Agarwal d31f4d99f5 Merge branch 'feature/pubsub-batching' of github.com:dapr/components-contrib into ps_batch_c_kafka 2022-09-16 11:36:23 +05:30
Dapr Bot cbbc8059d5
Merge branch 'master' into fix-kafka-metadata 2022-09-15 18:05:14 -07:00
Carlos Mendible 42fc9ae0f2
Implements getLabelFromMetadata Fixing #2062 (#2064)
Signed-off-by: cmendible <266546+cmendible@users.noreply.github.com>

Signed-off-by: cmendible <266546+cmendible@users.noreply.github.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2022-09-15 17:31:08 -07:00
Dapr Bot 09c4107f33
Merge branch 'master' into fix-kafka-metadata 2022-09-15 16:58:36 -07:00
Artur Souza adb5eee364
Merge branch 'master' into postgresql_config_store 2022-09-15 16:52:50 -07:00
Alessandro (Ale) Segala b8931a5575
Updated docs for creating new components (#2078)
Due to dapr/dapr#5062

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-15 16:47:31 -07:00
Bernd Verst ee638ce5ff
Merge branch 'master' into fix-kafka-metadata 2022-09-15 16:32:42 -07:00
Bernd Verst 3dab754b94
Merge pull request #2082 from yash-nisar/redis_binding
Add Redis binding certification tests
2022-09-15 16:30:22 -07:00
Bernd Verst d63ccc3713
Merge branch 'master' into redis_binding 2022-09-15 16:03:54 -07:00
Ryan Lettieri 097737f6cd Adding timeout to transactional batch in comsosdb statestore
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
2022-09-15 16:58:09 -06:00
Ryan Lettieri b2f4f1fe17
Merge branch 'master' into Cosmosdb_track2 2022-09-15 15:25:26 -06:00
Ryan Lettieri 705070036d Fixing conformance test for cosmosDB for track2sdk
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
2022-09-15 14:58:58 -06:00
Artur Souza 54d1d5e89b Merge remote-tracking branch 'upstream/feature/pubsub-batching' into ps_batch_c_kafka 2022-09-15 13:21:42 -07:00
Mukundan Sundararajan 3f9c42c4b8
Kafka bulk publish (#2059)
* Contrib updates for Batch Subscribe

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* commit

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Commit pubsub

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Update structs

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Update Default Batch struct name

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Update Default Batch

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Update return type for BatchPublish

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Add docs

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Rename batch to bulk

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* snssqs renam batch to bulk

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Renaming Bulker to BulkMessager

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Renaming names as discussed

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Minor updates

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Remove ContentType from BulkPublishRequest

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Update error type

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Changes to bulk subscribe and error type

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Segregating Bulk Publisher and Bulk Subscriber and removing them as mandatory

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Event Type name correction

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Docs update as per comments

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* bulk publish implementation for kafka

Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>

* Add ctx to BulkPublish.

Signed-off-by: Artur Souza <artursouza.ms@outlook.com>

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
Signed-off-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2022-09-15 13:17:17 -07:00
Deepanshu Agarwal f11660e70d Change to warning normal subscribe part as well
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-15 16:09:47 +05:30
Deepanshu Agarwal f5542c70b9 Incorporate review comments and remove index based entryID
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-15 16:02:30 +05:30
akhilac1 b1c7f5be96 Merge branch 'postgresql_config_store' of https://github.com/akhilac1/components-contrib into postgresql_config_store 2022-09-15 15:25:54 +05:30