github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-12 13:31:52 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #127945 from jpbetz/fix-peerproxy

Browse Source 
peerproxy flake: Cancel informers for shutdown server in peerproxy test
This commit is contained in:
Kubernetes Prow Robot 2024-10-09 08:36:29 +01:00 committed by GitHub
commit c5aa403a98
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
test/integration/apiserver/peerproxy/peer_proxy_test.go
View File

@ -24,6 +24,7 @@ import (
"github.com/stretchr/testify/assert" "github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require" "github.com/stretchr/testify/require"
v1 "k8s.io/api/batch/v1" v1 "k8s.io/api/batch/v1"
corev1 "k8s.io/api/core/v1" corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@ -143,7 +144,8 @@ func TestPeerProxiedRequestToThirdServerAfterFirstDies(t *testing.T) {
require.NoError(t, err) require.NoError(t, err)
// ensure storageversion garbage collector ctlr is set up // ensure storageversion garbage collector ctlr is set up
informersA := informers.NewSharedInformerFactory(kubeClientSetA, time.Second) informersA := informers.NewSharedInformerFactory(kubeClientSetA, time.Second)
setupStorageVersionGC(ctx, kubeClientSetA, informersA) informersACtx, informersACancel := context.WithCancel(ctx)
setupStorageVersionGC(informersACtx, kubeClientSetA, informersA)
// reset lease duration to default value for serverB and serverC since we will not be // reset lease duration to default value for serverB and serverC since we will not be
// shutting these down // shutting these down
controlplaneapiserver.IdentityLeaseDurationSeconds = 3600 controlplaneapiserver.IdentityLeaseDurationSeconds = 3600
@ -173,6 +175,7 @@ func TestPeerProxiedRequestToThirdServerAfterFirstDies(t *testing.T) {
klog.Infof("\nServerA has created jobs\n") klog.Infof("\nServerA has created jobs\n")
// shutdown serverA // shutdown serverA
informersACancel()
serverA.TearDownFn() serverA.TearDownFn()
var jobsB *v1.JobList var jobsB *v1.JobList