kubernetes/vendor/go.etcd.io/etcd/server/v3/mvcc/watcher.go

var ErrWatcherNotExist …

var ErrEmptyWatcherRange …

var ErrWatcherDuplicateID …

type WatchID …

type FilterFunc …

type WatchStream …

type WatchResponse …

type watchStream …

// Watch creates a new watcher in the stream and returns its WatchID.
func (ws *watchStream) Watch(id WatchID, key, end []byte, startRev int64, fcs ...FilterFunc) (WatchID, error) { … }

func (ws *watchStream) Chan() <-chan WatchResponse { … }

func (ws *watchStream) Cancel(id WatchID) error { … }

func (ws *watchStream) Close() { … }

func (ws *watchStream) Rev() int64 { … }

func (ws *watchStream) RequestProgress(id WatchID) { … }

func (ws *watchStream) RequestProgressAll() bool { … }