watchdog

Documentation

Index

• Constants
• func GetActivePods() map[string]*v1.Pod
• 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{})

Constants

const (
	//PodResource is a literal for pod resource
	PodResource = "pods"
)

Functions

func GetActivePods

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

GetActivePods get all active pods from podCache and returns them.

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 informer, do nothing for now.

func (*PodCache) OnDelete

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

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

func (*PodCache) OnUpdate

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

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