Method Stop

runner/runner.go:635–699

()

}

func (r *Runner) Stop() error {
	r.mux.Lock()
	defer r.mux.Unlock()

	r.running = false
	if r.quit != nil {
		close(r.quit)
		r.quit = nil
	}

	repos, err := r.poolManagerCtrl.GetRepoPoolManagers()
	if err != nil {
		return fmt.Errorf("error fetching repo pool managers: %w", err)
	}

	orgs, err := r.poolManagerCtrl.GetOrgPoolManagers()
	if err != nil {
		return fmt.Errorf("error fetching org pool managers: %w", err)
	}

	enterprises, err := r.poolManagerCtrl.GetEnterprisePoolManagers()
	if err != nil {
		return fmt.Errorf("error fetching enterprise pool managers: %w", err)
	}

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

	for _, repo := range repos {
		poolMgr := repo
		g.Go(func() error {
			err := poolMgr.Stop()
			if err != nil {
				return fmt.Errorf("failed to stop repo pool manager: %w", err)
			}
			return poolMgr.Wait()
		})
	}

	for _, org := range orgs {
		poolMgr := org
		g.Go(func() error {
			err := poolMgr.Stop()
			if err != nil {
				return fmt.Errorf("failed to stop org pool manager: %w", err)
			}
			return poolMgr.Wait()
		})
	}

	for _, enterprise := range enterprises {
		poolMgr := enterprise
		g.Go(func() error {
			err := poolMgr.Stop()
			if err != nil {
				return fmt.Errorf("failed to stop enterprise pool manager: %w", err)
			}
			return poolMgr.Wait()
		})