github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-21 10:51:29 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #95101 from a1k24/patch-92402-staticcheck

Browse Source 
fixes test/integration/ttlcontroller staticcheck
This commit is contained in:
Kubernetes Prow Robot 2020-10-07 02:16:42 -07:00 committed by GitHub
commit 777e84e184
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 30 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
hack/.staticcheck_failures
View File

@ -7,7 +7,6 @@ test/integration/examples
test/integration/framework
test/integration/garbagecollector
test/integration/scheduler_perf
test/integration/ttlcontroller
vendor/k8s.io/apimachinery/pkg/api/apitesting/roundtrip
vendor/k8s.io/apimachinery/pkg/api/meta
vendor/k8s.io/apimachinery/pkg/apis/meta/v1/validation

32
test/integration/ttlcontroller/ttlcontroller_test.go
View File

@ -51,6 +51,7 @@ func createClientAndInformers(t *testing.T, server *httptest.Server) (*clientset
func createNodes(t *testing.T, client *clientset.Clientset, startIndex, endIndex int) {
var wg sync.WaitGroup
errs := make(chan error, endIndex-startIndex)
for i := startIndex; i < endIndex; i++ {
wg.Add(1)
go func(idx int) {
@ -60,27 +61,50 @@ func createNodes(t *testing.T, client *clientset.Clientset, startIndex, endIndex
Name: fmt.Sprintf("node-%d", idx),
},
}
if _, err := client.CoreV1().Nodes().Create(context.TODO(), node, metav1.CreateOptions{}); err != nil {
t.Fatalf("Failed to create node: %v", err)
_, err := client.CoreV1().Nodes().Create(context.TODO(), node, metav1.CreateOptions{})
if err != nil {
errs <- err
}
}(i)
}
go func() { // wait in another go-routine to close channel
wg.Wait()
close(errs)
}()
for err := range errs {
if err != nil {
t.Fatalf("Failed to create node: %v", err)
}
}
}
func deleteNodes(t *testing.T, client *clientset.Clientset, startIndex, endIndex int) {
var wg sync.WaitGroup
errs := make(chan error, endIndex-startIndex)
for i := startIndex; i < endIndex; i++ {
wg.Add(1)
go func(idx int) {
defer wg.Done()
name := fmt.Sprintf("node-%d", idx)
if err := client.CoreV1().Nodes().Delete(context.TODO(), name, metav1.DeleteOptions{}); err != nil {
t.Fatalf("Failed to delete node: %v", err)
err := client.CoreV1().Nodes().Delete(context.TODO(), name, metav1.DeleteOptions{})
if err != nil {
errs <- err
}
}(i)
}
go func() { // wait in another go-routine to close channel
wg.Wait()
close(errs)
}()
for err := range errs {
if err != nil {
t.Fatalf("Failed to delete node: %v", err)
}
}
}
func waitForNodesWithTTLAnnotation(t *testing.T, nodeLister listers.NodeLister, numNodes, ttlSeconds int) {