util

Documentation

Index

• func BuildDcosConstraints(enable bool, labels map[string]string, preserveProjects map[string]struct{}, ...) [][]string
• func CombineLabels(parent, child map[string]string) map[string]string
• func GetClient(clusterName string, manageConfig *apistructs.ManageConfig) (string, *httpclient.HTTPClient, error)
• func GetDeployName(service *apistructs.Service) string
• func GetDiceWorkspaceFromEnvs(envs map[string]string) (apistructs.DiceWorkspace, error)
• func IsNotFound(err error) bool
• func ParseAnnotationFromEnv(k string) string
• func ParseEnableTagOption(options map[string]string, key string, defaultValue bool) (bool, error)
• func ParsePreserveProjects(options map[string]string, key string) map[string]struct{}
• func ParseServiceDependency(runtime *apistructs.ServiceGroup) ([][]*apistructs.Service, error)
• func VersionHas(c kubernetes.Interface, v string) (bool, error)

Functions

func BuildDcosConstraints

func BuildDcosConstraints(enable bool, labels map[string]string, preserveProjects map[string]struct{}, workspaceTags map[string]struct{}) [][]string

func CombineLabels

func CombineLabels(parent, child map[string]string) map[string]string

func GetClient

func GetClient(clusterName string, manageConfig *apistructs.ManageConfig) (string, *httpclient.HTTPClient, error)

GetClient get http client with cluster info.

func GetDeployName

func GetDeployName(service *apistructs.Service) string

func GetDiceWorkspaceFromEnvs

func GetDiceWorkspaceFromEnvs(envs map[string]string) (apistructs.DiceWorkspace, error)

func IsNotFound

func IsNotFound(err error) bool

func ParseAnnotationFromEnv

func ParseAnnotationFromEnv(k string) string

ParseAnnotationFromEnv TODO: get from service group

func ParseEnableTagOption

func ParseEnableTagOption(options map[string]string, key string, defaultValue bool) (bool, error)

func ParsePreserveProjects

func ParsePreserveProjects(options map[string]string, key string) map[string]struct{}

func ParseServiceDependency

func ParseServiceDependency(runtime *apistructs.ServiceGroup) ([][]*apistructs.Service, error)

func VersionHas

func VersionHas(c kubernetes.Interface, v string) (bool, error)