upstream/kubernetes
1
0
Fork 0
mirror of https://github.com/kubernetes/kubernetes.git synced 2026-05-28 04:04:39 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

test/apimachinery/watchlist: properly wire modified config to informer for fallback case

Browse source
This commit is contained in:
Lukasz Szaszkiewicz 2025-06-13 17:23:16 +02:00
parent 54291a55c2
commit 7f1dde2a0f
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
test/e2e/apimachinery/watchlist.go
View file

@ -198,14 +198,15 @@ var _ = SIGDescribe("API Streaming (aka. WatchList)", framework.WithFeatureGate(
ginkgo.It("falls backs to supported content type when when receiving resources as Tables was requested", func(ctx context.Context) {
featuregatetesting.SetFeatureGateDuringTest(ginkgo.GinkgoTB(), utilfeature.DefaultFeatureGate, featuregate.Feature(clientfeatures.WatchListClient), true)
modifiedClientConfig := f.ClientConfig()
modifiedClientConfig := dynamic.ConfigFor(f.ClientConfig())
modifiedClientConfig.AcceptContentTypes = strings.Join([]string{
fmt.Sprintf("application/json;as=Table;v=%s;g=%s", metav1.SchemeGroupVersion.Version, metav1.GroupName),
"application/json",
}, ",")
modifiedClientConfig.GroupVersion = &v1.SchemeGroupVersion
dynamicClient, err := dynamic.NewForConfig(modifiedClientConfig)
restClient, err := rest.RESTClientFor(modifiedClientConfig)
framework.ExpectNoError(err)
dynamicClient := dynamic.New(restClient)
stopCh := make(chan struct{})
defer close(stopCh)