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

fixes test/integration/ttlcontroller staticcheck

Browse Source
This commit is contained in:
a1k24 2020-09-28 01:06:56 +05:30
parent cea1d4e20b
commit 8854924e65
2 changed files with 28 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

34
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,48 @@ 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)
}
wg.Wait()
go func() { // wait in another go-routine to close channel
wg.Wait()
close(errs)
}()
for err := range errs {
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)
}
wg.Wait()
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) {