util

Documentation

Index

• func CreateMergePatch(original, new interface{}) ([]byte, error)
• func GetGangGroupId(s []string) string
• func GetGangMatchPolicyByPod(pod *v1.Pod) string
• func GetGangMinNumFromPod(pod *v1.Pod) (minNum int, err error)
• func GetGangNameByPod(pod *v1.Pod) string
• func GetId(namespace, name string) string
• func GetWaitTimeDuration(pg *v1alpha1.PodGroup, defaultTimeout time.Duration) time.Duration
• func IsPodNeedGang(pod *v1.Pod) bool
• func StringToGangGroupSlice(s string) ([]string, error)

Functions

func CreateMergePatch

func CreateMergePatch(original, new interface{}) ([]byte, error)

CreateMergePatch return patch generated from original and new interfaces

func GetGangGroupId

func GetGangGroupId(s []string) string

func GetGangMatchPolicyByPod

func GetGangMatchPolicyByPod(pod *v1.Pod) string

func GetGangMinNumFromPod

func GetGangMinNumFromPod(pod *v1.Pod) (minNum int, err error)

func GetGangNameByPod

func GetGangNameByPod(pod *v1.Pod) string

func GetId

func GetId(namespace, name string) string

func GetWaitTimeDuration

func GetWaitTimeDuration(pg *v1alpha1.PodGroup, defaultTimeout time.Duration) time.Duration

GetWaitTimeDuration returns a wait timeout based on the following precedences: 1. spec.scheduleTimeoutSeconds of the given pg, if specified 2. fall back to defaultTimeout

func IsPodNeedGang

func IsPodNeedGang(pod *v1.Pod) bool

func StringToGangGroupSlice

func StringToGangGroupSlice(s string) ([]string, error)

StringToGangGroupSlice Parse gang group's annotation like :"["nsA/gangA","nsB/gangB"]" => goLang slice : []string{"nsA/gangA"."nsB/gangB"}