github
/
k3s
mirror of https://github.com/k3s-io/k3s
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Address nits from PR #3423

pull/6/head
saadali 2015-01-13 21:51:45 -08:00
parent ff908a0d72
commit 826b61c76d
3 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/kubelet/config/config.go
View File

@ -76,7 +76,9 @@ func (c *PodConfig) Channel(source string) chan<- interface{} {
return c.mux.Channel(source)
}
func (c *PodConfig) SourceSeen(source string) bool {
// IsSourceSeen returns true if the specified source string has previously
// been marked as seen.
func (c *PodConfig) IsSourceSeen(source string) bool {
if c.pods == nil {
return false
}

2
pkg/kubelet/types.go
View File

@ -81,7 +81,7 @@ func ParsePodFullName(podFullName string) (podName, podNamespace string, podAnno
expectedNumFields := 3
actualNumFields := len(parts)
if actualNumFields != expectedNumFields {
glog.Warningf("found a podFullName (%q) with too few fields: expected %d, actual %d.", podFullName, expectedNumFields, actualNumFields)
glog.Errorf("found a podFullName (%q) with too few fields: expected %d, actual %d.", podFullName, expectedNumFields, actualNumFields)
return
}
podName = parts[0]

2
pkg/standalone/standalone.go
View File

@ -274,7 +274,7 @@ func createAndInitKubelet(kc *KubeletConfig, pc *config.PodConfig) (*kubelet.Kub
kc.RegistryBurst,
kc.MinimumGCAge,
kc.MaxContainerCount,
pc.SourceSeen,
pc.IsSourceSeen,
kc.ClusterDomain,
net.IP(kc.ClusterDNS))