Commit Graph

3297 Commits

Author SHA1 Message Date
Young Bu Park c69d5ea2ca
Add metadata property to TransactionalRequest (#430)
* Add Metadata to transactional request

* Use new transactional request strcut
2020-08-12 09:30:37 -07:00
Shalabh Mohan Shrivastava 42668a8ae1
State Store Components changes to adhere runtime changes for removing retry options (#426)
* State Store Components changes to adhere runtime changes for removing state retry options

* resolving code review comments - common method to CheckRequestOptions
2020-08-11 10:50:31 -07:00
Yaron Schneider 8f30f3a6e6
Update common operations list docs (#428) 2020-08-10 12:24:01 -07:00
Leon Mai 65575593c1
Sql component should save db object on Init instead of creating a new (#399)
one per operation.

Separately, if data arrives as []byte (as in grpc case) don't Marshal
it.

Co-authored-by: LM <lemai>
2020-07-29 15:26:07 -07:00
jjcollinge 38a8948bd8 Merge branch 'jjcollinge/pubsub-context' of github.com:jjcollinge/components-contrib into jjcollinge/pubsub-context 2020-07-28 10:04:26 +01:00
jjcollinge 19442e67c8 update pubsub components to use new context 2020-07-28 10:03:23 +01:00
Joni Collinge f868dc9497
Merge branch 'master' into jjcollinge/pubsub-context 2020-07-28 09:25:34 +01:00
Yaron Schneider 5892feca63
update Cloud Events to 1.0 (#419) 2020-07-23 17:13:26 -07:00
Sivamuthu Kumar 6085834d79
Add blob storage as state store (#348)
* Add blob storage as state store

* Updated comments for blob storage

Co-authored-by: Young Bu Park <youngp@microsoft.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-07-22 08:49:20 -07:00
Ally Parker cf3ee2a46a
Add topic to cloud events envelope (#396)
Co-authored-by: ibrahim.dursun <ibrahim.dursun@gmail.com>
2020-07-22 08:48:32 -07:00
Mark Chmarny b16d55f8ad
renames the cron package (#395) 2020-07-16 18:18:34 -07:00
Leon Mai b1c8dd5e31
Merge pull request #392 from dapr/cosmos4
#377 - cosmos deserialization issue
2020-07-14 14:55:45 -07:00
LMWF 1983d86849 merge 2020-07-14 13:59:29 -07:00
Leon Mai 85aca5ac44
Merge branch 'master' into cosmos4 2020-07-14 13:45:03 -07:00
LMWF 15be14b9b3 cleaned up 2020-07-14 13:17:38 -07:00
LMWF 17d3d0b848 #377 - cosmos deserialization issue 2020-07-13 20:07:36 -07:00
Mark Chmarny 05e71ffdc2
data serialized object (#391)
Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-07-13 13:31:32 -07:00
Mark Chmarny 680cdb7124
Merge pull request #389 from dapr/mchmarny-envelop-tests
Fizes JSON array envelope parsing, adds unit tests
2020-07-13 10:47:48 -07:00
Mark Chmarny dbc1a76dcf lint fix 2020-07-13 09:24:51 -07:00
Mark Chmarny 1589031af6 fiixes json array envelope parsing 2020-07-13 09:20:54 -07:00
Mark Chmarny 8f96d7fe82
Merge pull request #384 from dapr/mchmarny-fixes-double-envelope
Fixe for double envelope when published payload is already a cloud event
2020-07-10 11:29:02 -07:00
Mark Chmarny e238e9a08c
Merge branch 'master' into mchmarny-fixes-double-envelope 2020-07-10 11:18:45 -07:00
Mark Chmarny 47a329c3ce
Adds output support to Twitter binding #366 (#385)
* twitter output binding

* output metadata format to match input

* fixes lint error

* fixed init query validation

* fixes test timeouts

* fixes lint errors

* fixes lint errors

Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-07-09 17:01:30 -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 68c5a5537c changes cloudevent identification 2020-07-08 15:28:54 -07:00
Mark Chmarny d1966c63ca Merge branch 'mchmarny-fixes-double-envelope' of github.com:dapr/components-contrib into mchmarny-fixes-double-envelope 2020-07-08 11:23:33 -07:00
Mark Chmarny f1f69bf3c8 fixes speeling mistakes in ccmments 2020-07-08 11:23:23 -07:00
Mark Chmarny 44776d4463
Merge branch 'master' into mchmarny-fixes-double-envelope 2020-07-08 06:52:25 -07:00
Mark Chmarny 43092998ab uses provided CE as is, adds CE test 2020-07-08 06:50:10 -07:00
Joni Collinge 03b3dbfe88
Merge branch 'master' into jjcollinge/pubsub-context 2020-07-08 14:00:01 +01:00
Mark Chmarny 6b04b4c9fe
Merge pull request #386 from dapr/mchmarny-adds-cron-binding
Add scheduler binding #226
2020-07-08 05:57:44 -07:00
Mark Chmarny 111836eac8 adds Operations method implementation 2020-07-08 05:46:08 -07:00
Mark Chmarny 8b169a7d65 fixes lint errors, adds invoke test 2020-07-08 05:09:10 -07:00
Mark Chmarny d662a1829f fixes lint errors, adds invoke test 2020-07-08 04:58:09 -07:00
Mark Chmarny e98b3fc968 adds cron binding 2020-07-07 16:58:53 -07:00
Mark Chmarny 194ff4f914 fixes double envelop 2020-07-07 16:47:47 -07:00
jjcollinge 07b046f140 rename asb handler type to handle 2020-07-07 13:01:24 +01:00
jjcollinge 7734d05288 Merge branch 'master' into jjcollinge/pubsub-context 2020-07-07 12:41:58 +01:00
jjcollinge 410628af3d add context to pubsub handler signature 2020-07-07 12:37:15 +01: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
Leon Mai a086a42f2b
Implement the Multi() interface method adding transaction support in … (#372)
* Implement the Multi() interface method adding transaction support in the cosmos db component.  The implementation
uses a stored procedure to do this.  The stored procedure is registered in Init().

* linter

* code review comments

* code review

* remove comment

* casing and de-dup

* use 'in' in query

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-06-30 13:32:41 -07:00
Nils Schmidt 4007ba3622
Handle errors in AzureEventHubs.Read (#371) 2020-06-30 07:16:36 -07:00
Kyle Housley 9ef4fb5fb4
Make enableTLS work correctly (#373)
the enabletls does the opposite of what the config suggests
2020-06-29 14:39:55 -07:00
Shalabh Mohan Shrivastava 007dbd03b0
Fix for context deadline exceeded issue - use operation timeout (#370) 2020-06-25 15:11:56 -07:00
Shalabh Mohan Shrivastava 7b0fbe65cc
Setting URL correctly when username/password is not provided (#369)
* Adding Username/password optional

* fixing lint errors
2020-06-25 13:29:52 -07:00
Young Bu Park a6a0e3e3bc
rename servicediscovery to nameresolution pkg and refactor it (#368)
* rename servicediscovery to nameresolution pkg

* fix linter

* add comment

* add more logs
2020-06-24 11:23:15 -07:00
Carlos Mendible 3221db9709
Fixing #360 (#361)
Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-06-16 15:32:26 -07:00
Young Bu Park f46249c554
revert defer cancel back (#363)
* revert defer cancel back

* cancel timeout explc
2020-06-16 10:50:24 -07:00
Young Bu Park 98dba0e1cb
Cancel context when service is found (#362) 2020-06-16 10:31:29 -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