models

func K8sClientset ¶

func K8sClientset(kubeConfPath string) (*kubernetes.Clientset, error)

K8sClientset return the client of k8s

func K8sServerVersionQuery ¶

func K8sServerVersionQuery() (*version.Info, error)

K8sServerVersionQuery query the kubernetes api retrive the k8s info

func PodsDelete ¶

func PodsDelete(ctx context.Context, podNamespace, podName string) error

PodsDelete func

func PodsList ¶

func PodsList(ctx context.Context) (*v1.PodList, error)

PodsList return the Pods from k8s

func PodsMapAdd ¶

func PodsMapAdd(eventObject runtime.Object) *v1.Pod

func PodsMapCopy ¶

func PodsMapCopy() map[types.UID]*v1.Pod

func PodsMapDel ¶

func PodsMapDel(eventObject runtime.Object) *v1.Pod

func PodsWatch ¶

func PodsWatch(ctx context.Context) (watch.Interface, error)

PodsWatch return the watch pods events interface from k8s