feature: add context to lock&pubsub API

Signed-off-by: seachen <seachen@tencent.com>
2022-12-14 20:48:13 +08:00 · 2022-12-14 20:48:13 +08:00 · 49ee0616be
parent e59dfd63c0
commit 49ee0616be
40 changed files with 40 additions and 40 deletions
--- a/.build-tools/go.mod
+++ b/.build-tools/go.mod
@ -18,4 +18,4 @@ require (
 	gopkg.in/yaml.v2 v2.4.0 // indirect
 )

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/.github/infrastructure/conformance/temporal/worker/go.mod
+++ b/.github/infrastructure/conformance/temporal/worker/go.mod
@ -34,4 +34,4 @@ require (
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/go.mod
+++ b/go.mod
@ -376,4 +376,4 @@ replace github.com/toolkits/concurrent => github.com/niean/gotools v0.0.0-201512
 // this is a fork which addresses a performance issues due to go routines
 replace dubbo.apache.org/dubbo-go/v3 => dubbo.apache.org/dubbo-go/v3 v3.0.3-0.20220610080020-48691a404537

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221214124410-5e82abca48ab
--- a/middleware/http/wasm/example/go.mod
+++ b/middleware/http/wasm/example/go.mod
@ -2,6 +2,6 @@ module github.com/dapr/components-contrib/middleware/wasm/example

 go 1.19

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca

 require github.com/http-wasm/http-wasm-guest-tinygo v0.1.0
--- a/middleware/http/wasm/internal/e2e-guests/go.mod
+++ b/middleware/http/wasm/internal/e2e-guests/go.mod
@ -2,6 +2,6 @@ module github.com/dapr/components-contrib/middleware/wasm/internal

 go 1.19

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca

 require github.com/http-wasm/http-wasm-guest-tinygo v0.1.0
--- a/tests/certification/bindings/alicloud/dubbo/go.mod
+++ b/tests/certification/bindings/alicloud/dubbo/go.mod
@ -176,4 +176,4 @@ replace github.com/dapr/components-contrib => ../../../../..

 replace github.com/dapr/components-contrib/tests/certification => ../../..

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/bindings/alicloud/nacos/go.mod
+++ b/tests/certification/bindings/alicloud/nacos/go.mod
@ -147,4 +147,4 @@ replace github.com/dapr/components-contrib => ../../../../..

 replace github.com/dapr/components-contrib/tests/certification => ../../..

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/bindings/azure/blobstorage/go.mod
+++ b/tests/certification/bindings/azure/blobstorage/go.mod
@ -163,4 +163,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../../

 replace github.com/dapr/components-contrib => ../../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/bindings/azure/cosmosdb/go.mod
+++ b/tests/certification/bindings/azure/cosmosdb/go.mod
@ -165,4 +165,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../../

 replace github.com/dapr/components-contrib => ../../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/bindings/azure/eventhubs/go.mod
+++ b/tests/certification/bindings/azure/eventhubs/go.mod
@ -172,4 +172,4 @@ replace github.com/dapr/components-contrib => ../../../../..

 replace github.com/dapr/components-contrib/tests/certification => ../../..

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/bindings/azure/servicebusqueues/go.mod
+++ b/tests/certification/bindings/azure/servicebusqueues/go.mod
@ -169,4 +169,4 @@ replace github.com/dapr/components-contrib => ../../../../..

 replace github.com/dapr/components-contrib/tests/certification => ../../..

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/bindings/azure/storagequeues/go.mod
+++ b/tests/certification/bindings/azure/storagequeues/go.mod
@ -165,4 +165,4 @@ replace github.com/dapr/components-contrib => ../../../../..

 replace github.com/dapr/components-contrib/tests/certification => ../../..

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/bindings/cron/go.mod
+++ b/tests/certification/bindings/cron/go.mod
@ -140,7 +140,7 @@ require (
 	sigs.k8s.io/yaml v1.3.0 // indirect
 )

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca

 replace github.com/dapr/components-contrib/tests/certification => ../../

--- a/tests/certification/bindings/kafka/go.mod
+++ b/tests/certification/bindings/kafka/go.mod
@ -159,4 +159,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/bindings/localstorage/go.mod
+++ b/tests/certification/bindings/localstorage/go.mod
@ -140,4 +140,4 @@ replace github.com/dapr/components-contrib => ../../../..

 replace github.com/dapr/components-contrib/tests/certification => ../..

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/bindings/postgres/go.mod
+++ b/tests/certification/bindings/postgres/go.mod
@ -146,4 +146,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/bindings/rabbitmq/go.mod
+++ b/tests/certification/bindings/rabbitmq/go.mod
@ -143,4 +143,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/bindings/redis/go.mod
+++ b/tests/certification/bindings/redis/go.mod
@ -142,4 +142,4 @@ replace github.com/dapr/components-contrib => ../../../..

 replace github.com/dapr/components-contrib/tests/certification => ../..

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/go.mod
+++ b/tests/certification/go.mod
@ -142,4 +142,4 @@ require (

 replace github.com/dapr/components-contrib => ../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/pubsub/azure/eventhubs/go.mod
+++ b/tests/certification/pubsub/azure/eventhubs/go.mod
@ -171,4 +171,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../../

 replace github.com/dapr/components-contrib => ../../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/pubsub/azure/servicebus/topics/go.mod
+++ b/tests/certification/pubsub/azure/servicebus/topics/go.mod
@ -169,4 +169,4 @@ replace github.com/dapr/components-contrib => ../../../../../..

 replace github.com/dapr/components-contrib/tests/certification => ../../../..

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/pubsub/kafka/go.mod
+++ b/tests/certification/pubsub/kafka/go.mod
@ -159,4 +159,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/pubsub/mqtt/go.mod
+++ b/tests/certification/pubsub/mqtt/go.mod
@ -146,4 +146,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/pubsub/rabbitmq/go.mod
+++ b/tests/certification/pubsub/rabbitmq/go.mod
@ -143,4 +143,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/secretstores/azure/keyvault/go.mod
+++ b/tests/certification/secretstores/azure/keyvault/go.mod
@ -164,4 +164,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../../

 replace github.com/dapr/components-contrib => ../../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/secretstores/hashicorp/vault/go.mod
+++ b/tests/certification/secretstores/hashicorp/vault/go.mod
@ -140,4 +140,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../../

 replace github.com/dapr/components-contrib => ../../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/secretstores/local/env/go.mod
+++ b/tests/certification/secretstores/local/env/go.mod
@ -139,4 +139,4 @@ replace github.com/dapr/components-contrib => ../../../../..

 replace github.com/dapr/components-contrib/tests/certification => ../../..

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/secretstores/local/file/go.mod
+++ b/tests/certification/secretstores/local/file/go.mod
@ -139,4 +139,4 @@ replace github.com/dapr/components-contrib => ../../../../..

 replace github.com/dapr/components-contrib/tests/certification => ../../..

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/state/azure/blobstorage/go.mod
+++ b/tests/certification/state/azure/blobstorage/go.mod
@ -163,4 +163,4 @@ replace github.com/dapr/components-contrib => ../../../../..

 replace github.com/dapr/components-contrib/tests/certification => ../../..

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/state/azure/cosmosdb/go.mod
+++ b/tests/certification/state/azure/cosmosdb/go.mod
@ -164,4 +164,4 @@ replace github.com/dapr/components-contrib => ../../../../..

 replace github.com/dapr/components-contrib/tests/certification => ../../..

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/state/azure/tablestorage/go.mod
+++ b/tests/certification/state/azure/tablestorage/go.mod
@ -163,4 +163,4 @@ replace github.com/dapr/components-contrib => ../../../../..

 replace github.com/dapr/components-contrib/tests/certification => ../../..

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/state/cassandra/go.mod
+++ b/tests/certification/state/cassandra/go.mod
@ -143,4 +143,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/state/cockroachdb/go.mod
+++ b/tests/certification/state/cockroachdb/go.mod
@ -145,4 +145,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/state/memcached/go.mod
+++ b/tests/certification/state/memcached/go.mod
@ -141,4 +141,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/state/mongodb/go.mod
+++ b/tests/certification/state/mongodb/go.mod
@ -148,4 +148,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/state/mysql/go.mod
+++ b/tests/certification/state/mysql/go.mod
@ -138,6 +138,6 @@ require (

 replace github.com/dapr/components-contrib/tests/certification => ../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca

 replace github.com/dapr/components-contrib => ../../../../
--- a/tests/certification/state/postgresql/go.mod
+++ b/tests/certification/state/postgresql/go.mod
@ -143,4 +143,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/state/redis/go.mod
+++ b/tests/certification/state/redis/go.mod
@ -143,4 +143,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/certification/state/sqlserver/go.mod
+++ b/tests/certification/state/sqlserver/go.mod
@ -144,4 +144,4 @@ replace github.com/dapr/components-contrib/tests/certification => ../../

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca
--- a/tests/e2e/pubsub/jetstream/go.mod
+++ b/tests/e2e/pubsub/jetstream/go.mod
@ -22,4 +22,4 @@ require (

 replace github.com/dapr/components-contrib => ../../../../

-replace github.com/dapr/dapr => github.com/1046102779/dapr v0.0.0-20221208082204-c47f9f07131e
+replace github.com/dapr/dapr => github.com/1046102779/dapr 5e82abca