Extend playback to watch events

controllers/events/playback.go

@@ -134,6 +134,21 @@ func playback(ctx context.Context, r *EventWatcher, filename string) error {
 			err = r.handleEvent(ctx, &ev)
 			mtime.NowReset()
 			return err
+		case "watch":
+			dec := yaml.NewYAMLToJSONDecoder(bytes.NewBuffer(doc))
+			var u unstructured.Unstructured
+			err := dec.Decode(&u)
+			if err != nil {
+				return fmt.Errorf("error parsing: %v", err)
+			}
+			mtime.NowForce(details.Timestamp)
+			wi, err := r.watcher.getWatch(&u)
+			if err != nil {
+				return err
+			}
+			err = wi.checkConditionUpdates(&u, r)
+			mtime.NowReset()
+			return err
 		default:
 			return fmt.Errorf("style not recognized: %q", string(details.Style))
 		}

controllers/events/watcher.go

@@ -98,6 +98,18 @@ func (m *watchManager) getResourceInterface(gvk schema.GroupVersionKind, ns stri
 	return m.client.Resource(mapping.Resource).Namespace(ns), nil
 }
 
+func (m *watchManager) getWatch(obj runtime.Object) (*watchInfo, error) {
+	ma, _ := meta.Accessor(obj)
+	ref := refFromObject(ma)
+	m.Lock()
+	wi := m.watches[ref]
+	m.Unlock()
+	if wi == nil {
+		return nil, fmt.Errorf("watcher not found for object %q", ref)
+	}
+	return wi, nil
+}
+
 func (w *watchInfo) run(ew eventNotifier) {
 	for e := range w.watch.ResultChan() {
 		obj, ok := e.Object.(*unstructured.Unstructured)