If the server drops the connection, reestablish

watch.go

	// While we are supposed to be processing, make sure to reestablish the
	// client connection if anything unexpected happens.
	for processing {
		ch, err := client.Watch()
		if err != nil {
			glog.Error(err)
		} else {
			validChannel := true
			msg := Event{}

			// While a valid channel exists, read event messages and process them
			for validChannel {
				select {
				case msg, validChannel = <-ch:
					if !validChannel {
						glog.Warning("Channel closed by collector, restarting connection")
						break
					}

					err = HandleEvent(manager, msg)
					if err != nil {
						if glog.V(2) {
							glog.Error("Error handling event: ", err)
						}
					}
				case <-stopCh.WaitCh():
					// Something told us to stop, so shutdown the processing loop
					glog.Warning("k8s service received stop message")
					processing = false
					stopCh.Ack()
					break
				}
			}
		}
	}