Function acquireLock

storage.go:308–316

(ctx context.Context, storage Storage, lockKey string)

}

func acquireLock(ctx context.Context, storage Storage, lockKey string) error {
	err := storage.Lock(ctx, lockKey)
	if err == nil {
		locksMu.Lock()
		locks[lockKey] = storage
		locksMu.Unlock()
	}
	return err
}

func tryAcquireLock(ctx context.Context, storage Storage, lockKey string) (bool, error) {
	locker, ok := storage.(TryLocker)