From a4869a5f0b2cd30f2a9910745fc9b3b3611bca02 Mon Sep 17 00:00:00 2001 From: miraclesu Date: Wed, 1 Mar 2017 20:17:02 +0800 Subject: [PATCH] =?UTF-8?q?node:=20=E4=BF=AE=E5=A4=8D=E5=88=A0=E9=99=A4=20?= =?UTF-8?q?key=20=E5=8F=82=E6=95=B0=E9=94=99=E8=AF=AF=E5=AF=BC=E8=87=B4?= =?UTF-8?q?=E5=88=A0=E9=94=99=20key=20=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- models/node.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/models/node.go b/models/node.go index 82c27e3..0e70743 100644 --- a/models/node.go +++ b/models/node.go @@ -36,13 +36,13 @@ func (n *Node) Put(opts ...client.OpOption) (*client.PutResponse, 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 // 存在则返回进行 pid，不存在返回 -1 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 { 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 _, 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 -1, nil