Method WaitReady

watcher.go:19–26

(timeout time.Duration)

}

func (w *Watcher) WaitReady(timeout time.Duration) error {
	select {
	case <-w.readyCh:
		return nil
	case <-time.After(timeout):
		return errors.New("wait for watcher ready timeout")
	}
}

func (w *Watcher) Run() error {
	w.muReady.Lock()