Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + const DiceCluster + const EdasKindInK8s + const JobKindK8S + const JobKindMetronome + const K8SKindFlink + const K8SKindSpark + const K8SSparkVersion + const ServiceKindEdas + const ServiceKindK8S + const ServiceKindMarathon + func GenerateExecutorByCluster(cluster, executorType string) string + func GenerateExecutorByClusterName(clustername string) string + func GetExecuteConfigByExecutorName(name executortypes.Name) (string, *executorconfig.ExecutorConfig, error) + func SetJobExecutorByCluster(job *apistructs.Job) error + func SetJobVolumeExecutorByCluster(jobvolume *apistructs.JobVolume) error + func SetRuntimeExecutorByCluster(runtime *apistructs.ServiceGroup) error
Go to main page