From e3eca8c63ce8e892d590b8b8d3e4dc7e00106e83 Mon Sep 17 00:00:00 2001
From: Paul Morie <pmorie@redhat.com>
Date: Tue, 27 Sep 2016 10:59:25 -0400
Subject: [PATCH] Add node event for container/image GC failure

---
 pkg/kubelet/events/event.go | 2 ++
 pkg/kubelet/kubelet.go      | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/pkg/kubelet/events/event.go b/pkg/kubelet/events/event.go
index 6107c715b03..634b393e327 100644
--- a/pkg/kubelet/events/event.go
+++ b/pkg/kubelet/events/event.go
@@ -55,6 +55,8 @@ const (
 	HostNetworkNotSupported = "HostNetworkNotSupported"
 	UndefinedShaper         = "NilShaper"
 	NodeRebooted            = "Rebooted"
+	ContainerGCFailed       = "ContainerGCFailed"
+	ImageGCFailed           = "ImageGCFailed"
 
 	// Image manager event reason list
 	InvalidDiskCapacity = "InvalidDiskCapacity"
diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go
index a52f257b2ef..41bb7ebe54c 100644
--- a/pkg/kubelet/kubelet.go
+++ b/pkg/kubelet/kubelet.go
@@ -1121,6 +1121,7 @@ func (kl *Kubelet) StartGarbageCollection() {
 	go wait.Until(func() {
 		if err := kl.containerGC.GarbageCollect(kl.sourcesReady.AllReady()); err != nil {
 			glog.Errorf("Container garbage collection failed: %v", err)
+			kl.recorder.Eventf(kl.nodeRef, api.EventTypeWarning, events.ContainerGCFailed, err.Error())
 			loggedContainerGCFailure = true
 		} else {
 			var vLevel glog.Level = 4
@@ -1137,6 +1138,7 @@ func (kl *Kubelet) StartGarbageCollection() {
 	go wait.Until(func() {
 		if err := kl.imageManager.GarbageCollect(); err != nil {
 			glog.Errorf("Image garbage collection failed: %v", err)
+			kl.recorder.Eventf(kl.nodeRef, api.EventTypeWarning, events.ImageGCFailed, err.Error())
 			loggedImageGCFailure = true
 		} else {
 			var vLevel glog.Level = 4