dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
3,297 Commits 54 Branches 155 Tags 75 MiB
Commit Graph

71 Commits

Author SHA1 Message Date
Yaron Schneider d7eeb2413f
Fix RabbitMQ concurrency (#576) 
* fix rabbitmq concurrency

* linter

* add concurrency validation

* added tests and validation
 2021-01-07 19:29:58 -08:00
Yaron Schneider 7465e4092d
Add concurrency mode to rabbitMQ pub/sub (#575) 
* add concurrency mode to rabbitMQ pub/sub

* linter

* simplify
 2021-01-07 15:02:58 -08:00
Artur Souza e6dadfab6c
TTL in PubSub. (#565) 
* TTL in PubSub.

* Handle message TTL only if component cannot handle it.

* Removig dead code for overflow check in pubsub expiration.
 2020-12-29 14:28:52 -08:00
Trond Hindenes 660185b08c
Add support for prefetch (#562) 
* Add support for prefetch

* Fixed test implementation

* Gofmt-ed files

* Re-arranged struct

* Moar tests
 2020-12-21 10:42:16 -08:00
Joni Collinge 256f920918 fix lint 2020-11-30 16:47:01 +00:00
Joni Collinge 96a8a4d7ac Merge branch 'master' into jjcollinge/pubsub-context 2020-11-30 16:21:44 +00:00
Artur Souza 6266934d3f
Auto-reconnect rabbitmq pubsub (#519) 2020-11-09 12:27:53 -08:00
Joni Collinge 2e6b84ae40 Merge remote-tracking branch 'origin/master' into jjcollinge/pubsub-context 2020-11-02 09:05:16 +00:00
Yaron Schneider 182d204111
Add close method to pub/sub (#494) 
* add close method to pub/sub

* linter
 2020-10-12 19:06:33 -07:00
halspang f647d9eedb
Upgrade golang lint to 1.31 (#490) 
Upgrade golang lint to 1.31.0

https://github.com/dapr/components-contrib/issues/439
 2020-10-12 12:54:15 -07:00
Brightside Automation c344f68718 Merge branch 'master' into jjcollinge/pubsub-context 2020-08-19 14:46:03 +01:00
Yaron Schneider 677e551844
fix consumer exclusivity (#435) 2020-08-17 07:37:25 -07:00
jjcollinge 19442e67c8 update pubsub components to use new context 2020-07-28 10:03:23 +01:00
jjcollinge 410628af3d add context to pubsub handler signature 2020-07-07 12:37:15 +01:00
Mukundan Sundararajan 5c62707aba
Upgrade go version to 1.14.3 and linter version to 1.26.0 (#352) 
* Upgrade to go 1.14.3 and linter version to 1.26.0
 2020-05-29 15:26:33 -07:00
Young Bu Park ee97c3c56a
Use dapr logger (#238) 
* Use dapr logger

* skip linter false alarm
 2020-02-28 15:49:49 -08:00
Abhishek Gupta 9323c44ecf check etag for etcd update and delete ops (#175) 2020-01-09 12:33:23 -08:00
thinkerou a2f4b4c510 upgrade logrus to v1.4.2 (#150) 
* fix conflict

* upgrade logrus to v1.4.2

* fix lint error

error: `depguard  `github.com/sirupsen/logrus` is in the blacklist`
 2019-12-12 09:34:39 -08:00
Francisco Beltrao f89682397b Add Azure SignalR binding (#148) 
* Add Azure SignalR binding

* Fixes from go lint

* Go lint

* Use "github.com/dgrijalva/jwt-go" for jwt
Fix bug parsing connection string
Normalize usage of len vs == in strings

* Consistent usage of http header Set
 2019-12-03 09:08:53 -08:00
Abhishek Gupta c4bd2a47ea Implementation for Hazelcast based state store (#145) 
* hazelcast store impl

* go.mod update
 2019-11-27 21:12:47 -08:00
Francisco Beltrao 9e78671fc0 Add RabbitMQ pub/sub (#124) 
* Add RabbitMQ pub/sub

* Fix lint error (global variable)

* RabbitMQ pub/sub auto ack defaults to false
Fix log message incorrect prefix

* Remove extra line in go.mod

* Revert extra line in go.mod
 2019-11-27 10:37:09 -08:00