github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-30 06:54:01 +00:00
Code Issues Projects Releases Wiki Activity

Fix Event.Source for hostname_override case.

Browse Source
This commit is contained in:
Dawn Chen 2015-01-14 09:36:09 -08:00
parent 1f210d4961
commit 0716df8f2b
2 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/kubelet/util.go
View File

@ -82,9 +82,8 @@ func SetupLogging() {
record.StartLogging(glog.Infof)
}
func SetupEventSending(client *client.Client) {
func SetupEventSending(client *client.Client, hostname string) {
glog.Infof("Sending events to api server.")
hostname := util.GetHostname("")
record.StartRecording(client.Events(""),
api.EventSource{
Component: "kubelet",

5
pkg/standalone/standalone.go
View File

@ -170,16 +170,15 @@ func SimpleRunKubelet(client *client.Client, etcdClient tools.EtcdClient, docker
// 3 Standalone 'kubernetes' binary
// Eventually, #2 will be replaced with instances of #3
func RunKubelet(kcfg *KubeletConfig) {
kcfg.Hostname = util.GetHostname(kcfg.HostnameOverride)
if kcfg.KubeClient != nil {
kubelet.SetupEventSending(kcfg.KubeClient)
kubelet.SetupEventSending(kcfg.KubeClient, kcfg.Hostname)
} else {
glog.Infof("No api server defined - no events will be sent.")
}
kubelet.SetupLogging()
kubelet.SetupCapabilities(kcfg.AllowPrivileged)
kcfg.Hostname = util.GetHostname(kcfg.HostnameOverride)
cfg := makePodSourceConfig(kcfg)
k, err := createAndInitKubelet(kcfg, cfg)
if err != nil {