Method readJob

controller/mutators/etcd/job_mutator.go:193–199

(namespace string, name string)

}

func (j *jobMutatorImpl) readJob(namespace string, name string) (jobConfig pb.EntityConfig, version int, err error) {
	version, err = readValue(j.etcdStore, utils.JobKey(namespace, name), &jobConfig)
	if common.IsNonExist(err) {
		err = common.ErrJobConfigDoesNotExist
	}
	return
}