From ebc8eab5905e954c63a341a197690d66c3614334 Mon Sep 17 00:00:00 2001 From: feihujiang Date: Wed, 3 Jun 2015 14:51:32 +0800 Subject: [PATCH] get Events to be logged --- cmd/integration/integration.go | 1 + pkg/cloudprovider/nodecontroller/nodecontroller.go | 1 + pkg/controller/replication_controller.go | 1 + plugin/cmd/kube-scheduler/app/server.go | 1 + 4 files changed, 4 insertions(+) diff --git a/cmd/integration/integration.go b/cmd/integration/integration.go index 33b9cd64cff..84fec531175 100644 --- a/cmd/integration/integration.go +++ b/cmd/integration/integration.go @@ -176,6 +176,7 @@ func startComponents(firstManifestURL, secondManifestURL, apiVersion string) (st } eventBroadcaster := record.NewBroadcaster() schedulerConfig.Recorder = eventBroadcaster.NewRecorder(api.EventSource{Component: "scheduler"}) + eventBroadcaster.StartLogging(glog.Infof) eventBroadcaster.StartRecordingToSink(cl.Events("")) scheduler.New(schedulerConfig).Run() diff --git a/pkg/cloudprovider/nodecontroller/nodecontroller.go b/pkg/cloudprovider/nodecontroller/nodecontroller.go index 2d213243fcf..e06e9aef2c4 100644 --- a/pkg/cloudprovider/nodecontroller/nodecontroller.go +++ b/pkg/cloudprovider/nodecontroller/nodecontroller.go @@ -109,6 +109,7 @@ func NewNodeController( allocateNodeCIDRs bool) *NodeController { eventBroadcaster := record.NewBroadcaster() recorder := eventBroadcaster.NewRecorder(api.EventSource{Component: "controllermanager"}) + eventBroadcaster.StartLogging(glog.Infof) if kubeClient != nil { glog.Infof("Sending events to api server.") eventBroadcaster.StartRecordingToSink(kubeClient.Events("")) diff --git a/pkg/controller/replication_controller.go b/pkg/controller/replication_controller.go index 84f6895cc32..ae71b367d92 100644 --- a/pkg/controller/replication_controller.go +++ b/pkg/controller/replication_controller.go @@ -97,6 +97,7 @@ type ReplicationManager struct { // NewReplicationManager creates a new ReplicationManager. func NewReplicationManager(kubeClient client.Interface, burstReplicas int) *ReplicationManager { eventBroadcaster := record.NewBroadcaster() + eventBroadcaster.StartLogging(glog.Infof) eventBroadcaster.StartRecordingToSink(kubeClient.Events("")) rm := &ReplicationManager{ diff --git a/plugin/cmd/kube-scheduler/app/server.go b/plugin/cmd/kube-scheduler/app/server.go index c2693a1dc88..a59c498dedc 100644 --- a/plugin/cmd/kube-scheduler/app/server.go +++ b/plugin/cmd/kube-scheduler/app/server.go @@ -124,6 +124,7 @@ func (s *SchedulerServer) Run(_ []string) error { eventBroadcaster := record.NewBroadcaster() config.Recorder = eventBroadcaster.NewRecorder(api.EventSource{Component: "scheduler"}) + eventBroadcaster.StartLogging(glog.Infof) eventBroadcaster.StartRecordingToSink(kubeClient.Events("")) sched := scheduler.New(config)