models

Documentation

Index

• Variables
• func K8sClientset(kubeConfPath string) (*kubernetes.Clientset, error)
• func K8sServerVersionQuery() (*version.Info, error)
• func PodsDelete(ctx context.Context, podNamespace, podName string) error
• func PodsList(ctx context.Context) (*v1.PodList, error)
• func PodsMapAdd(eventObject runtime.Object) *v1.Pod
• func PodsMapCopy() map[types.UID]*v1.Pod
• func PodsMapDel(eventObject runtime.Object) *v1.Pod
• func PodsWatch(ctx context.Context) (watch.Interface, error)

Variables

var PodsMap sync.Map

Functions

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