Method AddJob

controller/mutators/etcd/job_mutator.go:148–186

AddJob adds a new job

(namespace string, job models.JobConfig)

// AddJob adds a new job
func (j *jobMutatorImpl) AddJob(namespace string, job models.JobConfig) error {
	err := common.Validate(&job, nil)
	if err != nil {
		return err
	}

	jobListProto, jobListVersion, err := readEntityList(j.etcdStore, utils.JobListKey(namespace))
	if err != nil {
		return err
	}

	jobProto := pb.EntityConfig{
		Name:      job.Name,
		Tomstoned: false,
	}
	jobVersion := kv.UninitializedVersion
	jobProto.Config, err = json.Marshal(job)
	if err != nil {
		return err
	}

	jobListProto, incarnation, exist := addEntity(jobListProto, jobProto.Name)
	if exist {
		return common.ErrJobConfigAlreadyExist
	}

	if incarnation > 0 {
		jobProto, jobVersion, err = j.readJob(namespace, job.Name)
		if err != nil {
			return err
		}
		jobProto.Tomstoned = false
	}

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

// GetHash returns hash that will be different if any job changed
func (j *jobMutatorImpl) GetHash(namespace string) (string, error) {