Function Run

pkg/gator/bench/bench.go:44–128

Run executes the benchmark with the given options and returns results for each engine tested.

(opts *Opts)

// Run executes the benchmark with the given options and returns results
// for each engine tested.
func Run(opts *Opts) ([]Results, error) {
	// Warn if iterations are too low for meaningful P99 statistics
	if opts.Iterations < MinIterationsForP99 && opts.Writer != nil {
		fmt.Fprintf(opts.Writer, "Warning: %d iterations may not provide statistically meaningful P99 metrics. Consider using at least %d iterations.\n\n",
			opts.Iterations, MinIterationsForP99)
	}

	// Default concurrency to 1 (sequential)
	if opts.Concurrency < 1 {
		opts.Concurrency = 1
	}

	// Read all resources from files/images
	objs, err := reader.ReadSources(opts.Filenames, opts.Images, opts.TempDir)
	if err != nil {
		return nil, fmt.Errorf("reading sources: %w", err)
	}
	if len(objs) == 0 {
		return nil, fmt.Errorf("no input data identified")
	}

	// Categorize objects
	var templates []*unstructured.Unstructured
	var constraints []*unstructured.Unstructured
	var reviewObjs []*unstructured.Unstructured

	for _, obj := range objs {
		switch {
		case reader.IsTemplate(obj):
			templates = append(templates, obj)
		case reader.IsConstraint(obj):
			constraints = append(constraints, obj)
		default:
			// Everything else is a potential review object
			reviewObjs = append(reviewObjs, obj)
		}
	}

	if len(templates) == 0 {
		return nil, fmt.Errorf("no ConstraintTemplates found in input")
	}
	if len(constraints) == 0 {
		return nil, fmt.Errorf("no Constraints found in input")
	}
	if len(reviewObjs) == 0 {
		return nil, fmt.Errorf("no objects to review found in input")
	}

	var results []Results
	var warnings []string

	// Determine which engines to benchmark
	engines := []Engine{opts.Engine}
	if opts.Engine == EngineAll {
		engines = []Engine{EngineRego, EngineCEL}
	}

	for _, engine := range engines {