nlxcrd

Documentation

Index

• type Controller
  • func NewCrdController(kubeClient clientset.Interface, ...) *Controller
  • func (c *Controller) Run(stopCh <-chan struct{})

Types

type Controller

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

Controller is responsible for setting up necessary IP routes and Openflow entries for inter-node traffic.

func NewCrdController

func NewCrdController(
	kubeClient clientset.Interface,
	informerFactory informers.SharedInformerFactory,
	crdInformer crdinformers.HeliosAgentInfoInformer,
	heliosClient helios.HeliosDP,
	interfaceStore interfacestore.InterfaceStore,
	networkConfig *config.NetworkConfig,
	nodeConfig *config.NodeConfig) *Controller

NewCrdController instantiates a new Controller object which will process Node events and ensure connectivity between different Nodes.

func (*Controller) Run

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

Run will create defaultWorkers workers (go routines) which will process the Traceflow events from the workqueue.