github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-02-22 07:03:28 +00:00
Code Issues Projects Releases Wiki Activity

pkg/controller/garbagecollector/garbagecollector_test: wrap kubeClient with a client that doesn't support WatchList semantics.

Browse Source
This commit is contained in:
Lukasz Szaszkiewicz
2025-11-03 10:02:55 +01:00
parent 5e2ad84f67
commit c832203707
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/controller/garbagecollector/garbagecollector_test.go
View File

@@ -818,6 +818,14 @@ func TestGetDeletableResources(t *testing.T) {
}
}
type wrappedKubeClientWithUnsupportedWatchListSemantics struct {
kubernetes.Interface
}
func (c *wrappedKubeClientWithUnsupportedWatchListSemantics) IsWatchListSemanticsUnSupported() bool {
return true
}
// TestGarbageCollectorSync ensures that a discovery client error
// or an informer sync error will not cause the garbage collector
// to block infinitely.
@@ -889,10 +897,12 @@ func TestGarbageCollectorSync(t *testing.T) {
srv, clientConfig := testServerAndClientConfig(alternativeTestHandler)
defer srv.Close()
clientConfig.ContentConfig.NegotiatedSerializer = nil
client, err := kubernetes.NewForConfig(clientConfig)
kubeClient, err := kubernetes.NewForConfig(clientConfig)
if err != nil {
t.Fatal(err)
}
// TODO(#115478): migrate this test to use fakeClient instead of the real client.
client := &wrappedKubeClientWithUnsupportedWatchListSemantics{kubeClient}
tweakableRM := meta.NewDefaultRESTMapper(nil)
tweakableRM.AddSpecific(schema.GroupVersionKind{Version: "v1", Kind: "Pod"}, schema.GroupVersionResource{Version: "v1", Resource: "pods"}, schema.GroupVersionResource{Version: "v1", Resource: "pod"}, meta.RESTScopeNamespace)