github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-08-21 16:43:15 +00:00
Code Issues Projects Releases Wiki Activity

fix test

Browse Source 
Kubernetes-commit: 9a7dddf5a713e109418f3726514fdf60246ada3b
This commit is contained in:
Keisuke Ishigami 2025-07-15 01:07:43 +09:00 committed by Kubernetes Publisher
parent 3633ea23d3
commit be4c8bc002
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
tools/leaderelection/leaderelection_test.go
View File

@ -557,7 +557,7 @@ func testReleaseLease(t *testing.T, objectType string) {
verb: "get", verb: "get",
objectType: objectType, objectType: objectType,
reaction: func(action fakeclient.Action) (handled bool, ret runtime.Object, err error) { reaction: func(action fakeclient.Action) (handled bool, ret runtime.Object, err error) {
return true, nil, errors.NewNotFound(action.(fakeclient.GetAction).GetResource().GroupResource(), action.(fakeclient.GetAction).GetName()) return true, createLockObject(t, objectType, action.GetNamespace(), action.(fakeclient.GetAction).GetName(), &rl.LeaderElectionRecord{HolderIdentity: "baz"}), nil
}, },
}, },
{ {
@ -574,6 +574,13 @@ func testReleaseLease(t *testing.T, objectType string) {
return true, action.(fakeclient.UpdateAction).GetObject(), nil return true, action.(fakeclient.UpdateAction).GetObject(), nil
}, },
}, },
{
verb: "get",
objectType: objectType,
reaction: func(action fakeclient.Action) (handled bool, ret runtime.Object, err error) {
return true, nil, errors.NewNotFound(action.(fakeclient.GetAction).GetResource().GroupResource(), action.(fakeclient.GetAction).GetName())
},
},
}, },
expectSuccess: true, expectSuccess: true,
outHolder: "", outHolder: "",
@ -844,9 +851,11 @@ func testReleaseOnCancellation(t *testing.T, objectType string) {
if lockObj != nil { if lockObj != nil {
// Third and more get (first create, second renew) should return our canceled error // Third and more get (first create, second renew) should return our canceled error
// FakeClient doesn't do anything with the context so we're doing this ourselves // FakeClient doesn't do anything with the context so we're doing this ourselves
if gets >= 3 { if gets >= 4 {
if gets == 4 {
close(onRenewCalled) close(onRenewCalled)
<-onRenewResume <-onRenewResume
}
return true, nil, context.Canceled return true, nil, context.Canceled
} }
return true, lockObj, nil return true, lockObj, nil