Commit Graph

425 Commits

Author SHA1 Message Date
Ian Luo 97912e75c6
mysql outbinding support (#615)
* mysql outbinding support

* fix lint issues

* use time duration string instead of number of seconds

* correct typo

* use 'addr' instead of 'server' and 'port' in order to align with url in dsn format

* simplify configuration, and allow PEM configurable

* jsonfy the query result

* add more unit test for mysql binding

* add unit test to verify timestamp

* add type verify in integration test

* add test to verify BOOLEAN

* update comment

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-01-25 18:45:26 -08:00
Nghia Tran 3086450ced
Add CosmosDB state store conformance tests (#622)
* Add CosmosDB conformance tests

* Fix workflow & lint

* Add more disclaimers to README.md
2021-01-20 14:38:09 -08:00
Mukundan Sundararajan 465d09e54d
Add initial set of conformance tests (#586)
* Add initial set of conformance tests

* remove go mod changes

* set and unset env var for test
2021-01-20 12:09:51 -08:00
Yaron Schneider a03a96c282
update kubernetes packages to 1.20 (#557) 2020-12-16 10:43:27 -08:00
Nghia Tran a4884f1d4b
Remove exporters component code (#553) 2020-12-10 13:38:26 -08:00
Michaël Hompus 6079c3b113
Add postmark as an output binding (#546)
* Add postmark as an output binding

* go tidy

* Update comments
2020-12-09 14:28:32 -08:00
Joni Collinge 31828b3779
Update ASB message finalization (#534)
* remove servicebus context hack

* add more verbose error message

* make error message lowercase

* update go-autorest

* update azure-sdk-for-go

* remove go mod replace go-autorest

* fix lint issues

* go mod tidy

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-12-04 22:13:00 -08:00
Yaron Schneider 763c856a44
update dependency for ocagent (#517) 2020-11-03 16:41:37 -08:00
Sky/敖小剑 ed7480237d
Upgrade grpc version to v1.32.0 (#501)
* remove etcd state store to prepare to update grpc to new version

* upgrade grpc version to v1.32.0

* upgrade grpc version to v1.32.0
2020-10-15 17:49:33 -07:00
Sky/敖小剑 4e77594a4d
remove etcd state store to prepare to update grpc to new version (#499)
* remove etcd state store to prepare to update grpc to new version

* update go.mod

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-10-15 09:53:49 -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
Mark Chmarny fbc3a3dd87
RethinkDB state store support (#423)
* rethinkdb state store

* added actor state change binding

* updated db record

* reconnect

* passing lint

* updated binding repsonse keys

* rethinkdb load test

* lint validated tests

* updated comments

* updates TransactionalStateRequest

* parameterized table

* correct error message

Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-09-24 16:19:14 -07:00
Mark Chmarny d2dcd8e508
Bi-directional output binding for PostgreSQL (#468)
* wip: postgres

* postgres crud binding

* CRUD postgres bidirectional output binding

* live test setup comments

* updated example conn string

* lint fixes

* test sql linting

* pr review updates

* lint fixes

* comment spelling

* metadata optional for close
2020-09-23 17:19:37 -07:00
Artur Souza 5b88ef7ec9
Update github.com/a8m/documentdb to latest commit to fix consistency … (#475)
* Update github.com/a8m/documentdb to latest commit to fix consistency level options.

* go mod tidy
2020-09-23 16:55:32 -07:00
Nghia Tran e51cff7fec
Use concurrency control in Multi() (#466)
Change Multi() to use same setQuery and delQuery mechanisms as Set() and Delete().
2020-09-22 15:13:39 -07:00
Richard Simpson 775bbebc6a
feat(middleware): add opa middleware (#456)
* feat(middleware): add opa middleware

* address linting feedback

* unwind logic a little more

* are we gonna need to throw hands lint?

* remove accidental assertion lib include

* address pr feedback

* expand test suite to headers

* fix errors and moar test

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-09-12 12:29:42 -07:00
AbserAri 26b085baba
update logger form nats-io's to dapr's (#449)
* update logger form nats-io's to dapr's

* run go mod tidy and go mod delete the nats-io gnatsd

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-09-03 18:58:34 -07:00
Mukundan Sundararajan c6623da87e
Change Kubernetes client to official go-client in the events binding. (#436)
* Change Kubernetes client to official go-client in the events binding.

* Change adding flags to init

* go mod tidy

* Proper call for handler

* Remove commented out code

* Refactor indentation
2020-08-18 11:49:06 -07:00
Geert Baeke 467375c254
Influx binding (#401)
* influx binding

* corrected linting errors

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-08-17 12:45:58 -07:00
Florian Wagner e60fa843f2
Adding middleware component for non interactive oauth2 client credentials flow (#431)
* Initial commit with mock not working

Signed-off-by: Florian Wagner <flwagner@microsoft.com>

* changed structure for mocking, added first test

Signed-off-by: Florian Wagner <flwagner@microsoft.com>

* oauth2clientcredentials input checks and tests

Signed-off-by: Florian Wagner <flwagner@microsoft.com>

* rename metadata authHeaderName to HeaderName

Signed-off-by: Florian Wagner <flwagner@microsoft.com>

* Run 'go mod tidy'

Signed-off-by: Florian Wagner <flwagner@microsoft.com>

* use dapr logger from caller

Signed-off-by: Florian Wagner <flwagner@microsoft.com>

* Fix additional lint requirements by build pipeline

Signed-off-by: Florian Wagner <flwagner@microsoft.com>

Co-authored-by: Florian Wagner <flwagner@microsoft.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-08-16 11:05:24 -07:00
Brooke Hamilton a0a293ca1b
[WIP] PostgreSQL State Store (#353)
* Added postgres state files

* Fix SQL Server integration tests. (#324)

* Initial unit and int tests for postgres

* Implemented dbaccess interface

* Formatting updates

* Create state table if not exists

* Initial set implementation

* Get and set with integration test

* Added delete

* Create date and update date in database

* Integration tests for bulk set and bulk delete

* Etag processing, test refactor

* Added tests for etag processing

* Updated const, removed public metadata fields

* Cleanup edits

* Fixed linting issues

* Ran go mod tidy

* Initial implementation of TransactionalStore

* Fixed linting issues

* Added tests and validation

* Test for creating the state table

* Fixed issue with parsing param value as string

* Update to integration tests

* Fixed linting issues

* Added retry logic from state

* Changed primary key to text

* Updated debug logging

* Review updates

Co-authored-by: Young Bu Park <youngp@microsoft.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-07-09 13:56:08 -07:00
Mark Chmarny e98b3fc968 adds cron binding 2020-07-07 16:58:53 -07:00
Joni Collinge 4b2252b017
ASB lock renewal per topic (#365)
* bump asb sdk version to 0.10.2

* add isolation per topic for lock renewal

* added cancellations on async handlers

* refactored out subscription logic from namespace

* updated error handling

* defer async context cancel

* fixed lint issues

* add connection recovery

* fix lint

* update comments

* update comments

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-07-02 08:02:42 -07: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
John b54585c4f0
Apache Pulsar - pubsub component (#346)
* created pulsar component

* fixed multi topic issue

* moved metadata struct

* finished writing metadata tests

* fixed linter issues

* modifies consumer type to failover

* uncapitalized errors

* changed subscriptionName to consumerID

* acknowledge message only if there's no error returned from handler

Co-authored-by: john verdonck <John@johns-MacBook-Pro.local>
2020-05-22 10:04:07 -07:00
Mark Chmarny 0e731f96aa
Added Twitter search input binding (#318)
* titter search binding

* refactored signal processing for lint comp

* titter search binding

* refactored signal processing for lint comp

* fixed twitter ref

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-04-29 08:02:57 -07:00
Lynn Orrell 8480a29c18
EventGrid Component Updates (#319)
* event grid udpates

* Initial event grid input binding

* Added Write() support to EventGrid component

* Updated eventgrid binding to use fasthttp instead of net/http

* Fixed linting issue in EventGrid binding

* Tidy up go.mod

* Added handshakePort to allow custom port for EG callback

* Now properly throwing an http 500 on handler err

* Updated event grid sdk for cloud event 1.0 support
Added support for all event grid sources via scope
Now validating required metadata on read/write

* Updated tests

* Fixed linting issue

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Young Bu Park <youngp@microsoft.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2020-04-29 08:02:22 -07:00
Ben Coleman ebf31ef7c5
Added SendGrid output binding for sending emails (#308)
* Added first cut of SendGrid binding

* Removed some junk

* tidy up based on PR review comments
Removed duped line, and logging, normalised error messages

* Silly mistakes on emailTo and subject checks

* Moving to new twilio folder structure

* adds BCC and CC, better error handling

* microscopic comment typo

* linter was complaining

* removing my accidental docs commit

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-04-22 21:54:01 -07:00
Pruthvidhar R Dhodda a36e498d02
Add TLS support for bindings.redis (#302)
* Add TLS support for bindings.redis

* Remove unsused dependencies

* Fix failing tests

* Remove unused variables
2020-04-09 12:02:24 -07:00
Sivamuthu Kumar b14500315a
Add Kinesis data stream binding (#273)
* Add Kinesis data stream binding

* fix lint kinesis

* Add license at top of the file

Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-03-24 11:33:23 -07:00
madhugilla dc1e938e61
Alicloudoss (#278)
* Object storage implementation for AliCloud

* linting fixes

* fixed comments and ran "go mod tidy" based on the feedback

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-03-20 12:34:38 -07:00
Abhishek Gupta 807e8893cb
Azure Event Hubs pubsub component (#242)
* event hubs pubsub

* go mod tidy

* go mod

Co-authored-by: yaron2 <yaronsc@microsoft.com>
Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-03-09 22:02:04 -07:00
Yaron Schneider 4602757a45
extend envelop to include a subject field (#249)
* extend envelop to include a subject field

* fix envelop test

* update mod

* try fix mod again
2020-03-04 22:59:26 -08:00
Young Bu Park ee97c3c56a
Use dapr logger (#238)
* Use dapr logger

* skip linter false alarm
2020-02-28 15:49:49 -08:00
Yaron Schneider c5ee4b273f
Add zero block for redis streams (#222)
* add zero block for redis streams

* update go.mod
2020-02-12 08:45:05 -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
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
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
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
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
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
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
Abhishek Gupta 356981000e Couchbase state store implementation (#100)
* first cut for couchbase store

* set and delete account for etag

* updated implementation

* fixed go mod
2019-11-18 23:13:41 -08:00
Leon Mai e7e02ee056 Servicediscovery (#118)
* service discovery component

* Update vendor files

* Remove dep on dapr

* lint

* Code review comments

* lint

* code review comments

* use const

* refactor

* code review
2019-11-14 13:14:57 -08:00
sayboras 32f5f81b9b Fixed dependency issue (#104) 2019-11-11 12:34:56 -08:00
Yoichi Kawasaki bd36a6759f Added state store: Cloud Firestore (#110)
* Added State Store: Cloud Firestore

* changed state store name
2019-11-08 14:43:43 -08:00
Joni Collinge ed3c829578 Azure ServiceBus PubSub Implementation (#93)
* initial skeleton code

* updated sub message handler

* lowercased errors

* added deadletter

* added context

* remove nil args

* added TODOs

* add max delivery count and timeout config

* refactored ensure methods

* removed confusing comment

* apply go fmt

* removed consumerID default

* updated go mod

* fixed up linter issues

* add package alias

* removed TODOs

* added additional servicebus config

* fix linting
2019-11-05 14:50:48 -08:00
Anubhav Mishra 4bbfb82e98 initial secretstore implementation of HashiCorp Vault (#84)
* initial secretstore implementation of HashiCorp vault

* updates after review

* fixing golangci-lint errors

* fixing temporary directory creation issues
2019-11-01 20:29:06 -07:00
Flier Lu 342e0d6223 [WIP] Add zookeeper state store (#80)
* [WIP] Add zookeeper state store

* go mod vendor

* fix lint warnings

* change state.StateStore to state.Store
2019-10-31 21:04:34 -07:00
Shalabh Mohan Shrivastava 3ae5547e41 Adding MongoDB State Store Implementation (#53)
* Adding MongoDB State Store Implementation

Adding MongoDB State Store Implementation

* Fix bugs and add unit tests

* Adding write/read concerns

* go sum changes

* adding defer cancellation

* fixing the bug for default case override

* Resolving code review comment

* Adding go mod vendor files

* Fixing lint errors
2019-10-31 12:03:04 -07:00
Abhilash Singh 0cae368496 [WIP] Add memcached state store (#71)
* Add memcached state store init

* Add parsing of optional parameters

* Add tests

* Update vendor

* Add memcached to supported state store list
2019-10-31 06:21:04 -07:00
Abhishek Gupta 49b6c9625c NATS pubsub component implementation (#65)
* inital version for  nats pubsub implementation

* added draft impl for nats pubsub

* updated impl, test

* new dependencies

* updated go.mod
2019-10-29 23:48:55 -07:00
sayboras 8adf323961 Add github action for CI (#59)
* Initial commit

* Fixed all linting error

* Used prepared query instead of string format

* Enabled linter for test
Enabled below linters
    - gochecknoglobals
    - gochecknoinits

* Enabled below linters
    - godox
    - interfacer
    - maligned

* Revert name change for StateStore in pkg state

* Incorporate review comments

* Cleanup the github ci

* Correct typo

* Add golangci-lint version in github ci step

* Update Readme.md
2019-10-28 15:39:48 -07:00
Anubhav Mishra cc7578c02b state: initial version for the consul state store implementation (#52)
* state: initial version for the consul state store implementation

* updates after review

* changes after running go mod vendor

* more clean up after review
2019-10-25 21:34:16 -07:00
Haishi2016 f157dab522 Support OpenCensus native exporter (#57)
* Support OpenCensus native exporter

* fix typo
2019-10-25 16:15:43 -07:00
Yaron Schneider f2b0cede8a
Add cassandra state store (#48)
* add cassandra state store

* refactor return statements
2019-10-23 12:47:28 -07:00
Haishi2016 5fccecbe44 update metadata properties from map of interfaces to map of strings (#47) 2019-10-23 12:03:58 -07:00
Yaron Schneider 0b93c5e585
Merge branch 'master' into exporters 2019-10-22 21:40:33 -07:00
Haishi Bai 4c3abdbf7f make exporters components 2019-10-22 18:51:01 -07:00
Roberto Rojas 63af15926b ETCD Implementation of State Store (#42)
* etcd: initial commit

* etcd: functionality and unit tests

* etcd: fixes marshaling data sent to etcd

* changes as per PR review
2019-10-22 14:30:15 -07:00
Yaron Schneider 887cd92b8d
vendor update (#34) 2019-10-14 23:49:50 -07:00
Yaron Schneider 2b8dbd2b44
dapr name change (#21) 2019-10-02 13:21:22 -07:00
Brendan Burns a1ab528d56 Add a Kubernetes input binding. (#15) 2019-09-30 22:01:43 -07:00
Yaron Schneider ad1d4aaec2
Add GCP Pub/Sub input and output binding (#18)
* add gcp pub-sub input/output binding

* update bindings list

* Update pubsub_test.go
2019-09-30 08:46:20 -07:00
Yaron Schneider a50e3de151
Add Azure Service Bus Queues binding (#13)
* add azure service bus queues bindings

* update table
2019-09-27 16:10:00 -07:00
Yaron Schneider 071f9ec31b
add azure blob storage binding (#4) 2019-09-27 07:45:26 -07:00
yaron2 22fea6f43d initial commit 2019-09-26 15:47:41 -07:00