kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-05 18:05:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

nomad: using struct level validations

Browse Source
This commit is contained in:
Armon Dadgar
2015-09-15 11:25:48 -07:00
parent f4ade80f80
commit c1d05a8bd9
1 changed files with 2 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
nomad/job_endpoint.go
View File

@@ -24,26 +24,13 @@ func (j *Job) Register(args *structs.JobRegisterRequest, reply *structs.JobRegis
if args.Job == nil {
return fmt.Errorf("missing job for registration")
}
if args.Job.ID == "" {
return fmt.Errorf("missing job ID for registration")
}
if args.Job.Name == "" {
return fmt.Errorf("missing job name for registration")
}
if args.Job.Type == "" {
return fmt.Errorf("missing job type for registration")
if err := args.Job.Validate(); err != nil {
return err
}
if args.Job.Type == structs.JobTypeCore {
return fmt.Errorf("job type cannot be core")
}
// Ensure priorities are bounded
if args.Job.Priority < structs.JobMinPriority {
args.Job.Priority = structs.JobMinPriority
} else if args.Job.Priority > structs.JobMaxPriority {
args.Job.Priority = structs.JobMaxPriority
}
// Commit this update via Raft
_, index, err := j.srv.raftApply(structs.JobRegisterRequestType, args)
if err != nil {