* Added certification tests for Azure Storage Queue Bindings
Signed-off-by: Amulya Varote <amulyavarote@microsoft.com>
* Changes based on the review comments
Signed-off-by: Amulya Varote <amulyavarote@microsoft.com>
* Added ttl test case to fetch the unexpired messages
Signed-off-by: Amulya Varote <amulyavarote@microsoft.com>
* parent dbb18e4d77
author Scott Hussey <sthussey@gmail.com> 1632277042 -0500
committer Scott Hussey <sthussey@gmail.com> 1639111222 -0600
Support Oauth2 authentication for Kafka
- Utilize the SASL OAUTHBEARER mechanism to support
the Oauth2 client_credentials flow for Kafka
authentication
- Deprecate `authRequired` field and introduce `authType`
to support varied authentication mechanisms
- Add a metadata upgrade mechanism to support backwards
compatability
- Recommend broker specific scopes to guard against a
compromised broker replaying a token
Signed-off-by: Scott Hussey <sthussey@gmail.com>
* kafka test - use volumes instead of root
CI test fails due to losing data written to container
root
Signed-off-by: Scott Hussey <sthussey@gmail.com>
* Clean up volumes
- When bringing down the docker-compose context, cleanup
volumes
Signed-off-by: Scott Hussey <sthussey@gmail.com>
* Clean up stale comment
Signed-off-by: Scott Hussey <sthussey@gmail.com>
* Resume config defaults
- Return some Kafka config to default values to lower config
footprint and stabilize flaky CI runs
Signed-off-by: Scott Hussey <sthussey@gmail.com>
* Add certification tests for ASB Queue binding
This commit adds certification tests for the Azure Service Bus Queue
Input/Output binding. This utilizes the new certification framework
and performs a series of tests as described in the test plan readme.
The general purpose of these tests is to serve as an integration test
and as such requires an actual Azure Service Bus connection and a
Dapr sidecar.
https://github.com/dapr/components-contrib/issues/957
* Add to github workflow and fix formatting
* Fix dependencies
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
* Fixing publish/subscribe race condition in RabbitMQ component.
Added amqpReady function to tests to wait for RabbitMQ readiness.
Tweaks to when subscribed is signaled in the test.
* Update go.mod(s)
* AKV Integration test - WIP
* KeyVault integration test
* Adds network interruption capabilities
* wip
* remove async handling
* Azure Secret Store test
* get with the flow
* Remove network interruption because it is pointless here
* newlines
* Address code review
* Updte Readme to remove section on basic conformance
* Allocate random ports
* Adds network interruption capabilities
* remove async handling
* update example docstring
* no need for loop
* small optimization
* newline for good measure
* update dapr version
* WIP
* tweaks
* Simplifying runnables
* Increase network timeout
* tweaks
* More tweaks
* Docker compose and structural tweaks
Co-authored-by: tanvigour <60332928+tanvigour@users.noreply.github.com>
* Tweak
* Working Kafka test
* Watcher ordered vs unordered
* Error simulation
* Made port explicit, removed Redis
* package.Run (better naming)
* terraform related changes
* Restructuring certification testing
* Remove copied go-sdk client package
* Fix terraform.go build issues
* Using master of go-sdk
* Using main of go-sdk
* Tweaks per PR
* Adding file headers and some tweaks per PR
* More tweaks
* More comments in Kafka test
Co-authored-by: tanvigour <60332928+tanvigour@users.noreply.github.com>
Co-authored-by: Tanvi Gour <tanvi.gour@gmail.com>
Co-authored-by: tanvigour <>
Co-authored-by: Long Dai <long.dai@intel.com>
Co-authored-by: Simon Leet <31784195+CodeMonkeyLeet@users.noreply.github.com>
Josh van Leeuwen
Alessandro (Ale) Segala
Yaron Schneider
addjuarez
Deepanshu Agarwal
Joni Collinge
Bernd Verst
Bruce Huang
amulyavarote
pigletfly
Shivam Kumar
Dmitry Shmulevich
Scott Hussey
halspang
Phil Kedy