Function processContainers

releng/config-forker/pkg/forker.go:209–262

processContainers applies env var fixes, image fixes, and replacement annotations to all containers in a pod spec. It returns an error wrapping the job name if any replacement fails.

(
	ctx context.Context,
	spec *v1.PodSpec,
	vars templateVars,
	annotation string,
	jobName string,
	resolver ImageResolver,
)

// annotations to all containers in a pod spec. It returns an error wrapping
// the job name if any replacement fails.
func processContainers(
	ctx context.Context,
	spec *v1.PodSpec,
	vars templateVars,
	annotation string,
	jobName string,
	resolver ImageResolver,
) error {
	if spec == nil {
		return nil
	}

	for idx := range spec.Containers {
		container := &spec.Containers[idx]
		container.Env = fixEnvVars(container.Env, vars.Version)
		container.Image = fixImage(container.Image, vars.Version)

		var err error

		container.Image, err = resolveImage(ctx, resolver, container.Image)
		if err != nil {
			return fmt.Errorf("%s: %w", jobName, err)
		}

		container.Command, err = performReplacement(
			container.Command, vars, annotation,
		)
		if err != nil {
			return fmt.Errorf("%s: %w", jobName, err)
		}

		container.Args, err = performReplacement(
			container.Args, vars, annotation,
		)
		if err != nil {
			return fmt.Errorf("%s: %w", jobName, err)
		}

		for envIdx := range container.Env {
			container.Env[envIdx].Name,
				container.Env[envIdx].Value,
				err = performEnvReplacement(
				container.Env[envIdx].Name,
				container.Env[envIdx].Value,
				vars, annotation,
			)
			if err != nil {
				return fmt.Errorf("%s: %w", jobName, err)
			}
		}
	}

	return nil
}

func generatePostsubmits(
	ctx context.Context,