common

Documentation

Index

• func CopyMap(to map[string]string, from map[string]string) map[string]string
• func DuplicateMap(o map[string]string) (r map[string]string)
• func GetEnvVar(envs []v1.EnvVar, name string) *v1.EnvVar
• func GetValidLabelNames() []contextutils.Key
• type FlinkDeployment

Functions

func CopyMap

func CopyMap(to map[string]string, from map[string]string) map[string]string

func DuplicateMap

func DuplicateMap(o map[string]string) (r map[string]string)

func GetEnvVar

func GetEnvVar(envs []v1.EnvVar, name string) *v1.EnvVar

func GetValidLabelNames

func GetValidLabelNames() []contextutils.Key

Types

type FlinkDeployment

type FlinkDeployment struct {
	Jobmanager  *appsv1.Deployment
	Taskmanager *appsv1.Deployment
	Hash        string
}