mirror of
				https://github.com/k3s-io/kubernetes.git
				synced 2025-10-31 05:40:42 +00:00 
			
		
		
		
	Fix a crash for kubelet when without EtcdClient.
This commit is contained in:
		| @@ -20,6 +20,7 @@ import ( | ||||
| 	"fmt" | ||||
| 	"net" | ||||
| 	"net/http" | ||||
| 	"reflect" | ||||
| 	"time" | ||||
|  | ||||
| 	"github.com/GoogleCloudPlatform/kubernetes/pkg/api" | ||||
| @@ -225,8 +226,7 @@ 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 { | ||||
| 	if !reflect.ValueOf(kc.EtcdClient).IsNil() { | ||||
| 		glog.Infof("Watching for etcd configs at %v", kc.EtcdClient.GetCluster()) | ||||
| 		config.NewSourceEtcd(config.EtcdKeyForHost(kc.Hostname), kc.EtcdClient, cfg.Channel(kubelet.EtcdSource)) | ||||
| 	} | ||||
|   | ||||
		Reference in New Issue
	
	Block a user