Documentation ¶
Index ¶
- Variables
- func AddQueue(sc *configs.SchedulerConfig, partition string, parentPathStr string, ...) error
- func CompareQueueMap(a map[string]interface{}, b map[string]interface{}) (bool, error)
- func CreateBasicConfigMap() *configs.SchedulerConfig
- func CreateJUnitReportDir() error
- func CreateLogFile(suiteName string, specName string, logType string, extension string) (*os.File, error)
- func CreateReportDirectory() (string, error)
- func GetAbsPath(p string) (string, error)
- func GetFileContents(filename string) ([]byte, error)
- func GetSubQueues(q map[string]interface{}) ([]map[string]interface{}, error)
- func GetSuiteName(testFilePath string) string
- func GetTestName() string
- func GetUUID() string
- func RandSeq(n int) string
- func ReportDirectoryPath() string
- func RunShellCmdForeground(cmdStr string) (string, error)
- func SetNodeSortPolicy(sc *configs.SchedulerConfig, partition string, ...) error
- func SetQueueTimestamp(sc *configs.SchedulerConfig, partition string, queuePathStr string) (string, error)
- func SetSchedulingPolicy(sc *configs.SchedulerConfig, partition string, queuePathStr string, ...) error
- func SliceExists(slice interface{}, item interface{}) (bool, error)
- func ToYAML(sc *configs.SchedulerConfig) (string, error)
- func Y2Map(yamlPath string) (map[interface{}]interface{}, error)
- func Yaml2Obj(yamlPath string) (runtime.Object, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ComputeNodeLabels = map[string]struct{}{
"compute": {},
}
View Source
var MasterTaints = map[string]struct{}{
"node-role.kubernetes.io/control-plane": {},
"node-role.kubernetes.io/master": {},
}
View Source
var RoleNodeLabel = "role"
Functions ¶
func AddQueue ¶ added in v1.1.0
func AddQueue(sc *configs.SchedulerConfig, partition string, parentPathStr string, newQ configs.QueueConfig) error
func CompareQueueMap ¶
Takes 2 restClient responses with queue information, and checks if they are the same by
- Validates queue name is same
- Validates qA and qB have same number of sub-queues 3a. If same queue name and 0 sub-queues, return true 3b. Otherwise, call CompareQueueMap on each child pairing of qA and qB
func CreateBasicConfigMap ¶
func CreateBasicConfigMap() *configs.SchedulerConfig
func CreateJUnitReportDir ¶ added in v1.3.0
func CreateJUnitReportDir() error
CreateDirectoryForJunitReports and returns the directory path If the directory cannot be created it'll return an error
func CreateLogFile ¶
func CreateReportDirectory ¶
CreateReportDirectory creates and returns the directory path If the directory cannot be created it'll return an error
func GetAbsPath ¶
func GetFileContents ¶
func GetSubQueues ¶
Returns a list of the children Q's of input. If no children, returns nil
func GetSuiteName ¶ added in v1.5.0
func GetTestName ¶
func GetTestName() string
GetTestName returns the test Name in a single string without spaces or /
func ReportDirectoryPath ¶
func ReportDirectoryPath() string
ReportDirectoryPath determines the directory path.
func RunShellCmdForeground ¶ added in v1.2.0
func SetNodeSortPolicy ¶ added in v1.1.0
func SetNodeSortPolicy(sc *configs.SchedulerConfig, partition string, policy configs.NodeSortingPolicy) error
func SetQueueTimestamp ¶ added in v1.1.0
func SetSchedulingPolicy ¶ added in v1.1.0
func SliceExists ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.