From d3faacd051b35248af76e9c58b0d6bd8dbdb4945 Mon Sep 17 00:00:00 2001 From: zqj <582132116@qq.com> Date: Tue, 29 Mar 2022 11:12:36 +0800 Subject: [PATCH] fix: update etcd --- common/etcd/etcd.go | 5 +++-- protos | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/common/etcd/etcd.go b/common/etcd/etcd.go index 9b848bd..4b1639a 100644 --- a/common/etcd/etcd.go +++ b/common/etcd/etcd.go @@ -40,7 +40,7 @@ func (e *EtcdClient) PutWithPrefix(prefix, key, val string) { func (e *EtcdClient) leaseKey(prefix, key, val string, ttl int64) (clientv3.LeaseID, error) { leaseResp, err := e.lease.Grant(context.TODO(), ttl) if err != nil { - logger.Error("PutWithLeasePrefix 设置租约时间失败:%v\n", err) + logger.Error("PutWithLeasePrefix leaseKey fail:%v\n", err) return 0, err } @@ -49,6 +49,7 @@ func (e *EtcdClient) leaseKey(prefix, key, val string, ttl int64) (clientv3.Leas logger.Error("PutWithLeasePrefix err: %v", err) return 0, err } + logger.Debug("lease key successful。。。") return leaseResp.ID, nil } @@ -80,7 +81,7 @@ func (e *EtcdClient) PutWithLeasePrefix(prefix, key, val string, ttl int64) erro select { case keepChan := <-keepRespChan: if keepChan == nil { - logger.Debug("租约已经失效") + logger.Debug("lease expire") leaseID = 0 break EXIT } else { diff --git a/protos b/protos index 5071be1..43bf509 160000 --- a/protos +++ b/protos @@ -1 +1 @@ -Subproject commit 5071be163d7bf5389320f21255f43f69ecf0166b +Subproject commit 43bf509f59c5aa87099fff52e0eeede70b0fe7d4 -- libgit2 0.21.2