From c6b96ecad82adb565615607f64a81b87c50a680a Mon Sep 17 00:00:00 2001
From: Rob Watson <rob@netflux.io>
Date: Mon, 20 Jun 2022 20:35:20 +0200
Subject: [PATCH] watcher: Add temporary panic-on-error handling

---
 logs/watcher.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/logs/watcher.go b/logs/watcher.go
index d6b3e78..3fb3253 100644
--- a/logs/watcher.go
+++ b/logs/watcher.go
@@ -134,6 +134,10 @@ func (w *Watcher) Watch(ctx context.Context) error {
 				w.watchResource(ctx, resource.GetUID(), labels.SelectorFromSet(selectorAsMap))
 			case watch.Deleted:
 				w.unwatchResource()
+			case watch.Error:
+				err := evt.Object.(error)
+				// TODO: remove panic and handle error
+				panic(err)
 			}
 		// errChan is never closed.
 		case err := <-w.errChan: