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 { … }