Commit Graph

3297 Commits

Author SHA1 Message Date
Artur Souza 339624b7a3
Update daprd in cert tests. (#1511)
Signed-off-by: Artur Souza <artursouza.ms@outlook.com>
2022-02-18 14:42:19 -08:00
Shubham Sharma 945f8a0746 Upgrade jsonx
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
2022-02-18 15:07:31 +05:30
Gehhilfe 80c2bbe284
Jetstream KV state store component (#1501)
* Add support for nats jetstream kv state store

Add tests for jetstream state store

Update go mod

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

* Fix lint errors

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

* Mod tidy

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

* Mod tidy all

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

* Mod tidy all

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

Co-authored-by: Looong Dai <long.dai@intel.com>
2022-02-17 10:19:03 -08:00
Laurence 41a5a08894
Fix: unsubscribe by id (#1483)
* Fix: unsubscribe by id

Signed-off-by: LaurenceLiZhixin <382673304@qq.com>

* fix: linter

Signed-off-by: LaurenceLiZhixin <382673304@qq.com>

* fix: UnSubscribe to Unsubscribe

Signed-off-by: LaurenceLiZhixin <382673304@qq.com>

* fix: mod tidy all

Signed-off-by: LaurenceLiZhixin <382673304@qq.com>

* Fix: change uuid repo

Signed-off-by: LaurenceLiZhixin <382673304@qq.com>

* Fix: mod tidy

Signed-off-by: LaurenceLiZhixin <382673304@qq.com>

Co-authored-by: Looong Dai <long.dai@intel.com>
2022-02-17 06:41:36 -08:00
Looong Dai 14419b421a
Merge pull request #1419 from 1046102779/feature/pulsar0107
feature/pulsar: add producer option disableBatching
2022-02-17 09:33:38 +08:00
1046102779 a03d7a6831 feature/pulsar: add producer option disableBatching
Signed-off-by: 1046102779 <seachen@tencent.com>
2022-02-16 19:03:43 +08:00
1046102779 0ebabf6397 feature/pulsar: add producer option disableBatching
Signed-off-by: 1046102779 <seachen@tencent.com>
2022-02-16 12:35:35 +08:00
1046102779 0b56101b94 feature/pulsar: add producer option disableBatching
Signed-off-by: 1046102779 <seachen@tencent.com>
2022-02-16 12:29:08 +08:00
1046102779 833a2845b0 feature/pulsar: add producer option disableBatching
Signed-off-by: 1046102779 <seachen@tencent.com>
2022-02-16 12:20:54 +08:00
1046102779 b6fb587525 feature/pulsar: add producer option disableBatching
Signed-off-by: 1046102779 <seachen@tencent.com>
2022-02-16 12:17:40 +08:00
1046102779 68ce7ddc95 Merge branch 'feature/pulsar0107' of https://github.com/1046102779/components-contrib into feature/pulsar0107 2022-02-16 12:07:39 +08:00
1046102779 2126b96dc6 feature/pulsar: add producer option disableBatching
Signed-off-by: 1046102779 <seachen@tencent.com>
2022-02-16 12:07:02 +08:00
Looong Dai 6e4139c7b1
Merge pull request #1498 from pkedy/postgres_state_store_set_with_etag_1497
Postgres state store: Fix `Set` with ETag
2022-02-16 10:00:31 +08:00
Phil Kedy 86592557ed
Merge branch 'master' into postgres_state_store_set_with_etag_1497 2022-02-15 12:46:44 -05:00
Gehhilfe 6ecc3b6f7b
Add support for nats jetstream wildcard subscriptions (#1465)
* Add support for nats jetstream wildcard subscriptions

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

* Add support for nats jetstream wildcard subscriptions

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

Co-authored-by: Looong Dai <long.dai@intel.com>
2022-02-15 09:46:33 -08:00
Looong Dai 0b1ba25e7f
Merge branch 'master' into postgres_state_store_set_with_etag_1497 2022-02-14 09:38:05 +08:00
Bernd Verst 96e730c0b1
Merge branch 'master' into gcp_pubsub_reconnect_loop 2022-02-11 16:38:32 -08:00
Dmitry Shmulevich 7fdebda09b
state store query API: remove preceding '.' in key names (#1500)
Signed-off-by: Dmitry Shmulevich <dmitry.shmulevich@gmail.com>
2022-02-11 15:00:43 -08:00
Phil Kedy 1c4ae2ad2a Updating go.sums of certification tests
Signed-off-by: Phil Kedy <phil.kedy@gmail.com>
2022-02-11 16:05:19 -05:00
Phil Kedy 4f3a18bb30 Updating go.sums of certification tests
Signed-off-by: Phil Kedy <phil.kedy@gmail.com>
2022-02-11 16:00:25 -05:00
Phil Kedy d5b2ce5377 Bump version of github.com/jackc/pgx/v4 to v4.15.0.
Signed-off-by: Phil Kedy <phil.kedy@gmail.com>
2022-02-11 15:53:31 -05:00
Phil Kedy e4ad31d36c Postgres state: Convert etag to uint32 instead of int to fix conversion error
Signed-off-by: Phil Kedy <phil.kedy@gmail.com>
2022-02-11 08:49:21 -05:00
Dmitry Shmulevich 1cb659c0b8
update conformance tests (#1492)
Signed-off-by: Dmitry Shmulevich <dmitry.shmulevich@gmail.com>
2022-02-09 17:58:48 -08:00
Dmitry Shmulevich eaecd4cb34
statestore query API: remove 'value' prefix from key names in query JSON object (#1491)
Signed-off-by: Dmitry Shmulevich <dmitry.shmulevich@gmail.com>
2022-02-09 17:17:47 -08:00
Daniel.Chung 4302917ee5
bingding/mysql: add select JSON_EXTRACT LONGTEXT column type to special case (#1486)
Signed-off-by: zdianjiang <zdianjiang@gmail.com>

Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-02-08 15:46:48 -08:00
Lucas Jellema 625f955fee
Introducing Oracle Database backed state store component (#1454)
* Introducing Oracle Database backed state store component

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* Implement Ping method with proper database ping

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* adding results from make modtidy-all - updated go.sum files
Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* etag only applied when first write policy requested - applied in integration test and component

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

Co-authored-by: Looong Dai <long.dai@intel.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
2022-02-08 12:00:34 -08:00
Lucas Jellema a383697ef5
Add config file authentication to oci object storage state store (#1430)
* Improving testing - verify expected methods are invoked

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* Adding support for composite keys (mapped to directories in buckets)

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* Adding support for TTL - expired elements are not returned in Get

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* fixing linting issues

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* fixing linting issue

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* adding support for TTL == -1 (never expire)

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* fix linting issue

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* introducing Instance Principal authentication for OCI client

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* fix linting issue

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* adding support for oci config file based authentication for OCI bjectStorage state store

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* expand ~ to user home directory in config file path; fix linting findings

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* gofumpt file because of linting issue

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* Do not allow config file path to start with ~/

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* introducing integration test for oci objectstorage state store

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* Fixing linting issues in integration test

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

* Fixing linting issues in integration test

Signed-off-by: lucasjellema <lucasjellema@gmail.com>

Co-authored-by: Looong Dai <long.dai@intel.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
2022-02-06 19:27:31 -08:00
Looong Dai c4a64ef471
Merge branch 'master' into gcp_pubsub_reconnect_loop 2022-02-07 10:23:22 +08:00
Taction 4885a835fc
Support version and engine path in vault secret store, add vaultValueType option. (#842)
* fix the value of a secret can be a json string format

Signed-off-by: Taction <zchao9100@gmail.com>

* fix lint

Signed-off-by: Taction <zchao9100@gmail.com>

* fix lint

Signed-off-by: Taction <zchao9100@gmail.com>

* Define engine name from metadata. and the default engine name is secret.

Signed-off-by: Taction <zchao9100@gmail.com>

* define engine path as component metadata param

Signed-off-by: Taction <zchao9100@gmail.com>

* fix get metadata with engine path

Signed-off-by: Taction <zchao9100@gmail.com>

* support version

Signed-off-by: Taction <zchao9100@gmail.com>

* add test for engine path config

Signed-off-by: Taction <zchao9100@gmail.com>

* If SkipVerify is true do not parse cert info.

Signed-off-by: Taction <zchao9100@gmail.com>

* fix lint

Signed-off-by: Taction <zchao9100@gmail.com>

* fix lint

Signed-off-by: Taction <zchao9100@gmail.com>

* fix test

Signed-off-by: Taction <zchao9100@gmail.com>

* Add parseAsMap option

Signed-off-by: Taction <zchao9100@gmail.com>

* Fix BulkGetSecret to get all secrets.

Signed-off-by: Taction <zchao9100@gmail.com>

* fix lint

Signed-off-by: Taction <zchao9100@gmail.com>

* refactor parseAsMap to vaultValueType, which accept values map and text

Signed-off-by: Taction <zchao9100@gmail.com>

* update test to satisfy Windows

Signed-off-by: Taction <zchao9100@gmail.com>

* Use version in Bulk Get API

when secret not have specified version just skip instead of returning error.
modify the way of formatting vaultSecretsPathAddr to satisfy vault list api

Signed-off-by: Taction <zchao9100@gmail.com>

* fix lint

Signed-off-by: Taction <zchao9100@gmail.com>

* fix lint

Signed-off-by: Taction <zchao9100@gmail.com>

Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2022-02-03 15:37:27 -08:00
Ricardo Corrêa 8297fc929b
Query StateStore API implementation for PostgreSQL StateStore (#1457)
* query state integration with dbaccess (postgresql)

Signed-off-by: Ricardo Corrêa <r.c.correa@outlook.com>

* query state integration with postgresql component

Signed-off-by: Ricardo Corrêa <r.c.correa@outlook.com>

* query state for postgresql

Signed-off-by: Ricardo Corrêa <r.c.correa@outlook.com>

* fix: linter error 'rowserrcheck'

Signed-off-by: Ricardo Corrêa <r.c.correa@outlook.com>

* query state integration with dbaccess (postgresql)

Signed-off-by: Ricardo Corrêa <r.c.correa@outlook.com>

* query state integration with postgresql component

Signed-off-by: Ricardo Corrêa <r.c.correa@outlook.com>

* fix: linter error 'rowserrcheck'

Signed-off-by: Ricardo Corrêa <r.c.correa@outlook.com>

* fix: linter error 'goimports -ed with -local github.com/dapr/'

Signed-off-by: Ricardo Corrêa <r.c.correa@outlook.com>

* performance improvementt in PosgreSQL Query API

Signed-off-by: Ricardo Corrêa <r.c.correa@outlook.com>

* added conformance test for PostgreSQL Query API

Signed-off-by: Ricardo Corrêa <r.c.correa@outlook.com>

Co-authored-by: Looong Dai <long.dai@intel.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
2022-02-02 18:14:18 -08:00
Taction 7c7c977d52
Fix rabbitmq pubsub reconnect (#1471)
Signed-off-by: zhangchao <zchao9100@gmail.com>
2022-02-02 11:56:48 -08:00
light-pan ea55aea8c3
Support configuring broker version in Kafka bindings component (#1459)
* Update kafka.go

Support configuring broker version in Kafka bindings component

Signed-off-by: panxiangyue <panxiangyue@corp-ci.com>
Signed-off-by: light-pan <373465009@qq.com>

* Update kafka_test.go

kafka binding add version test

Signed-off-by: panxiangyue <panxiangyue@corp-ci.com>
Signed-off-by: light-pan <373465009@qq.com>

* Update kafka.go

gofumpt check

Co-Authored-By: light-pan <21969903+light-pan@users.noreply.github.com>
Signed-off-by: light-pan <373465009@qq.com>

Co-authored-by: light-pan <21969903+light-pan@users.noreply.github.com>
Co-authored-by: Taction <zchao9100@gmail.com>
2022-01-31 09:08:34 -08:00
Daniel.Chung 8fe02469ba
bingding/mysql: add TEXT column type to special case (#1466)
Signed-off-by: zdianjiang <zdianjiang@gmail.com>

Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-01-28 11:29:30 -08:00
Jigar 9078f11985
Added ContentType to pubsub/binding/state request-response (#1376)
Signed-off-by: jigargandhi <jigarr.gandhi@gmail.com>

Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Looong Dai <long.dai@intel.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2022-01-28 10:17:04 -08:00
yellow chicks e04fd24a07
feature/pulsar: provide token && http request (#1427)
* feature/pulsar: provide token && http request

Signed-off-by: 1046102779 <seachen@tencent.com>

* feature/pulsar: provide token && http request

Signed-off-by: 1046102779 <seachen@tencent.com>

Co-authored-by: Looong Dai <long.dai@intel.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
2022-01-25 21:23:56 -08:00
Gehhilfe b835eb4e1e
pubsub jetstream: add nkey based authentication (#1441)
* pubsub jetstream: add nkey based authentication

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

* fix godot: comment should end in a period

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

* go mod tidy

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

* fix: go mod tidy

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

* pubsub jetstream: add e2e test

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

* Cleanup not needed files and move jwt

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

Co-authored-by: Looong Dai <long.dai@intel.com>
2022-01-25 21:11:50 -08:00
Dmitry Shmulevich 177d898a84 Update devcontainer to dapr-dev:0.1.6 (#1461)
Signed-off-by: Dmitry Shmulevich <dmitry.shmulevich@gmail.com>
2022-01-25 13:58:30 -08:00
Dmitry Shmulevich 0634d49987 pin certification tests to Daprd v1.6.0-rc.3 (#1451)
Signed-off-by: Dmitry Shmulevich <dmitry.shmulevich@gmail.com>
2022-01-25 13:58:12 -08:00
Laurence 2bf7f68e0c
Fix: add configuration unsubscribe api (#1440)
Signed-off-by: LaurenceLiZhixin <382673304@qq.com>

Co-authored-by: Looong Dai <long.dai@intel.com>
2022-01-20 22:18:57 -08:00
Amit Mor e69870e562 bugfixes: visibility timeout, dlq queue attributes (#1446)
Signed-off-by: Amit Mor <amit.mor@hotmail.com>
2022-01-18 10:40:10 -08:00
Amit Mor db9e071449
bugfixes: visibility timeout, dlq queue attributes (#1446)
Signed-off-by: Amit Mor <amit.mor@hotmail.com>
2022-01-18 10:31:53 -08:00
Yordan Pavlov 022c67a57b add reconnect loop for GCP pub/sub subscriptions
Signed-off-by: Yordan Pavlov <yordan.pavlov@dunnhumby.com>
2022-01-17 17:45:00 +00:00
Dmitry Shmulevich 160645023e
Pin certification tests to Daprd v1.6.0-rc.2 (#1443)
Signed-off-by: Dmitry Shmulevich <dmitry.shmulevich@gmail.com>
2022-01-14 16:50:26 -08:00
Bernd Verst c95b6919f9
temporarily disabled akv managed identity test (#1438)
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-01-13 18:22:53 -08:00
Bernd Verst 0f2398670a
Certification tests for Azure Blob Storage Binding (#1435)
* initial blobstorage output binding certification

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* More blobstorage tests

Signed-off-by: GitHub <noreply@github.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Rename some remnants from copy paste

Signed-off-by: GitHub <noreply@github.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Blobstorage Binding - test file upload

Signed-off-by: GitHub <noreply@github.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Blobstorage Output Binding Remove Pascal case

Signed-off-by: GitHub <noreply@github.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Blobstorage Output Binding: Remove list from conf test

Signed-off-by: GitHub <noreply@github.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Azure Blobstorage Binding - include name upon creation

Signed-off-by: GitHub <noreply@github.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* blobstore binding - verify encoding option

Signed-off-by: GitHub <noreply@github.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* go mod tidy

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Additional test cases

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* list blob tests WIP

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* More stable certification tests for AzBlob Binding

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Remaining Blob Storage Binding certification tests

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Lint blob storage certification tests

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* update go.mods

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Fix license header

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* use byte string instead of file

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Run make modtidy-all again

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2022-01-13 18:06:39 -08:00
Zheng Dayu 2d52913aa9
Add AlibabaCloud OOS Parameter Store as a secret component (#1402)
* secret stores supports alibabacloud oos parameterstore

Signed-off-by: Zheng Dayu <davidzheng23@gmail.com>

* run make modtidy-all

Signed-off-by: Zheng Dayu <davidzheng23@gmail.com>

Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Taction <zchao9100@gmail.com>
2022-01-13 09:56:44 -08:00
Yordan Pavlov b8063f2bdb
Fix #1250 by upgrading cloud.google.com/go/pubsub to v1.12.2 (#1285)
* upgrade cloud.google.com/go/pubsub to v1.12.2

Signed-off-by: Yordan Pavlov <yordan.pavlov@dunnhumby.com>

* update GCP secret manager test

Signed-off-by: Yordan Pavlov <yordan.pavlov@dunnhumby.com>

* make modtidy-all

Signed-off-by: Yordan Pavlov <yordan.pavlov@dunnhumby.com>

Co-authored-by: Yordan Pavlov <yordan.pavlov@dunnhumby.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
2022-01-13 09:26:42 -08:00
Dapr Bot 04a17fd414
Merge branch 'master' into feature/pulsar0107 2022-01-13 09:12:49 -08:00
Gehhilfe 44199ca4dc
Fix #1351 Fail with useful error message when an invalid account name is used (#1403)
* state azure blobstorage: fail for invalid account name

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

* state azure blobstorage: Remove duplicated code and add error check for common entpoint

Signed-off-by: Tim Burkert <burkert.tim@gmail.com>

Co-authored-by: Looong Dai <long.dai@intel.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
2022-01-13 09:02:07 -08:00
Dapr Bot c1e2dde27b
Merge branch 'master' into feature/pulsar0107 2022-01-13 07:47:13 -08:00