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

spelling: reschedule

Browse Source
This commit is contained in:
Josh Soref
2018-03-11 18:50:50 +00:00
parent 0cc21f8c57
commit 667cf5dc00
2 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
nomad/structs/structs.go
View File

@@ -2705,7 +2705,7 @@ func (r *ReschedulePolicy) Validate() error {
return nil
}
func NewReshedulePolicy(jobType string) *ReschedulePolicy {
func NewReschedulePolicy(jobType string) *ReschedulePolicy {
switch jobType {
case JobTypeService:
rp := DefaultServiceJobReschedulePolicy
@@ -2794,7 +2794,7 @@ func (tg *TaskGroup) Canonicalize(job *Job) {
}
if tg.ReschedulePolicy == nil {
tg.ReschedulePolicy = NewReshedulePolicy(job.Type)
tg.ReschedulePolicy = NewReschedulePolicy(job.Type)
}
// Set a default ephemeral disk object if the user has not requested for one

16
nomad/structs/structs_test.go
View File

@@ -193,7 +193,7 @@ func TestJob_Canonicalize_Update(t *testing.T) {
Name: "foo",
Count: 2,
RestartPolicy: NewRestartPolicy(JobTypeService),
ReschedulePolicy: NewReshedulePolicy(JobTypeService),
ReschedulePolicy: NewReschedulePolicy(JobTypeService),
EphemeralDisk: DefaultEphemeralDisk(),
Update: &UpdateStrategy{
Stagger: 30 * time.Second,
@@ -234,7 +234,7 @@ func TestJob_Canonicalize_Update(t *testing.T) {
Name: "foo",
Count: 2,
RestartPolicy: NewRestartPolicy(JobTypeBatch),
ReschedulePolicy: NewReshedulePolicy(JobTypeBatch),
ReschedulePolicy: NewReschedulePolicy(JobTypeBatch),
EphemeralDisk: DefaultEphemeralDisk(),
},
},
@@ -278,7 +278,7 @@ func TestJob_Canonicalize_Update(t *testing.T) {
Name: "foo",
Count: 2,
RestartPolicy: NewRestartPolicy(JobTypeBatch),
ReschedulePolicy: NewReshedulePolicy(JobTypeBatch),
ReschedulePolicy: NewReschedulePolicy(JobTypeBatch),
EphemeralDisk: DefaultEphemeralDisk(),
},
},
@@ -328,7 +328,7 @@ func TestJob_Canonicalize_Update(t *testing.T) {
Name: "foo",
Count: 2,
RestartPolicy: NewRestartPolicy(JobTypeService),
ReschedulePolicy: NewReshedulePolicy(JobTypeService),
ReschedulePolicy: NewReschedulePolicy(JobTypeService),
EphemeralDisk: DefaultEphemeralDisk(),
Update: &UpdateStrategy{
Stagger: 2 * time.Second,
@@ -371,7 +371,7 @@ func TestJob_Canonicalize_Update(t *testing.T) {
Name: "foo",
Count: 2,
RestartPolicy: NewRestartPolicy(JobTypeService),
ReschedulePolicy: NewReshedulePolicy(JobTypeService),
ReschedulePolicy: NewReschedulePolicy(JobTypeService),
EphemeralDisk: DefaultEphemeralDisk(),
Update: &UpdateStrategy{
Stagger: 30 * time.Second,
@@ -423,7 +423,7 @@ func TestJob_Canonicalize_Update(t *testing.T) {
Name: "foo",
Count: 2,
RestartPolicy: NewRestartPolicy(JobTypeService),
ReschedulePolicy: NewReshedulePolicy(JobTypeService),
ReschedulePolicy: NewReschedulePolicy(JobTypeService),
EphemeralDisk: DefaultEphemeralDisk(),
Update: &UpdateStrategy{
Stagger: 30 * time.Second,
@@ -439,7 +439,7 @@ func TestJob_Canonicalize_Update(t *testing.T) {
Name: "bar",
Count: 14,
RestartPolicy: NewRestartPolicy(JobTypeService),
ReschedulePolicy: NewReshedulePolicy(JobTypeService),
ReschedulePolicy: NewReschedulePolicy(JobTypeService),
EphemeralDisk: DefaultEphemeralDisk(),
Update: &UpdateStrategy{
Stagger: 30 * time.Second,
@@ -456,7 +456,7 @@ func TestJob_Canonicalize_Update(t *testing.T) {
Count: 26,
EphemeralDisk: DefaultEphemeralDisk(),
RestartPolicy: NewRestartPolicy(JobTypeService),
ReschedulePolicy: NewReshedulePolicy(JobTypeService),
ReschedulePolicy: NewReschedulePolicy(JobTypeService),
Update: &UpdateStrategy{
Stagger: 30 * time.Second,
MaxParallel: 3,