059c2aa799
Implement a flag that defines the frequency at which a node's out of disk condition can change its status. Use this flag to suspend out of disk status changes in the time period specified by the flag, after the status is changed once. Set the flag to 0 in e2e tests so that we can predictably test out of disk node condition. Also, use util.Clock interface for all time related functionality in the kubelet. Calling time functions in unversioned package or time package such as unversioned.Now() or time.Now() makes it really hard to test such code. It also makes the tests flaky and sometimes unnecessarily slow due to time.Sleep() calls used to simulate the time elapsed. So use util.Clock interface instead which can be faked in the tests.
86 lines
2.5 KiB
Go
86 lines
2.5 KiB
Go
/*
|
|
Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
|
|
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 kubemark
|
|
|
|
import (
|
|
"time"
|
|
|
|
kubeletapp "k8s.io/kubernetes/cmd/kubelet/app"
|
|
"k8s.io/kubernetes/pkg/api"
|
|
client "k8s.io/kubernetes/pkg/client/unversioned"
|
|
"k8s.io/kubernetes/pkg/kubelet/cadvisor"
|
|
"k8s.io/kubernetes/pkg/kubelet/cm"
|
|
kubecontainer "k8s.io/kubernetes/pkg/kubelet/container"
|
|
"k8s.io/kubernetes/pkg/kubelet/dockertools"
|
|
"k8s.io/kubernetes/pkg/volume/empty_dir"
|
|
"k8s.io/kubernetes/test/integration"
|
|
|
|
"github.com/golang/glog"
|
|
)
|
|
|
|
type HollowKubelet struct {
|
|
KubeletConfig *kubeletapp.KubeletConfig
|
|
}
|
|
|
|
func NewHollowKubelet(
|
|
nodeName string,
|
|
client *client.Client,
|
|
cadvisorInterface cadvisor.Interface,
|
|
dockerClient dockertools.DockerInterface,
|
|
kubeletPort, kubeletReadOnlyPort int,
|
|
containerManager cm.ContainerManager,
|
|
) *HollowKubelet {
|
|
testRootDir := integration.MakeTempDirOrDie("hollow-kubelet.", "")
|
|
manifestFilePath := integration.MakeTempDirOrDie("manifest", testRootDir)
|
|
glog.Infof("Using %s as root dir for hollow-kubelet", testRootDir)
|
|
|
|
return &HollowKubelet{
|
|
KubeletConfig: kubeletapp.SimpleKubelet(
|
|
client,
|
|
dockerClient,
|
|
nodeName,
|
|
testRootDir,
|
|
"", /* manifest-url */
|
|
"0.0.0.0", /* bind address */
|
|
uint(kubeletPort),
|
|
uint(kubeletReadOnlyPort),
|
|
api.NamespaceDefault,
|
|
empty_dir.ProbeVolumePlugins(),
|
|
nil, /* tls-options */
|
|
cadvisorInterface,
|
|
manifestFilePath,
|
|
nil, /* cloud-provider */
|
|
kubecontainer.FakeOS{}, /* os-interface */
|
|
20*time.Second, /* FileCheckFrequency */
|
|
20*time.Second, /* HTTPCheckFrequency */
|
|
1*time.Minute, /* MinimumGCAge */
|
|
10*time.Second, /* NodeStatusUpdateFrequency */
|
|
10*time.Second, /* SyncFrequency */
|
|
5*time.Minute, /* OutOfDiskTransitionFrequency */
|
|
40, /* MaxPods */
|
|
containerManager,
|
|
nil,
|
|
),
|
|
}
|
|
}
|
|
|
|
// Starts this HollowKubelet and blocks.
|
|
func (hk *HollowKubelet) Run() {
|
|
kubeletapp.RunKubelet(hk.KubeletConfig)
|
|
select {}
|
|
}
|