k8s

Documentation

Index

• func SetupK8sHelper(kubeConfigFilePath string)
• type Helper
  • func (k *Helper) GetCurrentNodePods() ([]*rpc.PodInfo, error)
  • func (k *Helper) GetPodInfo(namespace, name string) (*rpc.PodInfo, error)

Functions

func SetupK8sHelper

func SetupK8sHelper(kubeConfigFilePath string)

Types

type Helper

type Helper struct {
	NodeName string
	Client   *k8sclient.ClientInfo

	PodEvent record.EventRecorder
	Mgr      manager.Manager
}

var (
	K8sHelper *Helper
)

func (*Helper) GetCurrentNodePods

func (k *Helper) GetCurrentNodePods() ([]*rpc.PodInfo, error)

GetCurrentNodePods return the list of pods running on the local nodes

func (*Helper) GetPodInfo

func (k *Helper) GetPodInfo(namespace, name string) (*rpc.PodInfo, error)