(path string)
| 105 | } |
| 106 | |
| 107 | func (c *Client) Mkdir(path string) error { |
| 108 | c.Lock() |
| 109 | defer c.Unlock() |
| 110 | if c.closed { |
| 111 | return errors.Trace(ErrClosedClient) |
| 112 | } |
| 113 | log.Debugf("etcd mkdir node %s", path) |
| 114 | cntx, cancel := c.newContext() |
| 115 | defer cancel() |
| 116 | _, err := c.kapi.Set(cntx, path, "", &client.SetOptions{Dir: true, PrevExist: client.PrevNoExist}) |
| 117 | if err != nil && !isErrNodeExists(err) { |
| 118 | log.Debugf("etcd mkdir node %s failed: %s", path, err) |
| 119 | return errors.Trace(err) |
| 120 | } |
| 121 | log.Debugf("etcd mkdir OK") |
| 122 | return nil |
| 123 | } |
| 124 | |
| 125 | func (c *Client) Create(path string, data []byte) error { |
| 126 | c.Lock() |
no test coverage detected