Merge pull request #6592 from vishh/kubelet_logging

cmd/kubelet/app/server.go

@@ -425,6 +425,7 @@ func RunKubelet(kcfg *KubeletConfig, builder KubeletBuilder) {
 	} else {
 		startKubelet(k, podCfg, kcfg)
 	}
+	glog.Infof("Started kubelet")
 }
 
 func startKubelet(k KubeletBootstrap, podCfg *config.PodConfig, kc *KubeletConfig) {

pkg/kubelet/kubelet.go

@@ -561,7 +561,7 @@ func (kl *Kubelet) syncNodeStatus() {
 	if kl.kubeClient == nil {
 		return
 	}
-
+	glog.Infof("Starting node status updates")
 	for feq := initialNodeStatusUpdateFrequency; feq < kl.nodeStatusUpdateFrequency; feq += nodeStatusUpdateFrequencyInc {
 		select {
 		case <-time.After(feq):
@@ -1628,6 +1628,7 @@ func (kl *Kubelet) handleNotFittingPods(pods []api.Pod) {
 // no changes are seen to the configuration, will synchronize the last known desired
 // state every sync_frequency seconds. Never returns.
 func (kl *Kubelet) syncLoop(updates <-chan PodUpdate, handler SyncHandler) {
+	glog.Info("Starting kubelet main sync loop.")
 	for {
 		unsyncedPod := false
 		podSyncTypes := make(map[types.UID]metrics.SyncPodType)

pkg/kubelet/server.go

@@ -60,7 +60,7 @@ type TLSOptions struct {
 
 // ListenAndServeKubeletServer initializes a server to respond to HTTP network requests on the Kubelet.
 func ListenAndServeKubeletServer(host HostInterface, address net.IP, port uint, tlsOptions *TLSOptions, enableDebuggingHandlers bool) {
-	glog.V(1).Infof("Starting to listen on %s:%d", address, port)
+	glog.Infof("Starting to listen on %s:%d", address, port)
 	handler := NewServer(host, enableDebuggingHandlers)
 	s := &http.Server{
 		Addr:           net.JoinHostPort(address.String(), strconv.FormatUint(uint64(port), 10)),

pkg/kubelet/status_manager.go

@@ -53,6 +53,7 @@ func newStatusManager(kubeClient client.Interface) *statusManager {
 
 func (s *statusManager) Start() {
 	// syncBatch blocks when no updates are available, we can run it in a tight loop.
+	glog.Info("Starting to sync pod status with apiserver")
 	go util.Forever(func() {
 		err := s.syncBatch()
 		if err != nil {