Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + const DefaultEventsLimit + func BuildDcosConstraints(enable bool, labels map[string]string, preserveProjects map[string]struct{}, ...) [][]string + func CreateInnerSecretIfNotExist(cs kubernetes.Interface, sourceNs, targetNs, secretName string) (bool, error) + func FollowContinue(initialOpts *metav1.ListOptions, ...) error + func GenTolerations() []apiv1.Toleration + func GenerateK8SVolumes(job *apistructs.JobFromUser, clusterInfo ...apistructs.ClusterInfoData) ([]corev1.Volume, []corev1.VolumeMount, []*corev1.PersistentVolumeClaim) + func GetAndSetTokenAuth(client *httpclient.HTTPClient, executorName string) + func GetBigDataConf(task *spec.PipelineTask) (apistructs.BigdataConf, error) + func GetDNSPolicy(podNetwork apistructs.PodNetwork) corev1.DNSPolicy + func GetPullImagePolicy() corev1.PullPolicy + func GetScheduleInfo(cluster apistructs.ClusterInfo, executorName, executorKind string, ...) (apistructs.ScheduleInfo2, apistructs.ScheduleInfo, error) + func JudgeExistedByStatus(statusDesc apistructs.PipelineStatusDesc) (created bool, started bool, err error) + func MakeJobLabelSelector(task *spec.PipelineTask) string + func MakeJobName(task *spec.PipelineTask) string + func MakeVolume(task *spec.PipelineTask) []diceyml.Volume + func ParseJobHostBindTemplate(hostPath string, clusterInfo apistructs.ClusterInfoData) (string, error) + func PrintTaskInfo(task *spec.PipelineTask) string + func SearchEvents(client corev1client.EventsGetter, objOrRef runtime.Object) (*corev1.EventList, error) + func TransferStatus(status string) apistructs.PipelineStatus + func TransferToSchedulerJob(task *spec.PipelineTask) (job apistructs.JobFromUser, err error) + func ValidateAction(action *spec.PipelineTask) error + func WhichStorageClass(tp string, vendor string) string + type ErrorWrapper struct + func NewErrorWrapper(name string) *ErrorWrapper + func (e *ErrorWrapper) WrapTaskError(err *error, op string, task *spec.PipelineTask)