Clear resourceVersion on errors.

duda · Jan 12, 2015 · 6ad88bb · 6ad88bb
1 parent 21b661e
commit 6ad88bb
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/proxy/config/api.go b/pkg/proxy/config/api.go
@@ -127,9 +127,11 @@ func handleServicesWatch(resourceVersion *string, ch <-chan watch.Event, updates
 				service = obj
 			case *api.Status:
 				glog.Warningf("Got error status on WatchServices channel: %+v", obj)
+				*resourceVersion = ""
 				return
 			default:
 				glog.Errorf("Got unexpected object over WatchServices channel: %+v", obj)
+				*resourceVersion = ""
 				return
 			}
 
@@ -196,9 +198,11 @@ func handleEndpointsWatch(resourceVersion *string, ch <-chan watch.Event, update
 				endpoints = obj
 			case *api.Status:
 				glog.Warningf("Got error status on WatchEndpoints channel: %+v", obj)
+				*resourceVersion = ""
 				return
 			default:
 				glog.Errorf("Got unexpected object over WatchEndpoints channel: %+v", obj)
+				*resourceVersion = ""
 				return
 			}
 			*resourceVersion = endpoints.ResourceVersion