Recover from unexpected EOF with API Server

Signed-off-by: Waldemar Quevedo <[email protected]>

pkg/controller/controller.go

@@ -281,7 +281,9 @@ func (c *Controller) watch(watchVersion string) (<-chan *Event, <-chan error) {
 			for {
 				ev, st, err := pollEvent(decoder)
 				if err != nil {
-					if err == io.EOF { // apiserver will close stream periodically
+					// API Server will close stream periodically so schedule a reconnect,
+					// also recover in connection was broken for some reason.
+					if err == io.EOF || err == io.ErrUnexpectedEOF {
 						c.logger.Info("apiserver closed watch stream, retrying after 5s...")
 						time.Sleep(5 * time.Second)
 						break

pkg/controller/util.go

@@ -35,9 +35,10 @@ func pollEvent(decoder *json.Decoder) (*Event, *metav1.Status, error) {
 	re := &rawEvent{}
 	err := decoder.Decode(re)
 	if err != nil {
-		if err == io.EOF {
+		if err == io.EOF || err == io.ErrUnexpectedEOF {
 			return nil, nil, err
 		}
+
 		return nil, nil, fmt.Errorf("fail to decode raw event from apiserver (%v)", err)
 	}