Function FillNarInfoCache

internal/devpkg/narinfo_cache.go:59–93

FillNarInfoCache checks the remote binary cache for the narinfo of each package in the list, and caches the result. Callers of IsInBinaryCache may call this function first as a perf-optimization.

(ctx context.Context, packages ...*Package)

// package in the list, and caches the result.
// Callers of IsInBinaryCache may call this function first as a perf-optimization.
func FillNarInfoCache(ctx context.Context, packages ...*Package) error {
	defer debug.FunctionTimer().End()

	eligiblePackages := []*Package{}
	for _, p := range packages {
		// IMPORTANT: isEligibleForBinaryCache will call resolve() which is NOT
		// concurrency safe. Hence, we call it outside of the go-routine.
		isEligible, err := p.isEligibleForBinaryCache()
		// If the package is not eligible or there is an error in determining that, then skip it.
		if isEligible && err == nil {
			eligiblePackages = append(eligiblePackages, p)
		}
	}
	if len(eligiblePackages) == 0 {
		return nil
	}

	group, _ := errgroup.WithContext(ctx)
	for _, p := range eligiblePackages {
		pkg := p // copy the loop variable since its used in a closure below
		outputNames, err := pkg.GetOutputNames()
		if err != nil {
			return err
		}

		for _, outputName := range outputNames {
			name := outputName
			group.Go(func() error {
				_, err := pkg.fetchNarInfoStatusOnce(name)
				return err
			})
		}
	}
	return group.Wait()
}

// areExpectedOutputsInCacheOnce wraps fetchNarInfoStatusOnce and returns true
// if the expected outputs are in the cache.