nodeportlocal

Documentation

Index

• func InitController(kubeClient clientset.Interface, ...) (*nplk8s.NPLController, error)
• func InitializeNPLAgent(kubeClient clientset.Interface, ...) (*nplk8s.NPLController, error)

Functions

func InitController

func InitController(kubeClient clientset.Interface, informerFactory informers.SharedInformerFactory, portTable *portcache.PortTable, nodeName string) (*nplk8s.NPLController, error)

InitController initializes the NPLController with appropriate Pod and Service Informers. This function can be used independently while unit testing without using InitializeNPLAgent function.

func InitializeNPLAgent

func InitializeNPLAgent(
	kubeClient clientset.Interface,
	informerFactory informers.SharedInformerFactory,
	startPort int,
	endPort int,
	nodeName string,
) (*nplk8s.NPLController, error)

InitializeNPLAgent initializes the NodePortLocal agent. It sets up event handlers to handle Pod add, update and delete events. When a Pod gets created, a free Node port is obtained from the port table cache and a DNAT rule is added to NAT traffic to the Pod's ip:port.