scottk/kubernetes
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/kubernetes.git synced 2025-11-04 04:08:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Handle cache/reflector errors when updating objects in store

Browse Source
This commit is contained in:
Nicolae Vartolomei
2016-11-30 14:35:21 +02:00
parent 09bb156116
commit c6733f1c9e
1 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
pkg/client/cache/reflector.go vendored
View File

@@ -363,14 +363,23 @@ loop:
newResourceVersion := meta.GetResourceVersion() newResourceVersion := meta.GetResourceVersion()
switch event.Type { switch event.Type {
case watch.Added: case watch.Added:
r.store.Add(event.Object) err := r.store.Add(event.Object)
if err != nil {
utilruntime.HandleError(fmt.Errorf("%s: unable to add watch event object (%#v) to store: %v", r.name, event.Object, err))
}
case watch.Modified: case watch.Modified:
r.store.Update(event.Object) err := r.store.Update(event.Object)
if err != nil {
utilruntime.HandleError(fmt.Errorf("%s: unable to update watch event object (%#v) to store: %v", r.name, event.Object, err))
}
case watch.Deleted: case watch.Deleted:
// TODO: Will any consumers need access to the "last known // TODO: Will any consumers need access to the "last known
// state", which is passed in event.Object? If so, may need // state", which is passed in event.Object? If so, may need
// to change this. // to change this.
r.store.Delete(event.Object) err := r.store.Delete(event.Object)
if err != nil {
utilruntime.HandleError(fmt.Errorf("%s: unable to delete watch event object (%#v) from store: %v", r.name, event.Object, err))
}
default: default:
utilruntime.HandleError(fmt.Errorf("%s: unable to understand watch event %#v", r.name, event)) utilruntime.HandleError(fmt.Errorf("%s: unable to understand watch event %#v", r.name, event))
} }