github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-02 08:17:26 +00:00
Code Issues Projects Releases Wiki Activity

fix-review

Browse Source
This commit is contained in:
zhangxiaoyu-zidif 2017-08-22 10:57:48 +08:00
parent a7c69bd5fe
commit e83e799d1d
2 changed files with 13 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/kubectl/cmd/util/BUILD
View File

@ -114,6 +114,7 @@ go_test(
"//vendor/k8s.io/apimachinery/pkg/runtime:go_default_library", "//vendor/k8s.io/apimachinery/pkg/runtime:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime/schema:go_default_library", "//vendor/k8s.io/apimachinery/pkg/runtime/schema:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/util/diff:go_default_library", "//vendor/k8s.io/apimachinery/pkg/util/diff:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/util/sets:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/util/validation/field:go_default_library", "//vendor/k8s.io/apimachinery/pkg/util/validation/field:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/version:go_default_library", "//vendor/k8s.io/apimachinery/pkg/version:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/watch:go_default_library", "//vendor/k8s.io/apimachinery/pkg/watch:go_default_library",

33
pkg/kubectl/cmd/util/factory_test.go
View File

@ -37,6 +37,7 @@ import (
"k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/labels"
"k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime"
"k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apimachinery/pkg/runtime/schema"
"k8s.io/apimachinery/pkg/util/sets"
"k8s.io/apimachinery/pkg/watch" "k8s.io/apimachinery/pkg/watch"
"k8s.io/apiserver/pkg/util/flag" "k8s.io/apiserver/pkg/util/flag"
manualfake "k8s.io/client-go/rest/fake" manualfake "k8s.io/client-go/rest/fake"
@ -88,22 +89,16 @@ func TestPortsForObject(t *testing.T) {
}, },
} }
expected := []string{"101"} expected := sets.NewString("101")
got, err := f.PortsForObject(pod) ports, err := f.PortsForObject(pod)
if err != nil { if err != nil {
t.Fatalf("Unexpected error: %v", err) t.Fatalf("Unexpected error: %v", err)
} }
if len(expected) != len(got) {
t.Fatalf("Ports size mismatch! Expected %d, got %d", len(expected), len(got))
}
sort.Strings(expected) got := sets.NewString(ports...)
sort.Strings(got)
for i, port := range got { if !expected.Equal(got) {
if port != expected[i] { t.Fatalf("Ports mismatch! Expected %v, got %v", expected, got)
t.Fatalf("Port mismatch! Expected %s, got %s", expected[i], port)
}
} }
} }
@ -130,22 +125,18 @@ func TestProtocolsForObject(t *testing.T) {
}, },
} }
expected := "101/TCP,102/UDP" expected := sets.NewString("101/TCP", "102/UDP")
protocolsMap, err := f.ProtocolsForObject(pod) protocolsMap, err := f.ProtocolsForObject(pod)
if err != nil { if err != nil {
t.Fatalf("Unexpected error: %v", err) t.Fatalf("Unexpected error: %v", err)
} }
got := kubectl.MakeProtocols(protocolsMap)
expectedSlice := strings.Split(expected, ",")
gotSlice := strings.Split(got, ",")
sort.Strings(expectedSlice) protocolsString := kubectl.MakeProtocols(protocolsMap)
sort.Strings(gotSlice) protocolsStrings := strings.Split(protocolsString, ",")
got := sets.NewString(protocolsStrings...)
for i, protocol := range gotSlice { if !expected.Equal(got) {
if protocol != expectedSlice[i] { t.Fatalf("Protocols mismatch! Expected %v, got %v", expected, got)
t.Fatalf("Protocols mismatch! Expected %s, got %s", expectedSlice[i], protocol)
}
} }
} }