123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304 |
- /*
- Copyright 2017 The Kubernetes Authors.
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
- http://www.apache.org/licenses/LICENSE-2.0
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
- */
- package constants
- import (
- "path/filepath"
- "testing"
- "k8s.io/apimachinery/pkg/util/version"
- kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm"
- )
- func TestGetStaticPodDirectory(t *testing.T) {
- expected := "/etc/kubernetes/manifests"
- actual := GetStaticPodDirectory()
- if actual != expected {
- t.Errorf(
- "failed GetStaticPodDirectory:\n\texpected: %s\n\t actual: %s",
- expected,
- actual,
- )
- }
- }
- func TestGetAdminKubeConfigPath(t *testing.T) {
- expected := filepath.Join(KubernetesDir, AdminKubeConfigFileName)
- actual := GetAdminKubeConfigPath()
- if actual != expected {
- t.Errorf(
- "failed GetAdminKubeConfigPath:\n\texpected: %s\n\t actual: %s",
- expected,
- actual,
- )
- }
- }
- func TestGetBootstrapKubeletKubeConfigPath(t *testing.T) {
- expected := "/etc/kubernetes/bootstrap-kubelet.conf"
- actual := GetBootstrapKubeletKubeConfigPath()
- if actual != expected {
- t.Errorf(
- "failed GetBootstrapKubeletKubeConfigPath:\n\texpected: %s\n\t actual: %s",
- expected,
- actual,
- )
- }
- }
- func TestGetKubeletKubeConfigPath(t *testing.T) {
- expected := "/etc/kubernetes/kubelet.conf"
- actual := GetKubeletKubeConfigPath()
- if actual != expected {
- t.Errorf(
- "failed GetKubeletKubeConfigPath:\n\texpected: %s\n\t actual: %s",
- expected,
- actual,
- )
- }
- }
- func TestGetStaticPodFilepath(t *testing.T) {
- var tests = []struct {
- componentName, manifestsDir, expected string
- }{
- {
- componentName: "kube-apiserver",
- manifestsDir: "/etc/kubernetes/manifests",
- expected: "/etc/kubernetes/manifests/kube-apiserver.yaml",
- },
- {
- componentName: "kube-controller-manager",
- manifestsDir: "/etc/kubernetes/manifests/",
- expected: "/etc/kubernetes/manifests/kube-controller-manager.yaml",
- },
- {
- componentName: "foo",
- manifestsDir: "/etc/bar/",
- expected: "/etc/bar/foo.yaml",
- },
- }
- for _, rt := range tests {
- t.Run(rt.componentName, func(t *testing.T) {
- actual := GetStaticPodFilepath(rt.componentName, rt.manifestsDir)
- if actual != rt.expected {
- t.Errorf(
- "failed GetStaticPodFilepath:\n\texpected: %s\n\t actual: %s",
- rt.expected,
- actual,
- )
- }
- })
- }
- }
- func TestAddSelfHostedPrefix(t *testing.T) {
- var tests = []struct {
- componentName, expected string
- }{
- {
- componentName: "kube-apiserver",
- expected: "self-hosted-kube-apiserver",
- },
- {
- componentName: "kube-controller-manager",
- expected: "self-hosted-kube-controller-manager",
- },
- {
- componentName: "kube-scheduler",
- expected: "self-hosted-kube-scheduler",
- },
- {
- componentName: "foo",
- expected: "self-hosted-foo",
- },
- }
- for _, rt := range tests {
- t.Run(rt.componentName, func(t *testing.T) {
- actual := AddSelfHostedPrefix(rt.componentName)
- if actual != rt.expected {
- t.Errorf(
- "failed AddSelfHostedPrefix:\n\texpected: %s\n\t actual: %s",
- rt.expected,
- actual,
- )
- }
- })
- }
- }
- func TestEtcdSupportedVersion(t *testing.T) {
- var supportedEtcdVersion = map[uint8]string{
- 13: "3.2.24",
- 14: "3.3.10",
- 15: "3.3.10",
- 16: "3.3.17-0",
- 17: "3.4.3-0",
- 18: "3.4.3-0",
- }
- var tests = []struct {
- kubernetesVersion string
- expectedVersion *version.Version
- expectedWarning bool
- expectedError bool
- }{
- {
- kubernetesVersion: "1.x.1",
- expectedVersion: nil,
- expectedWarning: false,
- expectedError: true,
- },
- {
- kubernetesVersion: "1.10.1",
- expectedVersion: version.MustParseSemantic("3.2.24"),
- expectedWarning: true,
- expectedError: false,
- },
- {
- kubernetesVersion: "1.99.0",
- expectedVersion: version.MustParseSemantic("3.4.3-0"),
- expectedWarning: true,
- expectedError: false,
- },
- {
- kubernetesVersion: "v1.16.0",
- expectedVersion: version.MustParseSemantic("3.3.17-0"),
- expectedWarning: false,
- expectedError: false,
- },
- {
- kubernetesVersion: "1.17.2",
- expectedVersion: version.MustParseSemantic("3.4.3-0"),
- expectedWarning: false,
- expectedError: false,
- },
- }
- for _, rt := range tests {
- t.Run(rt.kubernetesVersion, func(t *testing.T) {
- actualVersion, actualWarning, actualError := EtcdSupportedVersion(supportedEtcdVersion, rt.kubernetesVersion)
- if (actualError != nil) != rt.expectedError {
- t.Fatalf("expected error %v, got %v", rt.expectedError, actualError != nil)
- }
- if (actualWarning != nil) != rt.expectedWarning {
- t.Fatalf("expected warning %v, got %v", rt.expectedWarning, actualWarning != nil)
- }
- if actualError == nil && actualVersion.String() != rt.expectedVersion.String() {
- t.Errorf("expected version %s, got %s", rt.expectedVersion.String(), actualVersion.String())
- }
- })
- }
- }
- func TestGetKubeDNSVersion(t *testing.T) {
- var tests = []struct {
- dns kubeadmapi.DNSAddOnType
- expected string
- }{
- {
- dns: kubeadmapi.KubeDNS,
- expected: KubeDNSVersion,
- },
- {
- dns: kubeadmapi.CoreDNS,
- expected: CoreDNSVersion,
- },
- }
- for _, rt := range tests {
- t.Run(string(rt.dns), func(t *testing.T) {
- actualDNSVersion := GetDNSVersion(rt.dns)
- if actualDNSVersion != rt.expected {
- t.Errorf(
- "failed GetDNSVersion:\n\texpected: %s\n\t actual: %s",
- rt.expected,
- actualDNSVersion,
- )
- }
- })
- }
- }
- func TestGetKubernetesServiceCIDR(t *testing.T) {
- var tests = []struct {
- svcSubnetList string
- isDualStack bool
- expected string
- expectedError bool
- name string
- }{
- {
- svcSubnetList: "192.168.10.0/24",
- isDualStack: false,
- expected: "192.168.10.0/24",
- expectedError: false,
- name: "valid: valid IPv4 range from single-stack",
- },
- {
- svcSubnetList: "fd03::/112",
- isDualStack: false,
- expected: "fd03::/112",
- expectedError: false,
- name: "valid: valid IPv6 range from single-stack",
- },
- {
- svcSubnetList: "192.168.10.0/24,fd03::/112",
- isDualStack: true,
- expected: "192.168.10.0/24",
- expectedError: false,
- name: "valid: valid <IPv4,IPv6> ranges from dual-stack",
- },
- {
- svcSubnetList: "fd03::/112,192.168.10.0/24",
- isDualStack: true,
- expected: "fd03::/112",
- expectedError: false,
- name: "valid: valid <IPv6,IPv4> ranges from dual-stack",
- },
- {
- svcSubnetList: "192.168.10.0/24,fd03:x::/112",
- isDualStack: true,
- expected: "",
- expectedError: true,
- name: "invalid: failed to parse subnet range for dual-stack",
- },
- }
- for _, rt := range tests {
- t.Run(rt.name, func(t *testing.T) {
- actual, actualError := GetKubernetesServiceCIDR(rt.svcSubnetList, rt.isDualStack)
- if rt.expectedError {
- if actualError == nil {
- t.Errorf("failed GetKubernetesServiceCIDR:\n\texpected error, but got no error")
- }
- } else if !rt.expectedError && actualError != nil {
- t.Errorf("failed GetKubernetesServiceCIDR:\n\texpected no error, but got: %v", actualError)
- } else {
- if actual.String() != rt.expected {
- t.Errorf(
- "failed GetKubernetesServiceCIDR:\n\texpected: %s\n\t actual: %s",
- rt.expected,
- actual.String(),
- )
- }
- }
- })
- }
- }
|