feat: add lock
parent
994478a00f
commit
13675c3e86
|
@ -54,8 +54,8 @@ func (r etcdLock) LockWithRetries(key string, unixTsToExpireNs int64) error {
|
||||||
log.INFO.Printf("acquired lock=%s failed, retries=%d, err=%s", key, i, err)
|
log.INFO.Printf("acquired lock=%s failed, retries=%d, err=%s", key, i, err)
|
||||||
time.Sleep(time.Millisecond * 100)
|
time.Sleep(time.Millisecond * 100)
|
||||||
}
|
}
|
||||||
return ErrRedisLockFailed
|
|
||||||
|
|
||||||
|
return ErrRedisLockFailed
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r etcdLock) Lock(key string, unixTsToExpireNs int64) error {
|
func (r etcdLock) Lock(key string, unixTsToExpireNs int64) error {
|
||||||
|
|
Loading…
Reference in New Issue