containers

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 15, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

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 MakeFlinkJobID(uuid string) string

func MakeFlinkJobManagerID

func MakeFlinkJobManagerID(uuid string) string

func MakeFlinkJobManagerName

func MakeFlinkJobManagerName(name string) string

func MakeFlinkJobName

func MakeFlinkJobName(name string) string

func MakeFlinkTaskManagerID

func MakeFlinkTaskManagerID(uuid string) string

func MakeFlinkTaskManagerName

func MakeFlinkTaskManagerName(name string) string

func MakeSparkTaskDriverID

func MakeSparkTaskDriverID(uuid string) string

func MakeSparkTaskDriverName

func MakeSparkTaskDriverName(name string) string

func MakeSparkTaskExecutorID

func MakeSparkTaskExecutorID(uuid string) string

func MakeSparkTaskExecutorName

func MakeSparkTaskExecutorName(name string) string

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL