Function processPeriodicContainers

releng/config-forker/pkg/forker.go:362–418

(
	ctx context.Context,
	spec *v1.PodSpec,
	conf *config.JobConfig,
	util config.UtilityConfig,
	vars templateVars,
	annotation string,
	jobName string,
	resolver ImageResolver,
)

}

func processPeriodicContainers(
	ctx context.Context,
	spec *v1.PodSpec,
	conf *config.JobConfig,
	util config.UtilityConfig,
	vars templateVars,
	annotation string,
	jobName string,
	resolver ImageResolver,
) error {
	if spec == nil {
		return nil
	}

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

		var err error

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

		if !shouldDecorate(conf, util) {
			container.Command = fixBootstrapArgs(container.Command, vars.Version)
			container.Args = fixBootstrapArgs(container.Args, vars.Version)
		}

		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
}