util

func AddWatcherDynamically ¶ added in v1.4.0

func AddWatcherDynamically(mgr manager.Manager, c controller.Controller, h handler.EventHandler, gvk schema.GroupVersionKind, controllerKey string) (bool, error)

func DiscoverGVK ¶ added in v1.4.0

func DiscoverGVK(gvk schema.GroupVersionKind) bool

func GetMessageKvFromCondition ¶ added in v1.5.0

func GetMessageKvFromCondition(condition *v1.PodCondition) (map[string]interface{}, error)

using pod condition message to get key-value pairs

func GetOrdinal ¶

func GetOrdinal(pod *corev1.Pod) int32

func GetTimeBeforePendingTimeout ¶ added in v1.8.0

func GetTimeBeforePendingTimeout(pod *v1.Pod, timeout time.Duration) (timeouted bool, nextCheckAfter time.Duration)

GetTimeBeforePendingTimeout return true when Pod was scheduled failed and timeout. nextCheckAfter > 0 means the pod is failed to schedule but not timeout yet.

func UpdateMessageKvCondition ¶ added in v1.5.0

func UpdateMessageKvCondition(kv map[string]interface{}, condition *v1.PodCondition)

using pod condition message to save key-value pairs