kubernetes/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/v2v3/watcher.go

func (s *v2v3Store) Watch(prefix string, recursive, stream bool, sinceIndex uint64) (v2store.Watcher, error) { … }

func (s *v2v3Store) mkV2Events(wr clientv3.WatchResponse) (evs []*v2store.Event) { … }

func mkRevs(wr clientv3.WatchResponse) (revs [][]*clientv3.Event) { … }

type v2v3Watcher …

func (w *v2v3Watcher) StartIndex() uint64 { … }

func (w *v2v3Watcher) Remove() { … }

func (w *v2v3Watcher) EventChan() chan *v2store.Event { … }