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
}