github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-07-18 17:21:23 +00:00
Code Issues Projects Releases Wiki Activity

Fix staticcheck in apiserver and client-go pkgs

Browse Source 
Kubernetes-commit: 830a137d2ea70663cd94403595313b95ac40ffe8
This commit is contained in:
tiloso 2021-06-19 22:03:46 +02:00 committed by Kubernetes Publisher
parent a31b18a6ac
commit 04efcfc452
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
rest/watch/decoder_test.go
View File

@ -18,6 +18,7 @@ package versioned_test
import ( import (
"encoding/json" "encoding/json"
"fmt"
"io" "io"
"testing" "testing"
"time" "time"
@ -51,10 +52,13 @@ func TestDecoder(t *testing.T) {
expect := &v1.Pod{ObjectMeta: metav1.ObjectMeta{Name: "foo"}} expect := &v1.Pod{ObjectMeta: metav1.ObjectMeta{Name: "foo"}}
encoder := json.NewEncoder(in) encoder := json.NewEncoder(in)
eType := eventType eType := eventType
errc := make(chan error)
go func() { go func() {
data, err := runtime.Encode(scheme.Codecs.LegacyCodec(v1.SchemeGroupVersion), expect) data, err := runtime.Encode(scheme.Codecs.LegacyCodec(v1.SchemeGroupVersion), expect)
if err != nil { if err != nil {
t.Fatalf("Unexpected error %v", err) errc <- fmt.Errorf("Unexpected error %v", err)
return
} }
event := metav1.WatchEvent{ event := metav1.WatchEvent{
Type: string(eType), Type: string(eType),
@ -70,7 +74,8 @@ func TestDecoder(t *testing.T) {
go func() { go func() {
action, got, err := decoder.Decode() action, got, err := decoder.Decode()
if err != nil { if err != nil {
t.Fatalf("Unexpected error %v", err) errc <- fmt.Errorf("Unexpected error %v", err)
return
} }
if e, a := eType, action; e != a { if e, a := eType, action; e != a {
t.Errorf("Expected %v, got %v", e, a) t.Errorf("Expected %v, got %v", e, a)
@ -81,7 +86,11 @@ func TestDecoder(t *testing.T) {
t.Logf("Exited read") t.Logf("Exited read")
close(done) close(done)
}() }()
<-done select {
case err := <-errc:
t.Fatal(err)
case <-done:
}
done = make(chan struct{}) done = make(chan struct{})
go func() { go func() {