watchermanager

type Watcher[T1 any] interface {
	OnChange(watch.WatchEvent[T1]) bool
}

type WatcherManager[T1 any] interface {
	// start the generic watcher channel
	Start(ctx context.Context)
	Stop()
	WatchChan() chan watch.WatchEvent[T1]
	Add(ctx context.Context, callback Watcher[T1], opts ...store.ListOption) error // Del is handled with the isDone or callBackFn result
}