Commit Graph

3297 Commits

Author SHA1 Message Date
akhilac1 aa492db3ec fixing merge conflict
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-24 00:12:25 +05:30
Mukundan Sundararajan 8b60079501 Merge remote-tracking branch 'upstream/master' into fix-kafka-session-done-merge-master 2022-09-24 00:11:19 +05:30
akhilac1 43f3465f9b fixed linter error
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-24 00:06:59 +05:30
ItalyPaleAle 65e2dbc363 💄
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-09-23 18:28:38 +00:00
Artur Souza 3877d658e0
Merge branch 'master' into memcached_certification_i1929-rebased 2022-09-23 11:13:33 -07:00
akhilac1 5e58fa4efe change to uuid.NewRandom to avoid panic
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-23 23:20:11 +05:30
Shubham Sharma cd206609ce
Use request metadata instead of component metadata (#2119)
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
2022-09-23 10:49:39 -07:00
Shubham Sharma 4f406a597f
Add bulk subscribe support to Azure Service Bus (#2100)
* Initial implementation

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* 

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Add tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Add comment

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor messages.go and add tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update message tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor servicebus.go logic

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor handleAsync

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor ReceiveAndBlock

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update binding

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Review comments addressed

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Lint

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update metadata name

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update activeMessagesChan logic for concurrency control

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Fix tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update metadata name

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Use request metadata instead of component metadata

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Review comments addressed

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Fix merge issue with metadata

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Remove unused metadata key

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Fix merge issue with metadata

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Lint!!!

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
2022-09-23 10:49:06 -07:00
akhilac1 3d3864956a Merge branch 'postgresql_config_store' of https://github.com/akhilac1/components-contrib into postgresql_config_store 2022-09-23 23:01:03 +05:30
akhilac1 fd0d789fe7 Review comments
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-23 23:00:27 +05:30
Alessandro (Ale) Segala 96fdc8a997
Merge branch 'master' into postgresql_config_store 2022-09-23 10:16:37 -07:00
yellow chicks acf698ee4b
optimize(middleware): Middleware to middleware.Middleware API (#2039)
Signed-off-by: 1046102779 <seachen@tencent.com>

Signed-off-by: 1046102779 <seachen@tencent.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2022-09-23 10:13:54 -07:00
Shubham Sharma b298b65cfe
Add bulk publish support to Azure Service Bus (#2106)
* Initial implementation

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Some improvements

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor and add tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Lint

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Use request metadata instead of component metadata

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Remove unused method

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Review comments addressed

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Doc comments

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
2022-09-23 09:57:00 -07:00
cong 1a7882fca5
fix(kafka): ConsumeClaim should return when messages channel closed (#2120)
Signed-off-by: cong <zhangcong1992@gmail.com>

Signed-off-by: cong <zhangcong1992@gmail.com>
2022-09-23 09:54:59 -07:00
deepanshuagarwal 8500da577c
Conf test for Bulk Subscribe and Kafka fixes (#2113)
* Conf test for Bulk Sub and Kafka Fixes

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

* Fix linting

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

* Incorporating comments

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

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-23 09:54:21 -07:00
Yaron Schneider 130f5afbd2
Merge branch 'master' into dapr-subscriptionproducerissuer 2022-09-23 09:03:37 -07:00
akhilac1 d013c7505e changed row iteration to use generic method from pgxv5
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-23 17:30:09 +05:30
akhilac1 86b77cc269 Merge branch 'postgresql_config_store' of https://github.com/akhilac1/components-contrib into postgresql_config_store 2022-09-23 14:17:11 +05:30
akhilac1 d569c1776d fixed wrapping error from %s to %w
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-23 14:16:46 +05:30
AkhilaC 2323ce9866
Merge branch 'master' into postgresql_config_store 2022-09-23 11:44:28 +05:30
Bernd Verst e1d9a3bf98
Merge pull request #2118 from mukundansundar/merge-master-pubsub-feature 2022-09-22 21:15:29 -07:00
Tiago Alves Macambira 8e4af0a3a4 Certification tests for MemCached State Store component.
* Add network instability tests.
* Fixed gofumpt issues.
* Addresses TTL translation from Dapr and Memcache domains.

    Memcached uses `0` as the non-expiring marker TTL.
    [src](https://github.com/memcached/memcached/wiki/Commands#set).

    On the other hand, Dapr uses `-1` for that.
    [src](https://docs.dapr.io/developing-applications/building-blocks/state-management/state-store-ttl/)

    This PR updates certification and memcached code and tests so Dapr -1 (and negative)
    values are translated to Memcached's `0`.

Closes #1929

Signed-off-by: Tiago Alves Macambira <tmacam@burocrata.org>
2022-09-22 18:26:55 -07:00
Mukundan Sundararajan e1697ba115 Merge branch 'master' into feature/pubsub-batching 2022-09-23 06:47:47 +05:30
Bernd Verst ac87ed4e9d
Merge pull request #2049 from zcong1993/master
fix(kafka): ConsumeClaim should return when session context is done
2022-09-22 13:26:53 -07:00
Bernd Verst f4fa64b0f4
Merge branch 'master' into master 2022-09-22 12:15:30 -07:00
Bernd Verst 1652f48a38
Merge pull request #2103 from mukundansundar/add-bulkpublish-conf-test
Adding conformance for bulk publish and properly map kafka errors on bulk publish
2022-09-22 12:04:11 -07:00
Bernd Verst be171c96f9
Merge pull request #2115 from ItalyPaleAle/blob-metadata-ascii
Do not allow Unicode letters in sanitized metadata
2022-09-22 11:58:52 -07:00
ItalyPaleAle 1a6e11fc63 Do not allow Unicode letters in sanitized metadata
Follow-up from #2112

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-09-22 16:46:14 +00:00
akhilac1 925e8f32a0 updated timeout
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-22 20:17:41 +05:30
Mukundan Sundararajan 4354f036e4 properly parse response errors from kafka on sending multiple messages in bulk publish
Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
2022-09-22 16:51:34 +05:30
akhilac1 f13fcf1ef3 Merge branch 'postgresql_config_store' of https://github.com/akhilac1/components-contrib into postgresql_config_store 2022-09-22 15:05:35 +05:30
akhilac1 5a06d2d980 fixed review comments
Signed-off-by: akhilac1 <chetlapalle.akhila@gmail.com>
2022-09-22 15:04:50 +05:30
Mukundan Sundararajan 2817724483
Merge branch 'master' into postgresql_config_store 2022-09-22 13:41:16 +05:30
Mukundan Sundararajan db0ace71bc address review comments
Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
2022-09-22 13:30:56 +05:30
Bernd Verst 9772c103c2
Merge pull request #2097 from pravinpushkar/fix/configapi_getall
Fix getAll configuration Api for azure app config
2022-09-22 00:04:09 -07:00
Bernd Verst a1f47964cd
Merge branch 'master' into fix/configapi_getall 2022-09-21 23:51:24 -07:00
Bernd Verst 6fe9cbc727
Merge pull request #2111 from berndverst/nomorenoise
actually disable cert test coverage notifications on PR and ok-to-test
2022-09-21 23:51:04 -07:00
Bernd Verst ac73313d6f
Merge branch 'master' into master 2022-09-21 23:40:53 -07:00
Bernd Verst 0af7a60c13
Merge branch 'master' into fix/configapi_getall 2022-09-21 23:36:17 -07:00
Bernd Verst 5dd903f94d
Merge branch 'master' into nomorenoise 2022-09-21 23:35:29 -07:00
Bernd Verst ce28451fef
Merge pull request #2110 from berndverst/certtestupdate
pin latest dapr/dapr in cert tests
2022-09-21 23:35:04 -07:00
Pravin Pushkar 2d72e46589
Merge branch 'master' into fix/configapi_getall 2022-09-22 11:55:02 +05:30
Bernd Verst aab8d44df3 import latest dapr/dapr in cert tests
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-21 23:18:41 -07:00
Bernd Verst 44027d34cc
Merge branch 'master' into certtestupdate 2022-09-21 23:16:27 -07:00
Bernd Verst a1ee8a3123
Merge pull request #2112 from berndverst/creatblobmetadata
sanitize createBlob request metadata in AzStorageBlob
2022-09-21 23:16:16 -07:00
Bernd Verst 16375aec8d
Merge branch 'master' into nomorenoise 2022-09-21 23:08:59 -07:00
Bernd Verst 0b8b663e3e add warning message for changing metadata key
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-21 23:05:22 -07:00
Bernd Verst abb3ce3030
Merge branch 'master' into creatblobmetadata 2022-09-21 22:53:30 -07:00
Bernd Verst a1bdcdd492
Merge pull request #2109 from berndverst/azuresdk-maintenance-upgrade
Upgrade all Azure Track 2 components to their latest minor / patch SDK versions
2022-09-21 22:52:14 -07:00
Bernd Verst ddf16a11b2 add test case
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-21 22:34:28 -07:00