Documentation ¶
Index ¶
- func GenContainers(task *spec.PipelineTask) ([]apistructs.TaskContainer, error)
- func GenFlinkContainers(task *spec.PipelineTask) []apistructs.TaskContainer
- func GenSparkContainers(task *spec.PipelineTask) []apistructs.TaskContainer
- func GenTaskContainer(task *spec.PipelineTask) []apistructs.TaskContainer
- func MakeFlinkJobID(uuid string) string
- func MakeFlinkJobManagerID(uuid string) string
- func MakeFlinkJobManagerName(name string) string
- func MakeFlinkJobName(name string) string
- func MakeFlinkTaskManagerID(uuid string) string
- func MakeFlinkTaskManagerName(name string) string
- func MakeSparkTaskDriverID(uuid string) string
- func MakeSparkTaskDriverName(name string) string
- func MakeSparkTaskExecutorID(uuid string) string
- func MakeSparkTaskExecutorName(name string) string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GenContainers ¶
func GenContainers(task *spec.PipelineTask) ([]apistructs.TaskContainer, error)
func GenFlinkContainers ¶
func GenFlinkContainers(task *spec.PipelineTask) []apistructs.TaskContainer
func GenSparkContainers ¶
func GenSparkContainers(task *spec.PipelineTask) []apistructs.TaskContainer
func GenTaskContainer ¶
func GenTaskContainer(task *spec.PipelineTask) []apistructs.TaskContainer
func MakeFlinkJobID ¶
func MakeFlinkJobManagerID ¶
func MakeFlinkJobManagerName ¶
func MakeFlinkJobName ¶
func MakeFlinkTaskManagerID ¶
func MakeSparkTaskDriverID ¶
func MakeSparkTaskDriverName ¶
func MakeSparkTaskExecutorID ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.