Add node event for container/image GC failure

pull/6/head
Paul Morie 2016-09-27 10:59:25 -04:00
parent 45723e0778
commit e3eca8c63c
2 changed files with 4 additions and 0 deletions

View File

@ -55,6 +55,8 @@ const (
HostNetworkNotSupported = "HostNetworkNotSupported" HostNetworkNotSupported = "HostNetworkNotSupported"
UndefinedShaper = "NilShaper" UndefinedShaper = "NilShaper"
NodeRebooted = "Rebooted" NodeRebooted = "Rebooted"
ContainerGCFailed = "ContainerGCFailed"
ImageGCFailed = "ImageGCFailed"
// Image manager event reason list // Image manager event reason list
InvalidDiskCapacity = "InvalidDiskCapacity" InvalidDiskCapacity = "InvalidDiskCapacity"

View File

@ -1121,6 +1121,7 @@ func (kl *Kubelet) StartGarbageCollection() {
go wait.Until(func() { go wait.Until(func() {
if err := kl.containerGC.GarbageCollect(kl.sourcesReady.AllReady()); err != nil { if err := kl.containerGC.GarbageCollect(kl.sourcesReady.AllReady()); err != nil {
glog.Errorf("Container garbage collection failed: %v", err) glog.Errorf("Container garbage collection failed: %v", err)
kl.recorder.Eventf(kl.nodeRef, api.EventTypeWarning, events.ContainerGCFailed, err.Error())
loggedContainerGCFailure = true loggedContainerGCFailure = true
} else { } else {
var vLevel glog.Level = 4 var vLevel glog.Level = 4
@ -1137,6 +1138,7 @@ func (kl *Kubelet) StartGarbageCollection() {
go wait.Until(func() { go wait.Until(func() {
if err := kl.imageManager.GarbageCollect(); err != nil { if err := kl.imageManager.GarbageCollect(); err != nil {
glog.Errorf("Image garbage collection failed: %v", err) glog.Errorf("Image garbage collection failed: %v", err)
kl.recorder.Eventf(kl.nodeRef, api.EventTypeWarning, events.ImageGCFailed, err.Error())
loggedImageGCFailure = true loggedImageGCFailure = true
} else { } else {
var vLevel glog.Level = 4 var vLevel glog.Level = 4