func()

in pkg/authenticator/ecrsecret.go [81:108]


func (s *ecrSecret) AddSecretToAllNamespace(ctx context.Context) error {
	cronjob, err := s.clientset.BatchV1().CronJobs(api.PackageNamespace).Get(ctx, cronJobName, metav1.GetOptions{})
	if err != nil {
		return err
	}

	if *cronjob.Spec.Suspend {
		return nil
	}

	jobSpec := &batchv1.Job{
		ObjectMeta: metav1.ObjectMeta{
			Name:      jobExecName + strconv.FormatInt(time.Now().UTC().UnixMilli(), 10),
			Namespace: api.PackageNamespace,
			Labels:    map[string]string{"createdBy": "controller"},
		},
		Spec: cronjob.Spec.JobTemplate.Spec,
	}

	jobs := s.clientset.BatchV1().Jobs(api.PackageNamespace)
	_, err = jobs.Create(ctx, jobSpec, metav1.CreateOptions{})
	if err != nil {
		return err
	}

	err = s.cleanupPrevRuns(ctx)
	return err
}