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