Function Run

releng/config-forker/pkg/forker.go:110–160

Run reads the job config, generates forked jobs, and writes the output YAML.

(ctx context.Context, opts Options)

// Run reads the job config, generates forked jobs, and writes the output YAML.
func Run(ctx context.Context, opts Options) error {
	if err := opts.Validate(); err != nil {
		return err
	}

	jobConfig, err := config.ReadJobConfig(opts.JobConfig)
	if err != nil {
		return fmt.Errorf("reading job config: %w", err)
	}

	vars := templateVars{
		Version:   opts.Version,
		GoVersion: opts.GoVersion,
	}

	newPresubmits, err := generatePresubmits(ctx, jobConfig, vars, opts.ImageResolver)
	if err != nil {
		return fmt.Errorf("generating presubmits: %w", err)
	}

	newPeriodics, err := generatePeriodics(ctx, jobConfig, vars, opts.ImageResolver)
	if err != nil {
		return fmt.Errorf("generating periodics: %w", err)
	}

	newPostsubmits, err := generatePostsubmits(ctx, jobConfig, vars, opts.ImageResolver)
	if err != nil {
		return fmt.Errorf("generating postsubmits: %w", err)
	}

	gyaml.FutureLineWrap()

	output, err := yaml.Marshal(map[string]any{
		"periodics":   newPeriodics,
		"presubmits":  newPresubmits,
		"postsubmits": newPostsubmits,
	})
	if err != nil {
		return fmt.Errorf("marshaling output: %w", err)
	}

	if opts.OutputPath != "" {
		if err := os.WriteFile(
			opts.OutputPath, output, filePermissions,
		); err != nil {
			return fmt.Errorf("writing output: %w", err)
		}
	}

	return nil
}

const (
	forkAnnotation               = "fork-per-release"