Commit Graph

3297 Commits

Author SHA1 Message Date
Ryan Lettieri 4ebe7ea400
Merge branch 'dapr:master' into master 2022-11-14 10:10:02 -07:00
spike 6937857bf8 Change error message and comment
Signed-off-by: spike <hello@spike.wiki>
2022-11-13 15:34:01 +08:00
spike 1d9f3358e4 Add rabbitmq tls metadata
Signed-off-by: spike <hello@spike.wiki>
2022-11-13 15:17:50 +08:00
Ryan Lettieri 9d39e9ee87 Adding in optional parameter for a namespace into temporal
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
2022-11-12 11:04:32 -07:00
Bernd Verst c92827c3de
Merge pull request #2272 from kubemq-io/master
Adding KubeMQ Binding - Queue
2022-11-11 13:58:03 -08:00
Lior Nabat 1024190fcc update for gofumpt
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-11 23:41:09 +02:00
KubeMQ adb840bb84
Merge branch 'dapr:master' into master 2022-11-11 23:34:39 +02:00
Bernd Verst ed70762380
Merge pull request #2275 from berndverst/linter
Upgrade linter and fix linter issues
2022-11-11 13:33:33 -08:00
Bernd Verst 462e2faadc Upgrade linter and fix linter issues
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-11 13:19:57 -08:00
Lior Nabat c53ea4a524 revert golangci.yml
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-11 23:14:41 +02:00
Lior Nabat cf1cee0941 update new line for linter
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-11 23:11:22 +02:00
Lior Nabat 12ad3b9bde update new line for linter
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-11 22:47:34 +02:00
Bernd Verst c23310ef04
Merge branch 'master' into master 2022-11-11 12:24:32 -08:00
Lior Nabat ac46b110c8 re-Arrange for lint
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-11 22:06:08 +02:00
Lior Nabat f928b2235e Remove Content-Type
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-11 21:47:55 +02:00
Lior Nabat 80ba89988c Add to conformance file
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-11 21:39:19 +02:00
KubeMQ ead1843aab
Merge branch 'master' into master 2022-11-11 21:36:57 +02:00
Taction 9870c5e33b
Add pubsub rabbitmq TTL support (#2093)
* Add pubsub rabbitmq TTL support

Signed-off-by: zhangchao <zchao9100@gmail.com>

* fix review: remove queue level ttl, both ttl is handled when publishing, to make message ttl has priority over queue level ttl

Signed-off-by: zhangchao <zchao9100@gmail.com>

* add rabbitmq ttl certificate test

Signed-off-by: zhangchao <zchao9100@gmail.com>

* fix lint

Signed-off-by: zhangchao <zchao9100@gmail.com>

* fix ttl certificate test precreate topic

Signed-off-by: zhangchao <zchao9100@gmail.com>

* tiny fix tests

Signed-off-by: zhangchao <zchao9100@gmail.com>

Signed-off-by: zhangchao <zchao9100@gmail.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-11 11:34:33 -08:00
Pravin Pushkar 7295b3acc1 azappconfig incorporate OnlyIfChanged flag from sdk
Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>
2022-11-11 23:49:23 +05:30
Lior Nabat a47d8f87dd Adding KubeMQ Binding - Queue
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-11 16:03:25 +02:00
Bernd Verst acb51bbbd3
Merge pull request #2244 from Jarema/explicitly-add-consumer
Add `streamName` and epxlicitly bind to consumer and stream
2022-11-11 00:28:43 -08:00
Ryan Lettieri 9e71493da7
Merge branch 'dapr:master' into master 2022-11-10 13:30:27 -07:00
Bernd Verst 0d3e794986
Merge branch 'master' into explicitly-add-consumer 2022-11-10 12:23:59 -08:00
Bernd Verst 74a090c400
Merge pull request #2263 from berndverst/storagequeuesencode
Storage Queues Binding: Add b64encoding option for messages
2022-11-10 12:23:27 -08:00
Bernd Verst e5a2266fa8 Address lint issues
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-10 12:23:04 -08:00
Bernd Verst eec3698d72 Use nats.go v1.19.1 and modtidy-all
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-10 12:08:36 -08:00
Bernd Verst 9a8bcc5fa5
Merge branch 'master' into explicitly-add-consumer
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-10 12:05:51 -08:00
Bernd Verst 989c25d421
Merge branch 'master' into storagequeuesencode 2022-11-10 12:03:46 -08:00
jinjianfeng-chn 875abcda56
Add rocketmq configuration items. Add orderly message. (#2198)
* Add rocketmq configuration items. Add orderly message. Change the version of rocketmq-client-go to v2.1.0.

Signed-off-by: jinjianfeng-chn <feng081212@163.com>

* modtidy

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

Signed-off-by: jinjianfeng-chn <feng081212@163.com>
Signed-off-by: Bernd Verst <4535280+berndverst@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>
2022-11-10 11:54:40 -08:00
Bernd Verst 3710319272
Merge branch 'master' into storagequeuesencode 2022-11-10 11:18:27 -08:00
Bernd Verst 1249716130
Merge pull request #2268 from yaron2/sqsfix-1
Fix deletion of sqs queue regression
2022-11-10 11:18:00 -08:00
yaron2 1f2c987c86 linter
Signed-off-by: yaron2 <schneider.yaron@live.com>
2022-11-10 10:32:24 -08:00
yaron2 beaa223bc2 fix deletion of sqs queue regression
Signed-off-by: yaron2 <schneider.yaron@live.com>
2022-11-10 10:08:35 -08:00
Ryan Lettieri a6176e3cf1 Adding in optional metadata parameter for namespace in temporal
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
2022-11-10 09:20:15 -07:00
Bernd Verst c8aa090e56
Merge branch 'master' into storagequeuesencode 2022-11-09 15:58:49 -08:00
wxbty e69ae3751d
feat:add redis binder invoke of del&get (#2197)
Signed-off-by: x-shadow-man <1494445739@qq.com>

Signed-off-by: x-shadow-man <1494445739@qq.com>
Co-authored-by: x-shadow-man <1494445739@qq.com>
2022-11-09 14:42:49 -08:00
Bernd Verst b2e5c1cbea
Merge branch 'master' into storagequeuesencode 2022-11-08 21:38:57 -08:00
Bernd Verst 73ec4e3cfc Storage Queues Binding: Add b64encoding option for messages
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-08 21:35:56 -08:00
Nick ce87730a73
pubsub jetstream: set Nats-Msg-Id for message deduplication (#2200) (#2202)
Signed-off-by: NickLarsenNZ <nick@aptiv.co.nz>

Signed-off-by: NickLarsenNZ <nick@aptiv.co.nz>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-08 19:49:34 -08:00
Bernd Verst 8256ac0a0a
Merge pull request #2262 from havardzzl/master
fix kubernetes nameresolution customize configuration
2022-11-08 18:57:26 -08:00
Bernd Verst dbfdabcbf4
Merge branch 'master' into master 2022-11-08 17:02:33 -08:00
Bernd Verst 6522138dc9
Merge pull request #2215 from kubemq-io/master
Add new PubSub component - KubeMQ Kubernetes message broker
2022-11-08 16:06:25 -08:00
zhangzhongliang@kanzhun.com 4cf523bc45 fix kubernetes nameresolution customize configuration 2022-11-08 16:19:55 +08:00
KubeMQ ae3c152b79
Merge pull request #2 from berndverst/pr2215
Update PR 2215 with Upstream
2022-11-07 21:53:11 +02:00
Bernd Verst 4b490adff9 Merge remote-tracking branch 'upstream/master' into kubemq-io/master
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-07 11:28:25 -08:00
Bernd Verst ede060959a
Refactors all state store to standardize metadata parsing (#2257) 2022-11-05 15:36:44 -07:00
Lior Nabat 0e783e593e Update - adding conformance tests
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-04 17:42:01 +02:00
KubeMQ 6039028458
Merge pull request #1 from berndverst/pr2215
Fix up PR 2215
2022-11-04 17:13:38 +02:00
Alessandro (Ale) Segala ca3e80b76b
Updated depguard linter config (#2245)
* Updated depguard linter config

1. Add older (pre-v4) versions of `github.com/cenkalti/backoff` to the denylist
2. Add `github.com/agrea/ptr` to the denylist (use `github.com/dapr/kit/ptr` instead)
3. Fixed error messages for denied deps

Port of dapr/dapr#5438

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

* ⚙️🧹

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

* Remove some github.com/pkg/errors

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

* make modtidy-all after rebase

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Bernd Verst <4535280+berndverst@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>
2022-11-03 22:19:21 -07:00
Taction 132b22ecf2
change GOLANG_PROTOBUF_REGISTRATION_CONFLICT from warn to ignore (#2254)
Signed-off-by: zhangchao <zchao9100@gmail.com>

Signed-off-by: zhangchao <zchao9100@gmail.com>
2022-11-03 21:56:07 -07:00