Method List

pkg/models/etcd/etcdclient.go:203–229

(path string, must bool)

}

func (c *Client) List(path string, must bool) ([]string, error) {
	c.Lock()
	defer c.Unlock()
	if c.closed {
		return nil, errors.Trace(ErrClosedClient)
	}
	cntx, cancel := c.newContext()
	defer cancel()
	r, err := c.kapi.Get(cntx, path, &client.GetOptions{Quorum: true})
	switch {
	case err != nil:
		if isErrNoNode(err) && !must {
			return nil, nil
		}
		log.Debugf("etcd list node %s failed: %s", path, err)
		return nil, errors.Trace(err)
	case !r.Node.Dir:
		log.Debugf("etcd list node %s failed: not a dir", path)
		return nil, errors.Trace(ErrNotDir)
	default:
		var paths []string
		for _, node := range r.Node.Nodes {
			paths = append(paths, node.Key)
		}
		return paths, nil
	}
}

func (c *Client) CreateEphemeral(path string, data []byte) (<-chan struct{}, error) {
	c.Lock()