dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
1,946 Commits 55 Branches 159 Tags 84 MiB
Commit Graph

1946 Commits

Author SHA1 Message Date
mecoding1 9e51ac90e4 Update eventHubs.go for lint fix ST1023: 
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-22 12:48:19 +00:00
mecoding1 a669c4733b Updating eventshub.go, to ensure receiving custom properties from IoT Hub 
Currently, we can receive only the system properties from iot hub. Done changes should allow the retrieval of all custom properties.
It is based on metadata key : requireAllProperties.

By default it is false, if true , looks into the , Properties of Event struct to retrieve the custom properties.

Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-22 12:48:19 +00:00
Armin Schlegel 0bbc8c42d6 jetstream pubsub now supports token based auth (#2295) 
Signed-off-by: Armin Schlegel <armin.schlegel@gmx.de>

Signed-off-by: Armin Schlegel <armin.schlegel@gmx.de>
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-22 12:48:19 +00:00
Pravin Pushkar 06ffaa52b5 address review comments 
Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-22 12:48:19 +00:00
Pravin Pushkar 1773283f79 address review comments 
Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-22 12:48:19 +00:00
Pravin Pushkar d7ac63f50e Address review comments 
Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-22 12:48:19 +00:00
Pravin Pushkar 42609bbcc0 azappconfig incorporate OnlyIfChanged flag from sdk 
Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-11-22 12:48:19 +00:00
Bernd Verst bd534a35db
Merge pull request #2293 from ItalyPaleAle/refactorings 
Some misc refactorings in state stores
 2022-11-17 11:16:57 -08:00
ItalyPaleAle 1e728597b4 Misc refactorings 
- Removed `state.DeleteWithOptions` and `state.SetWithOptions` which were useless at this point (likely a leftover from when there were retries)
- Some improvements in etag handling in postgres
- Other minor refactorings

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2022-11-17 16:29:29 +00:00
Bernd Verst d366211810
Merge pull request #2289 from berndverst/firstwritepostgres 
Postgres State Store: Add Support for First-Write concurrency
 2022-11-16 21:52:38 -08:00
Bernd Verst b7d56fd7d6 Postgresql: allow custom table table 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-16 20:13:57 -08:00
Bernd Verst 3af0953516 Postgres State Store: Add Support for First-Write concurrency 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-16 20:13:57 -08:00
Bernd Verst 973ff8f94c
Merge pull request #2287 from berndverst/fixservicebuscerttest 
Fix servicebus topics certification test
 2022-11-16 16:43:42 -08:00
Bernd Verst a76d4b25af fix servicebus topics certification test 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-16 16:12:42 -08:00
Bernd Verst 592ff74f75
Merge pull request #2286 from berndverst/asqbindingvisibilitytimeout 
ASQ Binding: Cert Test: Add queue visibilityTimeout test
 2022-11-16 15:43:58 -08:00
Bernd Verst d7dd4799d0 ASQ Binding: Cert Test: Add queue visibilityTimeout test 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-16 15:28:10 -08:00
Bernd Verst a5fbd61523
Merge pull request #2278 from berndverst/asbq-visibilitytimeout 2022-11-16 00:25:16 -08:00
Bernd Verst 1b645097df
Merge branch 'master' into asbq-visibilitytimeout 2022-11-15 17:04:21 -08:00
Bernd Verst 76ad618c88
Merge pull request #2285 from berndverst/cosmosdbuseragent 
Adding CosmosDB and TableStorage Dapr User Agents
 2022-11-15 17:02:32 -08:00
Bernd Verst 483e8b96bc Add user agent to table storage state store 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-15 16:49:56 -08:00
Bernd Verst 14d89afeef Add user agent back to Cosmos DB Binding 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-15 14:59:04 -08:00
Bernd Verst 2698482f34 Add user agent back to Cosmos DB state store 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-15 14:55:20 -08:00
Bernd Verst 507fbc5c8b Merge branch 'master' into asbq-visibilitytimeout 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-15 12:57:34 -08:00
Bernd Verst e8d070a44d
Merge pull request #2269 from RyanLettieri/master 2022-11-15 11:27:19 -08:00
Bernd Verst d916808824 address linter issue 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-14 18:14:19 -08:00
Bernd Verst 5c9a5792be ASQ Binding: Make visibilityTimeout configurable 
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
 2022-11-14 11:48:20 -08:00
Ryan Lettieri deb647c241 Updating workflows request struct 
Signed-off-by: Ryan Lettieri <ryanLettieri@microsoft.com>
 2022-11-14 12:39:35 -07:00
Ryan Lettieri 4ebe7ea400
Merge branch 'dapr:master' into master 2022-11-14 10:10:02 -07: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
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
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