k8s

Documentation

Index

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

Constants

const (
	NPLAnnotationKey          = "nodeportlocal.antrea.io"
	NPLEnabledAnnotationKey   = "nodeportlocal.antrea.io/enabled"
	NPLEnabledAnnotationIndex = "nplEnabledAnnotation"
)

Types

type NPLAnnotation

type NPLAnnotation struct {
	PodPort  int    `json:"podPort"`
	NodeIP   string `json:"nodeIP"`
	NodePort int    `json:"nodePort"`
}

NPLAnnotation is the structure used for setting NodePortLocal annotation on the Pods.

type NPLController

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

func NewNPLController

func NewNPLController(kubeClient clientset.Interface,
	podInformer cache.SharedIndexInformer,
	svcInformer cache.SharedIndexInformer,
	resyncPeriod time.Duration,
	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()