Method ExtendLock

internal/lock/lock.go:127–138

ExtendLock extends the TTL of the lock if the calling instance is the lock holder. This method ensures that the lock is renewed only by the lock holder. Parameters: - ctx: The context for managing the extension request. - extension: The additional time to extend the lock by. Returns an error if the

(ctx context.Context, extension time.Duration)

// Returns an error if the extension fails, either because the lock expired or
// the caller is not the lock holder.
func (l *Locker) ExtendLock(ctx context.Context, extension time.Duration) error {
	// Lua script ensures atomicity: checks the value and extends the TTL if the value matches.
	script := "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('pexpire', KEYS[1], ARGV[2]) else return 0 end"
	result, err := l.client.Eval(ctx, script, []string{l.key}, l.value, fmt.Sprintf("%d", extension.Milliseconds())).Result()
	if err != nil {
		return err
	}
	if result == int64(0) {
		return fmt.Errorf("lock extension failed for key %s, either lock expired or you're not the holder", l.key)
	}
	return nil
}

// WaitLock tries to acquire the lock within a specified waiting period.
// It will attempt to acquire the lock with exponential backoff if the lock is held by another process.