k8sapi

Documentation

Overview

Package k8sapi contains logic to retrieve pods running on local node

Index

• Variables
• func CreateKubeClient() (clientset.Interface, error)
• type Controller
  • func NewController(clientset kubernetes.Interface) *Controller
  • func (d *Controller) DiscoverK8SPods()
  • func (d *Controller) GetCNIPods() []string
  • func (d *Controller) K8SGetLocalPodIPs() ([]*K8SPodInfo, error)
• type K8SAPIs
• type K8SPodInfo

Variables

var ErrInformerNotSynced = errors.New("discovery: informer not synced")

ErrInformerNotSynced indicates that it has not synced with API server yet

Functions

func CreateKubeClient

func CreateKubeClient() (clientset.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) DiscoverK8SPods

func (d *Controller) DiscoverK8SPods()

DiscoverK8SPods discovers Pods running in the cluster

func (*Controller) GetCNIPods

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

GetCNIPods return the list of CNI pod names

func (*Controller) K8SGetLocalPodIPs

func (d *Controller) K8SGetLocalPodIPs() ([]*K8SPodInfo, error)

K8SGetLocalPodIPs return the list of pods running on the local nodes

type K8SAPIs

type K8SAPIs interface {
	K8SGetLocalPodIPs() ([]*K8SPodInfo, 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
	// Container is pod's container id
	Container string
	// IP is pod's ipv4 address
	IP  string
	UID string
}

K8SPodInfo provides pod info