k8s

Documentation

Index

• Constants
• type NPLController
  • func NewNPLController(kubeClient clientset.Interface, podInformer cache.SharedIndexInformer, ...) *NPLController
  • func (c *NPLController) Run(stopCh <-chan struct{})
  • func (c *NPLController) Worker()

Constants

const NPLEnabledAnnotationIndex = "nplEnabledAnnotation"

Types

type NPLController

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

func NewNPLController

func NewNPLController(kubeClient clientset.Interface,
	podInformer cache.SharedIndexInformer,
	svcInformer cache.SharedIndexInformer,
	pt *portcache.PortTable,
	nodeName string) *NPLController

func (*NPLController) Run

func (c *NPLController) Run(stopCh <-chan struct{})

Run starts to watch and process Pod updates for the Node where Antrea Agent is running. It starts a queue and a fixed number of workers to process the objects from the queue.

func (*NPLController) Worker

func (c *NPLController) Worker()