node

Documentation

Index

• func NewNodeController(ctx context.Context, k8sClientset *kubernetes.Clientset, ...) controller.Controller
• type NodeController
  • func (c *NodeController) Run(threadiness int, reconcilerPeriod string, stopCh chan struct{})

Functions

func NewNodeController

func NewNodeController(ctx context.Context, k8sClientset *kubernetes.Clientset, calicoClient client.Interface) controller.Controller

NewNodeController Constructor for NodeController

Types

type NodeController

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

NodeController implements the Controller interface. It is responsible for monitoring kubernetes nodes and responding to delete events by removing them from the Calico datastore. It keeps a cache of known calico nodes and their corresponding kubernetes nodes to accomplish this.

func (*NodeController) Run

func (c *NodeController) Run(threadiness int, reconcilerPeriod string, stopCh chan struct{})

Run starts the node controller. It does start-of-day preparation and then launches worker threads.