Method loadAllEntities

workers/cache/cache.go:92–162

()

}

func (w *Worker) loadAllEntities() error {
	endpoints, err := w.store.ListGiteaEndpoints(w.ctx)
	if err != nil {
		slog.ErrorContext(w.ctx, "failed to load gitea endpoints", "error", err)
	} else {
		for _, ep := range endpoints {
			cache.SetEndpoint(ep)
		}
	}

	endpoints, err = w.store.ListGithubEndpoints(w.ctx)
	if err != nil {
		slog.ErrorContext(w.ctx, "failed to load github endpoints", "error", err)
	} else {
		for _, ep := range endpoints {
			cache.SetEndpoint(ep)
		}
	}

	pools, err := w.store.ListAllPools(w.ctx)
	if err != nil {
		return fmt.Errorf("listing pools: %w", err)
	}

	scaleSets, err := w.store.ListAllScaleSets(w.ctx)
	if err != nil {
		return fmt.Errorf("listing scale sets: %w", err)
	}

	repos, err := w.store.ListRepositories(w.ctx, params.RepositoryFilter{})
	if err != nil {
		return fmt.Errorf("listing repositories: %w", err)
	}

	orgs, err := w.store.ListOrganizations(w.ctx, params.OrganizationFilter{})
	if err != nil {
		return fmt.Errorf("listing organizations: %w", err)
	}

	enterprises, err := w.store.ListEnterprises(w.ctx, params.EnterpriseFilter{})
	if err != nil {
		return fmt.Errorf("listing enterprises: %w", err)
	}

	for _, repo := range repos {
		if err := w.setCacheForEntity(repo, pools, scaleSets); err != nil {
			return fmt.Errorf("setting cache for repo: %w", err)
		}
	}

	for _, org := range orgs {
		if err := w.setCacheForEntity(org, pools, scaleSets); err != nil {
			return fmt.Errorf("setting cache for org: %w", err)
		}
	}

	for _, enterprise := range enterprises {
		if err := w.setCacheForEntity(enterprise, pools, scaleSets); err != nil {