logic

Documentation

Index

• func BuildDcosConstraints(enable bool, labels map[string]string, preserveProjects map[string]struct{}, ...) [][]string
• func GenTolerations() []apiv1.Toleration
• func GenerateK8SVolumes(job *apistructs.JobFromUser) ([]corev1.Volume, []corev1.VolumeMount, []*corev1.PersistentVolumeClaim)
• func GetAndSetTokenAuth(client *httpclient.HTTPClient, executorName string)
• func GetBigDataConf(task *spec.PipelineTask) (apistructs.BigdataConf, error)
• func GetCLusterInfo(clusterName string) (map[string]string, error)
• func GetScheduleInfo(cluster apistructs.ClusterInfo, executorName, executorKind string, ...) (apistructs.ScheduleInfo2, apistructs.ScheduleInfo, error)
• func MakeVolume(task *spec.PipelineTask) []diceyml.Volume
• func ParseJobHostBindTemplate(hostPath string, clusterInfo map[string]string) (string, error)
• func TransferToSchedulerJob(task *spec.PipelineTask) (job apistructs.JobFromUser, err error)
• func WhichStorageClass(tp string) string

Functions

func BuildDcosConstraints

func BuildDcosConstraints(enable bool, labels map[string]string, preserveProjects map[string]struct{}, workspaceTags map[string]struct{}) [][]string

func GenTolerations

func GenTolerations() []apiv1.Toleration

func GenerateK8SVolumes

func GenerateK8SVolumes(job *apistructs.JobFromUser) ([]corev1.Volume, []corev1.VolumeMount, []*corev1.PersistentVolumeClaim)

GenerateK8SVolumes According to job configuration, production volume related configuration

func GetAndSetTokenAuth

func GetAndSetTokenAuth(client *httpclient.HTTPClient, executorName string)

GetAndSetTokenAuth call this in goroutine

func GetBigDataConf

func GetBigDataConf(task *spec.PipelineTask) (apistructs.BigdataConf, error)

func GetCLusterInfo

func GetCLusterInfo(clusterName string) (map[string]string, error)

func GetScheduleInfo

func GetScheduleInfo(cluster apistructs.ClusterInfo, executorName, executorKind string, jobFromUser apistructs.JobFromUser) (apistructs.ScheduleInfo2, apistructs.ScheduleInfo, error)

func MakeVolume

func MakeVolume(task *spec.PipelineTask) []diceyml.Volume

func ParseJobHostBindTemplate

func ParseJobHostBindTemplate(hostPath string, clusterInfo map[string]string) (string, error)

ParseJobHostBindTemplate Analyze the hostPath template and convert it to the cluster info value

func TransferToSchedulerJob

func TransferToSchedulerJob(task *spec.PipelineTask) (job apistructs.JobFromUser, err error)

func WhichStorageClass

func WhichStorageClass(tp string) string