logic

Documentation

Index

• Constants
• func BuildDcosConstraints(enable bool, labels map[string]string, preserveProjects map[string]struct{}, ...) [][]string
• func FollowContinue(initialOpts *metav1.ListOptions, ...) error
• 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 MakeJobName(task *spec.PipelineTask) string
• func MakeVolume(task *spec.PipelineTask) []diceyml.Volume
• func ParseJobHostBindTemplate(hostPath string, clusterInfo map[string]string) (string, error)
• func SearchEvents(client corev1client.EventsGetter, objOrRef runtime.Object) (*corev1.EventList, error)
• func TransferToSchedulerJob(task *spec.PipelineTask) (job apistructs.JobFromUser, err error)
• func WhichStorageClass(tp string) string

Constants

const (
	DefaultEventsLimit = 5
)

Functions

func BuildDcosConstraints

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

func FollowContinue

func FollowContinue(initialOpts *metav1.ListOptions,
	listFunc func(metav1.ListOptions) (runtime.Object, error)) error

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 MakeJobName

func MakeJobName(task *spec.PipelineTask) string

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 SearchEvents

func SearchEvents(client corev1client.EventsGetter, objOrRef runtime.Object) (*corev1.EventList, error)

SearchEvents finds events about the specified object.

func TransferToSchedulerJob

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

func WhichStorageClass

func WhichStorageClass(tp string) string