mirror of
				https://github.com/optim-enterprises-bv/kubernetes.git
				synced 2025-11-04 04:08:16 +00:00 
			
		
		
		
	Moved node/testutil to upper dir.
This commit is contained in:
		@@ -182,7 +182,6 @@ pkg/controller/job
 | 
			
		||||
pkg/controller/namespace
 | 
			
		||||
pkg/controller/namespace/deletion
 | 
			
		||||
pkg/controller/node
 | 
			
		||||
pkg/controller/node/testutil
 | 
			
		||||
pkg/controller/podautoscaler
 | 
			
		||||
pkg/controller/podautoscaler/metrics
 | 
			
		||||
pkg/controller/podgc
 | 
			
		||||
 
 | 
			
		||||
@@ -20,7 +20,7 @@ go_test(
 | 
			
		||||
        "//pkg/api:go_default_library",
 | 
			
		||||
        "//pkg/api/install:go_default_library",
 | 
			
		||||
        "//pkg/api/testapi:go_default_library",
 | 
			
		||||
        "//pkg/controller/node/testutil:go_default_library",
 | 
			
		||||
        "//pkg/controller/testutil:go_default_library",
 | 
			
		||||
        "//pkg/securitycontext:go_default_library",
 | 
			
		||||
        "//vendor/k8s.io/api/core/v1:go_default_library",
 | 
			
		||||
        "//vendor/k8s.io/api/extensions/v1beta1:go_default_library",
 | 
			
		||||
@@ -128,6 +128,7 @@ filegroup(
 | 
			
		||||
        "//pkg/controller/service:all-srcs",
 | 
			
		||||
        "//pkg/controller/serviceaccount:all-srcs",
 | 
			
		||||
        "//pkg/controller/statefulset:all-srcs",
 | 
			
		||||
        "//pkg/controller/testutil:all-srcs",
 | 
			
		||||
        "//pkg/controller/ttl:all-srcs",
 | 
			
		||||
        "//pkg/controller/volume/attachdetach:all-srcs",
 | 
			
		||||
        "//pkg/controller/volume/events:all-srcs",
 | 
			
		||||
 
 | 
			
		||||
@@ -43,7 +43,7 @@ go_test(
 | 
			
		||||
        "//pkg/cloudprovider:go_default_library",
 | 
			
		||||
        "//pkg/cloudprovider/providers/fake:go_default_library",
 | 
			
		||||
        "//pkg/controller:go_default_library",
 | 
			
		||||
        "//pkg/controller/node/testutil:go_default_library",
 | 
			
		||||
        "//pkg/controller/testutil:go_default_library",
 | 
			
		||||
        "//pkg/kubelet/apis:go_default_library",
 | 
			
		||||
        "//plugin/pkg/scheduler/algorithm:go_default_library",
 | 
			
		||||
        "//vendor/github.com/golang/glog:go_default_library",
 | 
			
		||||
 
 | 
			
		||||
@@ -34,7 +34,7 @@ import (
 | 
			
		||||
	"k8s.io/kubernetes/pkg/cloudprovider"
 | 
			
		||||
	fakecloud "k8s.io/kubernetes/pkg/cloudprovider/providers/fake"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller/node/testutil"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller/testutil"
 | 
			
		||||
	kubeletapis "k8s.io/kubernetes/pkg/kubelet/apis"
 | 
			
		||||
	"k8s.io/kubernetes/plugin/pkg/scheduler/algorithm"
 | 
			
		||||
)
 | 
			
		||||
 
 | 
			
		||||
@@ -45,7 +45,7 @@ import (
 | 
			
		||||
	"k8s.io/kubernetes/pkg/api"
 | 
			
		||||
	_ "k8s.io/kubernetes/pkg/api/install"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/api/testapi"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller/node/testutil"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller/testutil"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/securitycontext"
 | 
			
		||||
)
 | 
			
		||||
 | 
			
		||||
 
 | 
			
		||||
@@ -24,7 +24,7 @@ go_test(
 | 
			
		||||
        "//pkg/cloudprovider:go_default_library",
 | 
			
		||||
        "//pkg/cloudprovider/providers/fake:go_default_library",
 | 
			
		||||
        "//pkg/controller:go_default_library",
 | 
			
		||||
        "//pkg/controller/node/testutil:go_default_library",
 | 
			
		||||
        "//pkg/controller/testutil:go_default_library",
 | 
			
		||||
        "//pkg/kubelet/apis:go_default_library",
 | 
			
		||||
        "//pkg/util/node:go_default_library",
 | 
			
		||||
        "//pkg/util/taints:go_default_library",
 | 
			
		||||
@@ -115,9 +115,6 @@ filegroup(
 | 
			
		||||
 | 
			
		||||
filegroup(
 | 
			
		||||
    name = "all-srcs",
 | 
			
		||||
    srcs = [
 | 
			
		||||
        ":package-srcs",
 | 
			
		||||
        "//pkg/controller/node/testutil:all-srcs",
 | 
			
		||||
    ],
 | 
			
		||||
    srcs = [":package-srcs"],
 | 
			
		||||
    tags = ["automanaged"],
 | 
			
		||||
)
 | 
			
		||||
 
 | 
			
		||||
@@ -25,7 +25,7 @@ import (
 | 
			
		||||
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 | 
			
		||||
	"k8s.io/apimachinery/pkg/util/wait"
 | 
			
		||||
	"k8s.io/client-go/kubernetes/fake"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller/node/testutil"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller/testutil"
 | 
			
		||||
)
 | 
			
		||||
 | 
			
		||||
const (
 | 
			
		||||
 
 | 
			
		||||
@@ -39,7 +39,7 @@ import (
 | 
			
		||||
	"k8s.io/kubernetes/pkg/cloudprovider"
 | 
			
		||||
	fakecloud "k8s.io/kubernetes/pkg/cloudprovider/providers/fake"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller/node/testutil"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller/testutil"
 | 
			
		||||
	kubeletapis "k8s.io/kubernetes/pkg/kubelet/apis"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/util/node"
 | 
			
		||||
	taintutils "k8s.io/kubernetes/pkg/util/taints"
 | 
			
		||||
 
 | 
			
		||||
@@ -24,7 +24,7 @@ import (
 | 
			
		||||
 | 
			
		||||
	"k8s.io/api/core/v1"
 | 
			
		||||
	"k8s.io/client-go/kubernetes/fake"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller/node/testutil"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller/testutil"
 | 
			
		||||
 | 
			
		||||
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 | 
			
		||||
	clienttesting "k8s.io/client-go/testing"
 | 
			
		||||
 
 | 
			
		||||
@@ -39,7 +39,7 @@ go_test(
 | 
			
		||||
    tags = ["automanaged"],
 | 
			
		||||
    deps = [
 | 
			
		||||
        "//pkg/controller:go_default_library",
 | 
			
		||||
        "//pkg/controller/node/testutil:go_default_library",
 | 
			
		||||
        "//pkg/controller/testutil:go_default_library",
 | 
			
		||||
        "//vendor/k8s.io/api/core/v1:go_default_library",
 | 
			
		||||
        "//vendor/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
 | 
			
		||||
        "//vendor/k8s.io/apimachinery/pkg/labels:go_default_library",
 | 
			
		||||
 
 | 
			
		||||
@@ -30,7 +30,7 @@ import (
 | 
			
		||||
	clientset "k8s.io/client-go/kubernetes"
 | 
			
		||||
	"k8s.io/client-go/kubernetes/fake"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller/node/testutil"
 | 
			
		||||
	"k8s.io/kubernetes/pkg/controller/testutil"
 | 
			
		||||
)
 | 
			
		||||
 | 
			
		||||
type FakeController struct{}
 | 
			
		||||
 
 | 
			
		||||
@@ -68,30 +68,31 @@ type FakeNodeHandler struct {
 | 
			
		||||
	DeleteWaitChan chan struct{}
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
// FakeLegacyHandler is a fake implemtation of CoreV1Interface.
 | 
			
		||||
type FakeLegacyHandler struct {
 | 
			
		||||
	v1core.CoreV1Interface
 | 
			
		||||
	n *FakeNodeHandler
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
// GetUpdatedNodesCopy returns a slice of Nodes with updates applied.
 | 
			
		||||
func (c *FakeNodeHandler) GetUpdatedNodesCopy() []*v1.Node {
 | 
			
		||||
	c.lock.Lock()
 | 
			
		||||
	defer c.lock.Unlock()
 | 
			
		||||
	updatedNodesCopy := make([]*v1.Node, len(c.UpdatedNodes), len(c.UpdatedNodes))
 | 
			
		||||
	for i, ptr := range c.UpdatedNodes {
 | 
			
		||||
func (m *FakeNodeHandler) GetUpdatedNodesCopy() []*v1.Node {
 | 
			
		||||
	m.lock.Lock()
 | 
			
		||||
	defer m.lock.Unlock()
 | 
			
		||||
	updatedNodesCopy := make([]*v1.Node, len(m.UpdatedNodes), len(m.UpdatedNodes))
 | 
			
		||||
	for i, ptr := range m.UpdatedNodes {
 | 
			
		||||
		updatedNodesCopy[i] = ptr
 | 
			
		||||
	}
 | 
			
		||||
	return updatedNodesCopy
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
// Core returns fake CoreInterface.
 | 
			
		||||
func (c *FakeNodeHandler) Core() v1core.CoreV1Interface {
 | 
			
		||||
	return &FakeLegacyHandler{c.Clientset.Core(), c}
 | 
			
		||||
func (m *FakeNodeHandler) Core() v1core.CoreV1Interface {
 | 
			
		||||
	return &FakeLegacyHandler{m.Clientset.Core(), m}
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
// CoreV1 returns fake CoreV1Interface
 | 
			
		||||
func (c *FakeNodeHandler) CoreV1() v1core.CoreV1Interface {
 | 
			
		||||
	return &FakeLegacyHandler{c.Clientset.CoreV1(), c}
 | 
			
		||||
func (m *FakeNodeHandler) CoreV1() v1core.CoreV1Interface {
 | 
			
		||||
	return &FakeLegacyHandler{m.Clientset.CoreV1(), m}
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
// Nodes return fake NodeInterfaces.
 | 
			
		||||
@@ -115,9 +116,8 @@ func (m *FakeNodeHandler) Create(node *v1.Node) (*v1.Node, error) {
 | 
			
		||||
		nodeCopy := *node
 | 
			
		||||
		m.CreatedNodes = append(m.CreatedNodes, &nodeCopy)
 | 
			
		||||
		return node, nil
 | 
			
		||||
	} else {
 | 
			
		||||
		return nil, errors.New("Create error.")
 | 
			
		||||
	}
 | 
			
		||||
	return nil, errors.New("create error")
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
// Get returns a Node from the fake store.
 | 
			
		||||
		Reference in New Issue
	
	Block a user