Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

[release-3.5]: upgrade gRPC-go to v1.52.0

Browse Source 
backport https://github.com/etcd-io/etcd/pull/14834 and https://github.com/etcd-io/etcd/pull/16324

Signed-off-by: Chao Chen <chaochn@amazon.com>
This commit is contained in:
Chao Chen
2023-10-16 21:42:47 -07:00
parent 3921831cdb
commit 6f4fa5a27a
20 changed files with 168 additions and 467 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
tests/integration/grpc_test.go
View File

@@ -22,8 +22,9 @@ import (
"testing"
"time"
clientv3 "go.etcd.io/etcd/client/v3"
"google.golang.org/grpc"
clientv3 "go.etcd.io/etcd/client/v3"
)
func TestAuthority(t *testing.T) {
@@ -107,12 +108,14 @@ func TestAuthority(t *testing.T) {
kv := setupClient(t, tc.clientURLPattern, clus, tlsConfig)
defer kv.Close()
_, err := kv.Put(context.TODO(), "foo", "bar")
if err != nil {
t.Fatal(err)
for i := 0; i < 100; i++ {
_, err := kv.Put(context.TODO(), "foo", "bar")
if err != nil {
t.Fatal(err)
}
}
assertAuthority(t, templateAuthority(t, tc.expectAuthorityPattern, clus.Members[0]), clus)
assertAuthority(t, tc.expectAuthorityPattern, clus)
})
}
}
@@ -180,18 +183,20 @@ func templateAuthority(t *testing.T, pattern string, m *member) string {
return authority
}
func assertAuthority(t *testing.T, expectedAuthority string, clus *ClusterV3) {
func assertAuthority(t *testing.T, expectedAuthorityPattern string, clus *ClusterV3) {
t.Helper()
requestsFound := 0
for _, m := range clus.Members {
requestsFound := 0
expectedAuthority := templateAuthority(t, expectedAuthorityPattern, m)
for _, r := range m.RecordedRequests() {
requestsFound++
if r.Authority != expectedAuthority {
if r.Authority == expectedAuthority {
requestsFound++
} else {
t.Errorf("Got unexpected authority header, member: %q, request: %q, got authority: %q, expected %q", m.Name, r.FullMethod, r.Authority, expectedAuthority)
}
}
}
if requestsFound == 0 {
t.Errorf("Expected at least one request")
if requestsFound == 0 {
t.Errorf("Expected at least one request with matched authority header value was recorded by the server intercepter on member %s but got 0", m.Name)
}
}
}