Method Refresh

redislock.go:250–268

Refresh extends the lock with a new TTL. May return ErrNotObtained if refresh is unsuccessful.

(ctx context.Context, ttl time.Duration, opt *Options)

// Refresh extends the lock with a new TTL.
// May return ErrNotObtained if refresh is unsuccessful.
func (l *Lock) Refresh(ctx context.Context, ttl time.Duration, opt *Options) error {
	if l == nil {
		return ErrNotObtained
	}
	ttlVal := strconv.FormatInt(int64(ttl/time.Millisecond), 10)

	return withRetry(ctx, ttl, opt.getRetryStrategy(), func(ctx context.Context) (bool, error) {
		_, err := luaRefresh.Run(ctx, l.client, l.keys, l.value, ttlVal).Result()
		if err == nil {
			return true, nil
		}
		if errors.Is(err, redis.Nil) {
			// the lock is no longer held by us; retrying cannot recover it.
			return true, ErrNotObtained
		}
		// transient error; allow the retry strategy to try again.
		return false, err
	})
}

// Release manually releases the lock.
// May return ErrLockNotHeld.