in pkg/preemptiontoleration/preemption_toleration_policy.go [55:83]
func parsePreemptionTolerationPolicy(
pc schedulingv1.PriorityClass,
) (*Policy, error) {
policy := &Policy{}
minimumPreemptablePriorityStr, ok := pc.Annotations[AnnotationKeyMinimumPreemptablePriority]
if !ok {
policy.MinimumPreemptablePriority = pc.Value + 1 // default value
} else {
minimumPreemptablePriority, err := strconv.ParseInt(minimumPreemptablePriorityStr, 10, 32)
if err != nil {
return nil, err
}
policy.MinimumPreemptablePriority = int32(minimumPreemptablePriority)
}
tolerationSecondsStr, ok := pc.Annotations[AnnotationKeyTolerationSeconds]
if !ok {
policy.TolerationSeconds = 0 // default value
} else {
tolerationSeconds, err := strconv.ParseInt(tolerationSecondsStr, 10, 64)
if err != nil {
return nil, err
}
policy.TolerationSeconds = tolerationSeconds
}
return policy, nil
}