kube_apis

package

v0.37.2-rc1 Latest Latest Go to latest Published: Jul 14, 2025 License: Apache-2.0 Imports: 17 Imported by: 0

Details

View Source

const (
	// Env variable key for Kubernetes node name
	POSTMAN_INSIGHTS_K8S_NODE = "POSTMAN_INSIGHTS_K8S_NODE"
)

This section is empty.

This section is empty.

type KubeClient struct {
	Clientset     *kubernetes.Clientset
	PodEventWatch *watchTool.RetryWatcher
	AgentNode     string
	AgentHost     string
}

KubeClient struct holds the Kubernetes clientset and event watcher

func NewKubeClient() (KubeClient, error)

NewKubeClient initializes a new Kubernetes client

func (kc *KubeClient) Close()

Close stops the event watcher

func (kc *KubeClient) FilterPodsByContainerImage(pods []coreV1.Pod, containerImage string, negate bool) ([]coreV1.Pod, error)

FilterPodsByContainerImage filters a list of pods by the container image name

func (kc *KubeClient) GetContainerUUIDs(pod coreV1.Pod) ([]string, error)

GetContainerUUIDs returns the UUIDs of all containers in a given pod

func (kc *KubeClient) GetPodsByUIDs(podUIDs []types.UID) ([]coreV1.Pod, error)

GetPods returns a list of pods running on the agent node with the given names

func (kc *KubeClient) GetPodsInAgentNode() ([]coreV1.Pod, error)

GetPodsInNode returns the names of all pods running in a given node

func (kc *KubeClient) GetPodsStatusByUIDs(podUIDs []types.UID) (maps.Map[types.UID, coreV1.PodPhase], error)

GetPodsStatus returns the statuses for list of pods