Method Lock

internal/lock/lock.go:87–99

Lock attempts to acquire the lock for the specified key with a timeout. If the lock is already held, it returns an error indicating the lock is unavailable. Parameters: - ctx: The context for managing the lock request lifecycle. - timeout: The time-to-live (TTL) for the lock. Returns an error if the

(ctx context.Context, timeout time.Duration)

// - timeout: The time-to-live (TTL) for the lock.
// Returns an error if the lock is already held or if there is a Redis error.
func (l *Locker) Lock(ctx context.Context, timeout time.Duration) error {
	success, err := l.client.SetNX(ctx, l.key, l.value, timeout).Result()
	if err != nil {
		return err
	}
	if !success {
		return &lockError{
			err: ErrLockHeld,
			msg: fmt.Sprintf("lock for key %s is already held", l.key),
		}
	}
	return nil
}

// Unlock releases the lock if the calling instance is the lock holder (based on the value).
// The operation is atomic, ensuring only the holder of the lock can release it.