1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980 |
- /*
- 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 kubelet
- import (
- "testing"
- v1 "k8s.io/api/core/v1"
- metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
- "k8s.io/apimachinery/pkg/runtime"
- "k8s.io/apimachinery/pkg/util/version"
- "k8s.io/client-go/kubernetes/fake"
- core "k8s.io/client-go/testing"
- kubeadmapiv1beta2 "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm/v1beta2"
- "k8s.io/kubernetes/cmd/kubeadm/app/constants"
- configutil "k8s.io/kubernetes/cmd/kubeadm/app/util/config"
- )
- func TestCreateConfigMap(t *testing.T) {
- nodeName := "fake-node"
- client := fake.NewSimpleClientset()
- client.PrependReactor("get", "nodes", func(action core.Action) (bool, runtime.Object, error) {
- return true, &v1.Node{
- ObjectMeta: metav1.ObjectMeta{
- Name: nodeName,
- },
- Spec: v1.NodeSpec{},
- }, nil
- })
- client.PrependReactor("create", "roles", func(action core.Action) (bool, runtime.Object, error) {
- return true, nil, nil
- })
- client.PrependReactor("create", "rolebindings", func(action core.Action) (bool, runtime.Object, error) {
- return true, nil, nil
- })
- client.PrependReactor("create", "configmaps", func(action core.Action) (bool, runtime.Object, error) {
- return true, nil, nil
- })
- clusterCfg := &kubeadmapiv1beta2.ClusterConfiguration{
- KubernetesVersion: constants.CurrentKubernetesVersion.String(),
- }
- internalcfg, err := configutil.DefaultedInitConfiguration(&kubeadmapiv1beta2.InitConfiguration{}, clusterCfg)
- if err != nil {
- t.Fatalf("unexpected failure by DefaultedInitConfiguration: %v", err)
- }
- if err := CreateConfigMap(&internalcfg.ClusterConfiguration, client); err != nil {
- t.Errorf("CreateConfigMap: unexpected error %v", err)
- }
- }
- func TestCreateConfigMapRBACRules(t *testing.T) {
- client := fake.NewSimpleClientset()
- client.PrependReactor("create", "roles", func(action core.Action) (bool, runtime.Object, error) {
- return true, nil, nil
- })
- client.PrependReactor("create", "rolebindings", func(action core.Action) (bool, runtime.Object, error) {
- return true, nil, nil
- })
- if err := createConfigMapRBACRules(client, version.MustParseSemantic("v1.11.0")); err != nil {
- t.Errorf("createConfigMapRBACRules: unexpected error %v", err)
- }
- }
|