Commit d3faacd051b35248af76e9c58b0d6bd8dbdb4945
1 parent
4255fd8e
fix: update etcd
Showing
2 changed files
with
4 additions
and
3 deletions
Show diff stats
common/etcd/etcd.go
| @@ -40,7 +40,7 @@ func (e *EtcdClient) PutWithPrefix(prefix, key, val string) { | @@ -40,7 +40,7 @@ func (e *EtcdClient) PutWithPrefix(prefix, key, val string) { | ||
| 40 | func (e *EtcdClient) leaseKey(prefix, key, val string, ttl int64) (clientv3.LeaseID, error) { | 40 | func (e *EtcdClient) leaseKey(prefix, key, val string, ttl int64) (clientv3.LeaseID, error) { |
| 41 | leaseResp, err := e.lease.Grant(context.TODO(), ttl) | 41 | leaseResp, err := e.lease.Grant(context.TODO(), ttl) |
| 42 | if err != nil { | 42 | if err != nil { |
| 43 | - logger.Error("PutWithLeasePrefix 设置租约时间失败:%v\n", err) | 43 | + logger.Error("PutWithLeasePrefix leaseKey fail:%v\n", err) |
| 44 | return 0, err | 44 | return 0, err |
| 45 | } | 45 | } |
| 46 | 46 | ||
| @@ -49,6 +49,7 @@ func (e *EtcdClient) leaseKey(prefix, key, val string, ttl int64) (clientv3.Leas | @@ -49,6 +49,7 @@ func (e *EtcdClient) leaseKey(prefix, key, val string, ttl int64) (clientv3.Leas | ||
| 49 | logger.Error("PutWithLeasePrefix err: %v", err) | 49 | logger.Error("PutWithLeasePrefix err: %v", err) |
| 50 | return 0, err | 50 | return 0, err |
| 51 | } | 51 | } |
| 52 | + logger.Debug("lease key successful。。。") | ||
| 52 | return leaseResp.ID, nil | 53 | return leaseResp.ID, nil |
| 53 | } | 54 | } |
| 54 | 55 | ||
| @@ -80,7 +81,7 @@ func (e *EtcdClient) PutWithLeasePrefix(prefix, key, val string, ttl int64) erro | @@ -80,7 +81,7 @@ func (e *EtcdClient) PutWithLeasePrefix(prefix, key, val string, ttl int64) erro | ||
| 80 | select { | 81 | select { |
| 81 | case keepChan := <-keepRespChan: | 82 | case keepChan := <-keepRespChan: |
| 82 | if keepChan == nil { | 83 | if keepChan == nil { |
| 83 | - logger.Debug("租约已经失效") | 84 | + logger.Debug("lease expire") |
| 84 | leaseID = 0 | 85 | leaseID = 0 |
| 85 | break EXIT | 86 | break EXIT |
| 86 | } else { | 87 | } else { |