code: func (p *Plan) Stop() {
  	p.stopLock.Lock()
  	defer p.stopLock.Unlock()
  	if p.stop {
  		return
  	}
  	p.stop = true
  	if p.cancelFunc != nil {
  		p.cancelFunc()
  	}
  	close(p.stopCh)
  }
docs: // Stop is used to stop running the watch plan