Function NewMultiLocker

internal/lock/lock.go:182–208

NewMultiLocker creates a new MultiLocker instance that manages locks for multiple keys. Keys are deduplicated and sorted lexicographically to ensure consistent lock ordering across all callers, preventing deadlocks. Parameters: - client: A Redis universal client to interact with Redis. - keys: The k

(client redis.UniversalClient, keys []string, value string)

// - value: A unique value to associate with all locks (ensures lock ownership).
// Returns a pointer to a new MultiLocker instance.
func NewMultiLocker(client redis.UniversalClient, keys []string, value string) *MultiLocker {
	// Deduplicate keys
	seen := make(map[string]bool)
	uniqueKeys := make([]string, 0, len(keys))
	for _, key := range keys {
		if key != "" && !seen[key] {
			seen[key] = true
			uniqueKeys = append(uniqueKeys, key)
		}
	}

	// Sort keys lexicographically to ensure consistent ordering
	sort.Strings(uniqueKeys)

	// Create lockers for each key
	lockers := make([]*Locker, len(uniqueKeys))
	for i, key := range uniqueKeys {
		lockers[i] = NewLocker(client, key, value)
	}

	return &MultiLocker{
		client:  client,
		lockers: lockers,
		keys:    uniqueKeys,
		value:   value,
	}
}

// Lock attempts to acquire all locks in deterministic order.
// If any lock acquisition fails, all previously acquired locks are released (rollback).