clusterutil

Documentation

Overview

Package clusterutil cluster utils

Index

• Constants
• func GenerateExecutorByCluster(cluster, executorType string) string
• func GenerateExecutorByClusterName(clustername string) string
• func SetJobExecutorByCluster(job *apistructs.Job) error
• func SetJobVolumeExecutorByCluster(jobvolume *apistructs.JobVolume) error
• func SetRuntimeExecutorByCluster(runtime *apistructs.ServiceGroup) error

Constants

const (
	// ServiceKindMarathon marathon executor type
	ServiceKindMarathon = "MARATHON"
	// ServiceKindK8S k8s executor type
	ServiceKindK8S = "K8S"
	// ServiceKindEdas edas executor type
	ServiceKindEdas = "EDAS"
	// JobKindMetronome metronome executor type
	JobKindMetronome = "METRONOME"
	// JobKindK8S k8s job executor type
	JobKindK8S = "K8SJOB"
	// EdasKindInK8s k8s service executor in edas
	EdasKindInK8s = "EDASINK8S"
	// DiceCluster DICE_CLUSTER env key
	DiceCluster = "DICE_CLUSTER"
	// k8sKindFlink Identify k8s flink type
	K8SKindFlink = "K8SFLINK"
	// k8sKindSpark Identify k8s spark type
	K8SKindSpark = "K8SSpark"
	// k8sSparkVersion Identify k8s flink version
	K8SSparkVersion = "2.4.0"
)

Functions

func GenerateExecutorByCluster

func GenerateExecutorByCluster(cluster, executorType string) string

GenerateExecutorByCluster Get executorname according to `cluster` and `executorType`

func GenerateExecutorByClusterName

func GenerateExecutorByClusterName(clustername string) string

func SetJobExecutorByCluster

func SetJobExecutorByCluster(job *apistructs.Job) error

SetJobExecutorByCluster When the job executor is empty, set the executor according to the cluster value

func SetJobVolumeExecutorByCluster

func SetJobVolumeExecutorByCluster(jobvolume *apistructs.JobVolume) error

func SetRuntimeExecutorByCluster

func SetRuntimeExecutorByCluster(runtime *apistructs.ServiceGroup) error

SetRuntimeExecutorByCluster When the runtime executor is empty, set the executor according to the cluster value