utils

Documentation

Index

• Variables
• func ISVKNode(n *corev1.Node) bool
• func IsDaemonSetPod(pod *corev1.Pod) bool
• func IsStsPod(pod *corev1.Pod) bool
• func IsWindowsOS() bool
• func Max(a, b int) int
• func Minimal(a int) int
• func NormalizePath(path string) string
• func PodSandboxExited(p *corev1.Pod) bool
• func RegisterClients(restConfig *rest.Config)
• func SetStsKinds(kids []string)
• func TrimStr(s string, l int) string

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 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 IsStsPod

func IsStsPod(pod *corev1.Pod) bool

IsStsPod pod is sts

func IsWindowsOS

func IsWindowsOS() bool

func Max

func Max(a, b int) int

func Minimal

func Minimal(a int) int

func NormalizePath

func NormalizePath(path string) string

NormalizePath returns the normal path in heterogeneous platform.

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