(path string, data []byte)
| 229 | } |
| 230 | |
| 231 | func (c *Client) CreateEphemeral(path string, data []byte) (<-chan struct{}, error) { |
| 232 | c.Lock() |
| 233 | defer c.Unlock() |
| 234 | if c.closed { |
| 235 | return nil, errors.Trace(ErrClosedClient) |
| 236 | } |
| 237 | cntx, cancel := c.newContext() |
| 238 | defer cancel() |
| 239 | log.Debugf("etcd create-ephemeral node %s", path) |
| 240 | _, err := c.kapi.Set(cntx, path, string(data), &client.SetOptions{PrevExist: client.PrevNoExist, TTL: c.timeout}) |
| 241 | if err != nil { |
| 242 | log.Debugf("etcd create-ephemeral node %s failed: %s", path, err) |
| 243 | return nil, errors.Trace(err) |
| 244 | } |
| 245 | log.Debugf("etcd create-ephemeral OK") |
| 246 | return runRefreshEphemeral(c, path), nil |
| 247 | } |
| 248 | |
| 249 | func (c *Client) CreateEphemeralInOrder(path string, data []byte) (<-chan struct{}, string, error) { |
| 250 | c.Lock() |
nothing calls this directly
no test coverage detected