jinql
/
cronsun
mirror of https://github.com/shunfei/cronsun
1
0
Fork 0
Code Issues Releases Wiki Activity

node: 修复删除 key 参数错误导致删错 key 的问题

pull/1/head
miraclesu 2017-03-01 20:17:02 +08:00
parent 501422d4b6
commit a4869a5f0b
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
models/node.go
View File

@ -36,13 +36,13 @@ func (n *Node) Put(opts ...client.OpOption) (*client.PutResponse, error) {
} }
func (n *Node) Del() (*client.DeleteResponse, error) { func (n *Node) Del() (*client.DeleteResponse, error) {
return DefalutClient.Delete(conf.Config.Proc+n.ID, client.WithFromKey()) return DefalutClient.Delete(conf.Config.Proc + n.ID)
} }
// 判断 node 是否已注册到 etcd // 判断 node 是否已注册到 etcd
// 存在则返回进行 pid，不存在返回 -1 // 存在则返回进行 pid，不存在返回 -1
func (n *Node) Exist() (pid int, err error) { func (n *Node) Exist() (pid int, err error) {
resp, err := DefalutClient.Get(conf.Config.Proc+n.ID, client.WithFromKey()) resp, err := DefalutClient.Get(conf.Config.Proc + n.ID)
if err != nil { if err != nil {
return return
} }
@ -52,7 +52,7 @@ func (n *Node) Exist() (pid int, err error) {
} }
if pid, err = strconv.Atoi(string(resp.Kvs[0].Value)); err != nil { if pid, err = strconv.Atoi(string(resp.Kvs[0].Value)); err != nil {
if _, err = DefalutClient.Delete(conf.Config.Proc+n.ID, client.WithFromKey()); err != nil { if _, err = DefalutClient.Delete(conf.Config.Proc + n.ID); err != nil {
return return
} }
return -1, nil return -1, nil