watchdog

Documentation

Index

• func GetActivePods() map[string]*v1.Pod
• func GetPod(namespace, name string) (*v1.Pod, error)
• func NewNodeLabeler(client v1core.CoreV1Interface, hostname string, labels map[string]string) *nodeLabeler
• func NewPodCache(client kubernetes.Interface, hostName string)
• func NewPodCacheForTest(client kubernetes.Interface)
• type PodCache
  • func (p *PodCache) OnAdd(obj interface{})
  • func (p *PodCache) OnDelete(obj interface{})
  • func (p *PodCache) OnUpdate(oldObj, newObj interface{})

Functions

func GetActivePods

func GetActivePods() map[string]*v1.Pod

GetActivePods get all active pods from podCache and returns them.

func GetPod

func GetPod(namespace, name string) (*v1.Pod, error)

func NewNodeLabeler

func NewNodeLabeler(client v1core.CoreV1Interface, hostname string, labels map[string]string) *nodeLabeler

NewNodeLabeler returns a new nodeLabeler

func NewPodCache

func NewPodCache(client kubernetes.Interface, hostName string)

NewPodCache creates a new podCache

func NewPodCacheForTest

func NewPodCacheForTest(client kubernetes.Interface)

NewPodCacheForTest creates a new podCache for testing

Types

type PodCache

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

PodCache contains a podInformer of pod

func (*PodCache) OnAdd

func (p *PodCache) OnAdd(obj interface{})

OnAdd is a callback function for podInformer, do nothing for now.

func (*PodCache) OnDelete

func (p *PodCache) OnDelete(obj interface{})

OnDelete is a callback function for podInformer, do nothing for now.

func (*PodCache) OnUpdate

func (p *PodCache) OnUpdate(oldObj, newObj interface{})

OnUpdate is a callback function for podInformer, do nothing for now.