Method UpdateJob

controller/mutators/etcd/job_mutator.go:114–145

UpdateJob updates job config

(namespace string, job models.JobConfig)

// UpdateJob updates job config
func (j *jobMutatorImpl) UpdateJob(namespace string, job models.JobConfig) (err error) {
	jobListProto, jobListVersion, err := readEntityList(j.etcdStore, utils.JobListKey(namespace))
	if err != nil {
		return err
	}

	jobListProto, found := updateEntity(jobListProto, job.Name)
	if !found {
		j.logger.With(
			"job", job,
		).Info("job not found for update, creating new job")
		return j.AddJob(namespace, job)
	}

	jobProto, jobVersion, err := j.readJob(namespace, job.Name)
	if err != nil {
		return err
	}
	if jobProto.Tomstoned {
		return common.ErrJobConfigDoesNotExist
	}
	jobProto.Tomstoned = false
	jobProto.Config, err = json.Marshal(job)
	if err != nil {
		return
	}

	return kvstore.NewTransaction().
		AddKeyValue(utils.JobListKey(namespace), jobListVersion, &jobListProto).
		AddKeyValue(utils.JobKey(namespace, job.Name), jobVersion, &jobProto).
		WriteTo(j.etcdStore)
}

// AddJob adds a new job
func (j *jobMutatorImpl) AddJob(namespace string, job models.JobConfig) error {