Method startWatch

watcher.go:164–186

startWatch is a goroutine that watches the policy change.

()

// startWatch is a goroutine that watches the policy change.
func (w *Watcher) startWatch() error {
	watcher := w.client.Watch(context.Background(), w.keyName)
	for res := range watcher {
		// Skip progress notifications
		if res.IsProgressNotify() {
			continue
		}
		// Skip empty events
		if len(res.Events) == 0 {
			continue
		}
		t := res.Events[0]
		if t.IsCreate() || t.IsModify() {
			w.lock.RLock()
			//ignore self update
			if rev := t.Kv.ModRevision; rev > w.lastSentRev && w.callback != nil {
				w.callback(strconv.FormatInt(rev, 10))
			}
			w.lock.RUnlock()
		}
	}
	return nil
}