Add event watching to deploy (#405)

* Add event watching to deploy

* Add comment

deploy/deploy.go

@@ -19,6 +19,7 @@ import (
 	dclient "github.com/docker/docker/client"
 	"github.com/openconfig/gnmi/errlist"
 	metallbclientv1 "github.com/openconfig/kne/api/metallb/clientset/v1beta1"
+	"github.com/openconfig/kne/events"
 	kexec "github.com/openconfig/kne/exec"
 	"github.com/openconfig/kne/load"
 	logshim "github.com/openconfig/kne/logshim"
@@ -280,6 +281,16 @@ func (d *Deployment) Deploy(ctx context.Context, kubecfg string) (rerr error) {
 			rerr = w.Cleanup(rerr)
 		}()
 	}
+	// Watch for incoming events to fail early in case of events signaling unrecoverable errors.
+	if w, err := events.NewWatcher(ctx, kClient, cancel); err != nil {
+		log.Warningf("Failed to start event watcher: %v", err)
+	} else {
+		w.SetProgress(d.Progress)
+		defer func() {
+			cancel()
+			rerr = w.Cleanup(rerr)
+		}()
+	}
 
 	d.Ingress.SetKClient(kClient)
 	d.Ingress.SetRCfg(rCfg)