utils

func AlmostEqual ¶ added in v0.2.0

func AlmostEqual(a, b float64) bool

func CalculatePodRequests ¶

func CalculatePodRequests(pods []v1.Pod, resource v1.ResourceName) (int64, error)

CalculatePodRequests sum request total from pods

func ContainMaps ¶ added in v0.2.0

func ContainMaps(a map[string]string, b map[string]string) bool

ContainMaps to judge the maps b is contained by maps a

func ContainsString ¶

func ContainsString(slice []string, str string) bool

func EvictPodWithGracePeriod ¶

func EvictPodWithGracePeriod(client clientset.Interface, pod *v1.Pod, gracePeriodSeconds int32) error

EvictPodWithGracePeriod evict pod with grace period

func GetAddressAndDialer ¶

func GetAddressAndDialer(endpoint string) (string, func(ctx context.Context, addr string) (net.Conn, error), error)

GetAddressAndDialer returns the address parsed from the given endpoint and a context dialer.

func GetContainerIdFromKey ¶ added in v0.2.0

func GetContainerIdFromKey(key string) string

func GetInt32withDefault ¶

func GetInt32withDefault(i *int32, value int32) int32

func GetInt64withDefault ¶

func GetInt64withDefault(i *int64, value int64) int64

func GetNodeRef ¶

func GetNodeRef(nodeName string) *v1.ObjectReference

func GetPodCondition ¶

func GetPodCondition(status *v1.PodStatus, conditionType v1.PodConditionType) (int, *v1.PodCondition)

GetPodCondition extracts the provided condition from the given status and returns that. Returns nil and -1 if the condition is not present, and the index of the located condition. copied from k8s.io/kubernetes/pkg/api/v1/pod.go

func GetPodContainerByName ¶ added in v0.2.0

func GetPodContainerByName(pod *v1.Pod, containerName string) (v1.Container, error)

GetPodContainerByName get container info by container name

func GetPodReadyCondition ¶

func GetPodReadyCondition(status v1.PodStatus) *v1.PodCondition

GetPodReadyCondition extracts the pod ready condition from the given status and returns that. Returns nil if the condition is not present. copied from k8s.io/kubernetes/pkg/api/v1/pod.go

func GetPodsFromScale ¶

func GetPodsFromScale(kubeClient client.Client, scale *autoscalingapiv1.Scale) ([]v1.Pod, error)

func GetScale ¶

func GetScale(ctx context.Context, restMapper meta.RESTMapper, scaleClient scale.ScalesGetter, namespace string, ref autoscalingv2.CrossVersionObjectReference) (*autoscalingapiv1.Scale, *meta.RESTMapping, error)

func GetUint32withDefault ¶

func GetUint32withDefault(i *uint32, value uint32) uint32

func GetUint64FromMaps ¶

func GetUint64FromMaps(key string, maps map[string]uint64) uint64

func GetUint64withDefault ¶

func GetUint64withDefault(i *uint64, value uint64) uint64

func IsPodAvailable ¶

func IsPodAvailable(pod *v1.Pod, minReadySeconds int32, now metav1.Time) bool

IsPodAvailable returns true if a pod is available; false otherwise. copied from k8s.io/kubernetes/pkg/api/v1/pod.go

func IsPodReady ¶

func IsPodReady(pod *v1.Pod) bool

IsPodReady returns true if a pod is ready; false otherwise. copied from k8s.io/kubernetes/pkg/api/v1/pod.go

func KindForResource ¶ added in v0.2.0

func KindForResource(resource string, restMapper meta.RESTMapper) (string, error)

func LabelSelectorMatched ¶

func LabelSelectorMatched(maps map[string]string, selector *metav1.LabelSelector) (bool, error)

func ParseDuration ¶

func ParseDuration(s string) (time.Duration, error)

ParseDuration ParseDuration

func ParseFloat ¶

func ParseFloat(str string, defaultValue float64) (float64, error)

func RemoveNodeTaints ¶ added in v0.2.0

func RemoveNodeTaints(client clientset.Interface, nodeLister corelisters.NodeLister, nodeName string, taint v1.Taint, retry *uint64) (*v1.Node, error)

func UpdateNodeConditionsStatues ¶ added in v0.2.0

func UpdateNodeConditionsStatues(client clientset.Interface, nodeLister corelisters.NodeLister, nodeName string, condition v1.NodeCondition, retry *uint64) (*v1.Node, error)

UpdateNodeConditionsStatues be used to update node condition with check whether it needs to update

func UpdateNodeTaints ¶ added in v0.2.0

func UpdateNodeTaints(client clientset.Interface, nodeLister corelisters.NodeLister, nodeName string, taint v1.Taint, retry *uint64) (*v1.Node, error)

UpdateNodeTaints be used to update node taints with check whether it needs to update