Method WaitLock

internal/lock/lock.go:147–172

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. Parameters: - ctx: The context for managing the wait request lifecycle. - lockTimeout: The TTL to set for the lock when acquired.

(ctx context.Context, lockTimeout, waitTimeout time.Duration)

// - waitTimeout: The maximum time to wait for the lock to become available.
// Returns an error if the lock could not be acquired within the wait timeout.
func (l *Locker) WaitLock(ctx context.Context, lockTimeout, waitTimeout time.Duration) error {
	if err := ctx.Err(); err != nil {
		return fmt.Errorf("lock wait cancelled for key %s: %w", l.key, err)
	}

	deadline := time.Now().Add(waitTimeout)
	for time.Now().Before(deadline) {
		err := l.Lock(ctx, lockTimeout)
		if err == nil {
			return nil
		}
		if !errors.Is(err, ErrLockHeld) {
			if ctxErr := ctx.Err(); ctxErr != nil {
				return fmt.Errorf("lock wait cancelled for key %s: %w", l.key, ctxErr)
			}
			return err
		}
		if err := sleepWithJitter(ctx, deadline); err != nil {
			return fmt.Errorf("lock wait cancelled for key %s: %w", l.key, err)
		}
	}
	return &lockError{
		err: ErrLockWaitTimeout,
		msg: fmt.Sprintf("failed to acquire lock for key %s within the wait timeout", l.key),
	}
}

// NewMultiLocker creates a new MultiLocker instance that manages locks for multiple keys.
// Keys are deduplicated and sorted lexicographically to ensure consistent lock ordering