controlloop

Documentation

Index

• func PodInformerFactory(k8sClientSet kubernetes.Interface) (v1coreinformerfactory.SharedInformerFactory, error)
• type PodController
  • func NewPodController(k8sCoreClient kubernetes.Interface, wbClient wbclientset.Interface, ...) *PodController
  • func (pc *PodController) Shutdown()
  • func (pc *PodController) Start(stopChan <-chan struct{})

Functions

func PodInformerFactory

func PodInformerFactory(k8sClientSet kubernetes.Interface) (v1coreinformerfactory.SharedInformerFactory, error)

PodInformerFactory is a wrapper around NewSharedInformerFactoryWithOptions. Before returning the informer, it will extract the node name from environment variable "NODENAME". It will then try to look up the node with the given name. On success, it will create an informer that filters all pods with spec.nodeName == <value of env NODENAME>.

Types

type PodController

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

func NewPodController

func NewPodController(k8sCoreClient kubernetes.Interface, wbClient wbclientset.Interface, k8sCoreInformerFactory v1coreinformerfactory.SharedInformerFactory, wbSharedInformerFactory wbinformers.SharedInformerFactory, netAttachDefInformerFactory nadinformers.SharedInformerFactory, broadcaster record.EventBroadcaster, recorder record.EventRecorder) *PodController

NewPodController ...

func (*PodController) Shutdown

func (pc *PodController) Shutdown()

Shutdown stops the PodController worker queue

func (*PodController) Start

func (pc *PodController) Start(stopChan <-chan struct{})

Start runs worker thread after performing cache synchronization