ridv/gorealis-v2
1
0
Fork 0
Code Issues Pull requests Projects Releases 13 Packages Wiki Activity Actions

Renaming function in job update to reduce ambiguity about which underlying object it is modifiying. Adding support for specifying ranges in updates as well as SLA Awareness.

Browse source
This commit is contained in:
Renan DelValle 2020-05-07 11:31:31 -07:00
parent ed81bcb28d
commit 96384e6fdc
No known key found for this signature in database
GPG key ID: C240AD6D6F443EC9
1 changed files with 14 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

16
jobUpdate.go
View file

@ -131,8 +131,20 @@ func (j *JobUpdate) VariableBatchStrategy(autoPause bool, batchSizes ...int32) *
return j
}
func newUpdateSettings() *aurora.JobUpdateSettings {
// SlaAware makes the scheduler enforce the SLA Aware policy if the job meets the SLA awareness criteria.
// By default, the scheduler will only apply SLA Awareness to jobs in the production tier with 20 or more instances.
func (j *JobUpdate) SlaAware(slaAware bool) *JobUpdate {
j.request.Settings.SlaAware = &slaAware
return j
}
// AddInstanceRange allows updates to only touch a certain specific range of instances
func (j *JobUpdate) AddInstanceRange(first, last int32) *JobUpdate {
j.request.Settings.UpdateOnlyTheseInstances = append(j.request.Settings.UpdateOnlyTheseInstances,
&aurora.Range{First: first, Last: last})
return j
}
func newUpdateSettings() *aurora.JobUpdateSettings {
us := aurora.JobUpdateSettings{}
// Mirrors defaults set by Pystachio
us.UpdateOnlyTheseInstances = []*aurora.Range{}
@ -198,7 +210,7 @@ func (j *JobUpdate) Tier(tier string) *JobUpdate {
return j
}
func (j *JobUpdate) MaxFailure(maxFail int32) *JobUpdate {
func (j *JobUpdate) TaskMaxFailure(maxFail int32) *JobUpdate {
j.task.MaxFailure(maxFail)
return j
}