Method WatchInOrder

pkg/models/etcd/etcdclient.go:301–345

(path string)

}

func (c *Client) WatchInOrder(path string) (<-chan struct{}, []string, error) {
	if err := c.Mkdir(path); err != nil {
		return nil, nil, err
	}
	c.Lock()
	defer c.Unlock()
	if c.closed {
		return nil, nil, errors.Trace(ErrClosedClient)
	}
	log.Debugf("etcd watch-inorder node %s", path)
	cntx, cancel := c.newContext()
	defer cancel()
	r, err := c.kapi.Get(cntx, path, &client.GetOptions{Quorum: true, Sort: true})
	switch {
	case err != nil:
		log.Debugf("etcd watch-inorder node %s failed: %s", path, err)
		return nil, nil, errors.Trace(err)
	case !r.Node.Dir:
		log.Debugf("etcd watch-inorder node %s failed: not a dir", path)
		return nil, nil, errors.Trace(ErrNotDir)
	}
	var index = r.Index
	var paths []string
	for _, node := range r.Node.Nodes {
		paths = append(paths, node.Key)
	}
	signal := make(chan struct{})
	go func() {
		defer close(signal)
		watch := c.kapi.Watcher(path, &client.WatcherOptions{AfterIndex: index})
		for {
			r, err := watch.Next(c.context)
			switch {
			case err != nil:
				log.Debugf("etch watch-inorder node %s failed: %s", path, err)
				return
			case r.Action != "get":
				log.Debugf("etcd watch-inorder node %s update", path)
				return
			}
		}
	}()
	log.Debugf("etcd watch-inorder OK")
	return signal, paths, nil
}