Documentation
¶
Index ¶
- Constants
- Variables
- func CreateMergePatch(original, new interface{}) ([]byte, error)
- func GetPodGroupFullName(pg *v12.PodGroup) string
- func GetWaitTimeDuration(pg *v12.PodGroup, defaultMaxScheTime *time.Duration) time.Duration
- func VerifyPodAnnSatisfied(pod *v1.Pod) (string, bool)
- func VerifyPodLabelSatisfied(pod *v1.Pod) (string, bool)
Constants ¶
View Source
const ( // PodGroupAnn is not used now PodGroupAnn = "group.batch.scheduler.tencent.com" // PodGroupLabel is the default label of batch scheduler PodGroupLabel = "group.batch.scheduler.tencent.com" )
View Source
const DefaultWaitTime = 60 * time.Second
DefaultWaitTime is 60s if MaxScheduleTime is not specified.
Variables ¶
View Source
var ( // ErrorNotMatched means pod does not match batch scheduling ErrorNotMatched = fmt.Errorf("not match batch scheduling") // ErrorWaiting means pod number does not match the min pods required ErrorWaiting = fmt.Errorf("waiting") // ErrorResourceNotEnough means cluster resource is not enough, mainly used in Pre-Filter ErrorResourceNotEnough = fmt.Errorf("resource not enough") )
Functions ¶
func CreateMergePatch ¶
CreateMergePatch return patch generated from original and new interfaces
func GetPodGroupFullName ¶
GetPodGroupFullName verify if pod ann satisfies batch scheduling
func GetWaitTimeDuration ¶
GetWaitTimeDuration verify if pod ann satisfies batch scheduling
func VerifyPodAnnSatisfied ¶
VerifyPodAnnSatisfied verifies if pod ann satisfies batch scheduling
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.