utils

Documentation

Index

• Constants
• Variables
• func GetNodeCapabilities(capName string) string
• func ISVKNode(n *corev1.Node) bool
• func IsDaemonSetPod(pod *corev1.Pod) bool
• func IsFixedNamePod(pod *corev1.Pod) bool
• func IsWindowsOS() bool
• func NormalizePath(path string) string
• func PodInfoKey(namespace, name string) string
• func PodSandboxExited(p *corev1.Pod) bool
• func RegisterClients(restConfig *rest.Config)
• func SetStsKinds(kids []string)
• func TrimStr(s string, l int) string

Constants

const (
	NodeCapabilityERDMA = "erdma"
)

Variables

var APIExtensionsClient apiextensionsclient.Interface

APIExtensionsClient k8s client set

var (
	// DefaultPatchBackoff for patch status field
	DefaultPatchBackoff = wait.Backoff{
		Duration: 1 * time.Second,
		Steps:    3,
		Factor:   2,
		Jitter:   1.1,
	}
)

var K8sClient kubernetes.Interface

K8sClient k8s client set

var NetworkClient networkingclientset.Interface

NetworkClient network client set

Functions

func GetNodeCapabilities

func GetNodeCapabilities(capName string) string

func ISVKNode

func ISVKNode(n *corev1.Node) bool

ISVKNode node is run by virtual kubelet

func IsDaemonSetPod

func IsDaemonSetPod(pod *corev1.Pod) bool

IsDaemonSetPod pod is create by daemonSet

func IsFixedNamePod

func IsFixedNamePod(pod *corev1.Pod) bool

IsFixedNamePod pod is sts

func IsWindowsOS

func IsWindowsOS() bool

func NormalizePath

func NormalizePath(path string) string

NormalizePath returns the normal path in heterogeneous platform.

func PodInfoKey

func PodInfoKey(namespace, name string) string

func PodSandboxExited

func PodSandboxExited(p *corev1.Pod) bool

PodSandboxExited pod sandbox is exited

func RegisterClients

func RegisterClients(restConfig *rest.Config)

RegisterClients create all k8s clients

func SetStsKinds

func SetStsKinds(kids []string)

SetStsKinds set custom sts workload kinds

func TrimStr

func TrimStr(s string, l int) string

TrimStr witch len