Commit Graph

3232 Commits

Author SHA1 Message Date
Joni Collinge e67ea01fbe
Added check to handle nil request body in nethttpadaptor (#218) 2020-02-10 12:36:52 -08:00
Yaron Schneider df6c3c3e32
add params for mongoDB (#216) 2020-02-10 11:04:37 -08:00
Joni Collinge 6c65fda88d
Add Rate Limiting Middleware (#193)
* add initial ratelimit middleware

* fixed linting issues

* updated rate limiting logic

* removed redundant const

* remove obsolete go.uber.org/ratelimit reference in go mod

* migrated from juju/ratelimit to tollbooth rate limit

* moved adaptor to a separate package and added tests

* added RemoteAddr

* moved handler wrapped outside hot path

* fix linter
2020-02-07 13:25:36 -08:00
Yaron Schneider d2a6fa5264
close azure service bus sender connection (#209) 2020-02-06 22:19:55 -08:00
Carlos Mendible 226bff98ff
Fixed issue preventing authentication fallback to MSI (#206)
* Fixed issue preventing auth fallback to MSI

* Changed variable name

* checking if keys are present
2020-02-04 14:02:17 -08:00
Young Bu Park 5a24823c89
Upgrade go to 1.13.7 and linter to 1.23.2 (#205)
* upgrade go

* Fix all linter errors
2020-02-03 14:29:29 -08:00
Young Bu Park 1fba8dd4b0
Initial commit of component development doc (#202)
* Add component development docs

* fix comments
2020-01-31 09:27:08 -08:00
REDDY PRASAD 5f3f850852
Add GCP Secret Manager (#199)
*  Add GCP Secret Manager

* Update tests

* Fix lint errors

* Update as per review

* Run go mod tidy

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-01-30 21:51:52 -08:00
Mark Russinovich 3833ca9eb7
Added Twilio binding (#203)
* Added Twilio binding

* Fixed linter bugs
2020-01-30 18:18:52 -08:00
Haishi2016 0cfa9ad99c
sort store names alphabetically (#201) 2020-01-30 17:00:57 -08:00
Yaron Schneider 4433e605f1
Add CloudState CRDT (#200)
* add CloudState CRDT

* fix linter

* add tests
2020-01-29 14:13:23 -08:00
Abhishek Gupta 6de230391d
Aerospike state store implementation (#196)
* aerospike state store impl

* fixed linter issues:

* addressed feedback

* Delete bearer_middleware.go

* Delete cassandra_test.go

* Revert "Delete cassandra_test.go"

This reverts commit 462c066814.

* Revert "Delete bearer_middleware.go"

This reverts commit ae114a1df1.

Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-01-28 18:55:14 -08:00
Ivan Gavryliuk 84c4e6bf8e Azure Table Storage state (#197)
* initial scaffolding

* tidy go.mod

* adding delete functionality and tests

* updating Readme.md

* ETag concurrency support and github review fixes

* removing unused isConflictError

* ping build, some issue with CI timing out

Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-01-28 09:20:18 -08:00
Joni Collinge ca2c3821a2 Add concurrency to Azure ServiceBus pubsub (#179)
* added worker pool for concurrent receive

* fixed missing end quote

* added type alias

* removed shadow decl

* added cleanup logic for subscription receiver

* renamed metadata property to numConcurrentHandlers and added handler specific timeout

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-01-24 10:26:11 -08:00
Abhishek Gupta 3734491718 NATS Streaming pubsub implementation (#173)
* NATS streaming pubsub impl

* after go mod tidy

* updates tests, other refactoring

* updated client ID generator

* updated test

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-01-17 14:54:01 -08:00
Marcin Kosieradzki 381777dc3b Implemented OIDC Bearer middleware (#188)
* Implemented OIDC Bearer middleware

* Fixed indentation
Added support for case-insensitive scheme
Moved scheme to constant

Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-01-16 13:26:30 -08:00
Carlos Mendible e5fbb7e825 [WIP] Adding support for Manage Identities in the Azure Key Vault Secret Store (#185)
* Adding support for Manage Identities

* Refactored & changed validation in GetClientCert()

* Updated Client Cert tests

* Fixed linting issue

* Using pointer for k and setting the kv name

* Added MSI Tests

* Decoupling auth utils from keyValueSecretStore

* auth utils decoupled from keyvaultSecretStore

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-01-15 13:27:07 -08:00
Joni Collinge bcfc66c79b fixed retry logic for servicebus listener (#186) 2020-01-14 12:51:13 -08:00
Shalabh Mohan Shrivastava e7639f90c9
Modify the AppResponse struct to have the store name (#183)
* Need to change the AppResponse struct to have the store name and state requests separately to support multiple state stores support in Dapr.

This is needed to support this requirement : dapr/dapr#636

* Putting the state in a separate struct

* Reverting the last commit - and keeping the things simple, just adding the storeName in the struct
2020-01-09 15:52:45 -08:00
Dr. David Kunz 49553859a0 Update redis_test.go (#165)
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-01-09 12:34:32 -08:00
Abhishek Gupta 9323c44ecf check etag for etcd update and delete ops (#175) 2020-01-09 12:33:23 -08:00
Francisco Beltrao 1a37f892aa Move SQLServer state store from azure folder (#181) 2020-01-07 23:38:44 -08:00
Artur Souza cab73a9b55
Merge pull request #177 from abhirockzz/dapr-issue123
Added port option to cassandra state store
2020-01-07 14:13:40 -08:00
Artur Souza 0ad870bebf
Merge branch 'master' into dapr-issue123 2020-01-07 14:05:59 -08:00
Francisco Beltrao db8b6135d6 Rename SQLServer state ctor to existing pattern (#176) 2020-01-07 06:17:13 -08:00
abhishek 7d841d55a9 added port option to cassandra state store 2020-01-07 18:05:26 +05:30
Francisco Beltrao 70381d8312 Add sql server state (#158)
* Add sql server state

* Fix lint

* Disable docker based tests

* Rename store to SQLServer
Use env variable DAPR_TEST_SQL_CONNSTRING to enable integratoion test

* Add support to Azure SQL on integration test

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-01-06 09:14:13 -08:00
Yaron Schneider 8b89a57b4e
fix redis streams waiting for handler (#172) 2020-01-05 10:54:15 -08:00
Marcin Kosieradzki 3db863cac6 Changed schema to be consistent with blobstorage (#166)
* Changed schema to be consistent with blobstorage

* Updated tests to match the updated schema
2019-12-27 10:35:28 -08:00
Yaron Schneider 94d9988642
fix close channel by queue redecleration (#162) 2019-12-23 16:17:00 -08:00
Haishi2016 98999a6044
fix regression switching to session which missed header injection (#157) 2019-12-19 10:22:52 -08:00
Haishi2016 701f12e529
oAuth2 HTTP middleware (#151)
* oAuth2 HTTP middleware

* fix go mod

* refactor to use sessions

* go mod tidy
2019-12-17 09:43:14 -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
stather 744880306f Azure storage queue binding implementation (#146)
* folders and files

* boilerplate added

* write queue done
parse metadata done

* refactor of init and write

* All done

* lint updates

* Additional lint fixes

* lint simplifications

* UPdated to make testable
Make read blocking

* working tests

* linting fix

* Added backoff so we dont eat CPU

* go mod tidy to fix error

* fixed test failures

* Fixed lint error
2019-12-03 21:31:46 -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
Prafulla Anurag 9ffc7dc2ce Cloudkms secretstore (#121)
* Initial Commit creating cloudkmsclient

* Changes to go.mod go.sum

* Minor changes

* Add basic metadata structure, decrypt function

* Add GetSecret Module

* Add module to fetch secret file from cloud storage

* Finish coding the secret store

* Delete changes to go.mod

* Remove changes from go.mod and go.sum

* Add init test for cloudkms

* fix golint failures

* Edited the documentation
2019-11-29 12:23:23 -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
Yaron Schneider e644714b17
Update Makefile (#144) 2019-11-27 10:18:28 -08:00
sayboras eabe18a79f Support AWS secret manager as secret store (#142)
* Initial commit

* Initial commit

* Update Readme.md

* Update godoc comment

* Added session token

* Incorporate review comment

* Added the header

* Corrected godoc
2019-11-26 07:36:11 -08:00
sayboras 08362d9e6b Added check for go.mod (#141)
* Added check for go.mod

* Rename the make target

* Grrrrr

* Update go.mod and go.sum

* Run gofmt and goimports

* Correct typo
2019-11-25 00:45:51 -08:00
Shalabh Mohan Shrivastava fac9d4a41b
Removing go vendoring (#139)
* Removing go vendoring

* Removing modules-download-mode: vendor, to fix the build error
2019-11-22 13:41:10 -08:00
Shalabh Mohan Shrivastava bcd23db009
Changes to include Package names pubsub/secret stores/state to be consistent with company name (#137)
* [Commit - PubSub changes ]

Changing the names of the packages directory so to be consistent with name of the company .

It is to be noted that package name can not have hyphen "-" in the name.
So changing the directory names and putting under company names.

For example - servicebus package would be

dapr/components-contrib/pubsub/azure/servicebus

* Commit 2 - Changes for Secret Stores

* Commit 3 - for the state store changes
2019-11-22 12:46:42 -08:00
Shalabh Mohan Shrivastava a63a0b23be
Merge pull request #128 from dapr/naming
Changes to include Bindings Package names to be consistent with company name
2019-11-22 11:31:20 -08:00
Yaron Schneider 62856f9e0c
Merge branch 'master' into naming 2019-11-22 11:15:50 -08:00
Shalabh Mohan Shrivastava a6e7b3031a
Merge pull request #136 from dapr/requests
Split the requests and responses for input/output bindings
2019-11-21 18:30:56 -08:00
Shalabh Mohan Shrivastava ad0e80bd3c Removing unused import 2019-11-21 18:23:43 -08:00
Shalabh Mohan Shrivastava b1ae76550b Split the requests and responses for input/output bindings 2019-11-21 18:19:17 -08:00
Leon Mai 48d385b82b Don't return nil for response when length of items is 0 (#133) 2019-11-20 15:21:21 -08:00
Shalabh Mohan Shrivastava a48c4bc55d
Merge pull request #131 from dapr/metadata
Adding metadata to State Delete and Get requests
2019-11-20 11:06:46 -08:00