k8sapi

Documentation

Overview

Package k8sapi contains logic to retrieve pods running on local node

Index

• func CreateKubeClient() (kubernetes.Interface, error)
• type Controller
  • func NewController(clientset kubernetes.Interface) *Controller
  • func (d *Controller) DiscoverCNIK8SPods()
  • func (d *Controller) DiscoverK8SPods(podListWatcher *cache.ListWatch)
  • func (d *Controller) GetCNIPods() []string
  • func (d *Controller) GetPod(podName, namespace string) (*v1.Pod, error)
  • func (d *Controller) SetNodeLabel(key, value string) error
• type K8SAPIs
• type K8SPodInfo

Functions

func CreateKubeClient

func CreateKubeClient() (kubernetes.Interface, error)

CreateKubeClient creates a k8s client

Types

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

Controller defines global context for discovery controller

func NewController

func NewController(clientset kubernetes.Interface) *Controller

NewController creates a new DiscoveryController

func (*Controller) DiscoverCNIK8SPods

func (d *Controller) DiscoverCNIK8SPods()

DiscoverCNIK8SPods discovers CNI pods, aws-node, running in the cluster

func (*Controller) DiscoverK8SPods

func (d *Controller) DiscoverK8SPods(podListWatcher *cache.ListWatch)

DiscoverK8SPods takes a watcher and updates the Controller cache

func (*Controller) GetCNIPods

func (d *Controller) GetCNIPods() []string

GetCNIPods return the list of CNI pod names

func (*Controller) GetPod

func (d *Controller) GetPod(podName, namespace string) (*v1.Pod, error)

func (*Controller) SetNodeLabel

func (d *Controller) SetNodeLabel(key, value string) error

type K8SAPIs

type K8SAPIs interface {
	SetNodeLabel(key, value string) error
	GetPod(podName, namespace string) (*v1.Pod, error)
}

K8SAPIs defines interface to use kubelet introspection API

type K8SPodInfo

type K8SPodInfo struct {
	// Name is pod's name
	Name string
	// Namespace is pod's namespace
	Namespace string
	// Sandbox is pod's sandbox id
	Sandbox string
	// IP is pod's ipv4 address
	IP  string
	UID string
}

K8SPodInfo provides pod info