k8s

Documentation

Index

• func BuildConfig(kubeconfig string) (*rest.Config, error)
• func GetNetworkingCondition(ctx context.Context, kubeClient kubernetes.Interface, nodeName string) v1.ConditionStatus
• func IsNodeNotReady(node *v1.Node) bool
• func IsNodeReady(node *v1.Node) bool
• func IsPodFinished(pod *v1.Pod) bool
• func IsStatefulSetPod(pod *v1.Pod) bool
• func NewCRDClient(kubeconfig string) (clientset.Interface, error)
• func NewKubeClient(kubeconfig string) (kubernetes.Interface, error)
• func UpdateNetworkingCondition(ctx context.Context, kubeClient kubernetes.Interface, nodeName string, ...) error

Functions

func BuildConfig

func BuildConfig(kubeconfig string) (*rest.Config, error)

func GetNetworkingCondition

func GetNetworkingCondition(
	ctx context.Context,
	kubeClient kubernetes.Interface,
	nodeName string,
) v1.ConditionStatus

func IsNodeNotReady

func IsNodeNotReady(node *v1.Node) bool

func IsNodeReady

func IsNodeReady(node *v1.Node) bool

func IsPodFinished

func IsPodFinished(pod *v1.Pod) bool

func IsStatefulSetPod

func IsStatefulSetPod(pod *v1.Pod) bool

func NewCRDClient

func NewCRDClient(kubeconfig string) (clientset.Interface, error)

NewCRDClient creates CRD client

func NewKubeClient

func NewKubeClient(kubeconfig string) (kubernetes.Interface, error)

NewKubeClient creates a k8s client

func UpdateNetworkingCondition

func UpdateNetworkingCondition(
	ctx context.Context,
	kubeClient kubernetes.Interface,
	nodeName string,
	networkReady bool,
	readyReason string,
	unReadyReason string,
	readyMsg string,
	unReadyMsg string,
) error