Method Start

workers/cache/cache.go:221–293

()

}

func (w *Worker) Start() error {
	slog.DebugContext(w.ctx, "starting cache worker")
	w.mux.Lock()
	defer w.mux.Unlock()

	if w.running {
		return nil
	}

	g, _ := errgroup.WithContext(w.ctx)

	g.Go(func() error {
		ctrlInfo, err := w.store.ControllerInfo()
		if err != nil {
			return fmt.Errorf("failed to get controller info: %w", err)
		}
		// CachedGARMAgentTools is now populated by the database layer during conversion
		cache.SetControllerCache(ctrlInfo)
		return nil
	})

	g.Go(func() error {
		if err := w.loadAllGithubCredentials(); err != nil {
			return fmt.Errorf("loading all github credentials: %w", err)
		}
		return nil
	})

	g.Go(func() error {
		if err := w.loadAllGiteaCredentials(); err != nil {
			return fmt.Errorf("loading all gitea credentials: %w", err)
		}
		return nil
	})

	g.Go(func() error {
		if err := w.loadAllEntities(); err != nil {
			return fmt.Errorf("loading all entities: %w", err)
		}
		return nil
	})

	g.Go(func() error {
		if err := w.loadAllInstances(); err != nil {
			return fmt.Errorf("loading all instances: %w", err)
		}
		return nil
	})

	if err := w.waitForErrorGroupOrContextCancelled(g); err != nil {
		return fmt.Errorf("waiting for error group: %w", err)
	}

	consumer, err := watcher.RegisterConsumer(
		w.ctx, w.consumerID,
		watcher.WithAll())
	if err != nil {
		return fmt.Errorf("registering consumer: %w", err)