diff --git a/pkg/kubelet/util.go b/pkg/kubelet/util.go index cc6aa5834ce..7c88f150047 100644 --- a/pkg/kubelet/util.go +++ b/pkg/kubelet/util.go @@ -29,6 +29,7 @@ import ( "github.com/GoogleCloudPlatform/kubernetes/pkg/client/record" "github.com/GoogleCloudPlatform/kubernetes/pkg/clientauth" "github.com/GoogleCloudPlatform/kubernetes/pkg/health" + "github.com/GoogleCloudPlatform/kubernetes/pkg/tools" "github.com/GoogleCloudPlatform/kubernetes/pkg/util" "github.com/coreos/go-etcd/etcd" "github.com/golang/glog" @@ -59,7 +60,7 @@ func InitHealthChecking(k *Kubelet) { } // TODO: move this into a pkg/tools/etcd_tools -func EtcdClientOrDie(etcdServerList util.StringList, etcdConfigFile string) *etcd.Client { +func EtcdClientOrDie(etcdServerList util.StringList, etcdConfigFile string) tools.EtcdClient { if len(etcdServerList) > 0 { return etcd.NewClient(etcdServerList) } else if etcdConfigFile != "" { diff --git a/pkg/standalone/standalone.go b/pkg/standalone/standalone.go index b9af29ac77a..96665b268a7 100644 --- a/pkg/standalone/standalone.go +++ b/pkg/standalone/standalone.go @@ -200,7 +200,6 @@ func makePodSourceConfig(kc *KubeletConfig) *config.PodConfig { glog.Infof("Adding manifest url: %v", kc.ManifestURL) config.NewSourceURL(kc.ManifestURL, kc.HttpCheckFrequency, cfg.Channel(kubelet.HTTPSource)) } - if kc.EtcdClient != nil { glog.Infof("Watching for etcd configs at %v", kc.EtcdClient.GetCluster()) config.NewSourceEtcd(config.EtcdKeyForHost(kc.Hostname), kc.EtcdClient, cfg.Channel(kubelet.EtcdSource))