github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-06-23 05:37:13 +00:00
Code Issues Projects Releases Wiki Activity

Fix Infelicities in TestRESTClientLimiter

Browse Source 
Signed-off-by: Vatsal Parekh <vatsalparekh@outlook.com>

Kubernetes-commit: c980cf489eeb39fd0fe0af7e80cfea2dbe2007db
This commit is contained in:
Vatsal Parekh 2022-09-15 19:30:40 +05:30 committed by Kubernetes Publisher
parent ece64627e4
commit bf2b395a89
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
rest/config_test.go
View File

@ -163,18 +163,22 @@ func TestRESTClientLimiter(t *testing.T) {
Limiter flowcontrol.RateLimiter Limiter flowcontrol.RateLimiter
}{ }{
{ {
Name: "with no QPS",
Config: Config{}, Config: Config{},
Limiter: flowcontrol.NewTokenBucketRateLimiter(5, 10), Limiter: flowcontrol.NewTokenBucketRateLimiter(5, 10),
}, },
{ {
Name: "with QPS:10",
Config: Config{QPS: 10}, Config: Config{QPS: 10},
Limiter: flowcontrol.NewTokenBucketRateLimiter(10, 10), Limiter: flowcontrol.NewTokenBucketRateLimiter(10, 10),
}, },
{ {
Name: "with QPS:-1",
Config: Config{QPS: -1}, Config: Config{QPS: -1},
Limiter: nil, Limiter: nil,
}, },
{ {
Name: "with RateLimiter",
Config: Config{ Config: Config{
RateLimiter: flowcontrol.NewTokenBucketRateLimiter(11, 12), RateLimiter: flowcontrol.NewTokenBucketRateLimiter(11, 12),
}, },
@ -191,7 +195,7 @@ func TestRESTClientLimiter(t *testing.T) {
t.Fatalf("unexpected error: %v", err) t.Fatalf("unexpected error: %v", err)
} }
if !reflect.DeepEqual(testCase.Limiter, client.rateLimiter) { if !reflect.DeepEqual(testCase.Limiter, client.rateLimiter) {
t.Fatalf("unexpected rate limiter: %#v", client.rateLimiter) t.Fatalf("unexpected rate limiter: %#v, expected %#v at %s", client.rateLimiter, testCase.Limiter, testCase.Name)
} }
}) })
t.Run("Unversioned_"+testCase.Name, func(t *testing.T) { t.Run("Unversioned_"+testCase.Name, func(t *testing.T) {
@ -203,7 +207,7 @@ func TestRESTClientLimiter(t *testing.T) {
t.Fatalf("unexpected error: %v", err) t.Fatalf("unexpected error: %v", err)
} }
if !reflect.DeepEqual(testCase.Limiter, client.rateLimiter) { if !reflect.DeepEqual(testCase.Limiter, client.rateLimiter) {
t.Fatalf("unexpected rate limiter: %#v", client.rateLimiter) t.Fatalf("unexpected rate limiter: %#v, expected %#v at %s", client.rateLimiter, testCase.Limiter, testCase.Name)
} }
}) })
} }