node

Documentation

Index

• Constants
• func NewNodeController(ctx context.Context, k8sClientset *kubernetes.Clientset, ...) controller.Controller
• type NodeController
  • func (c *NodeController) OnStatusUpdated(status bapi.SyncStatus)
  • func (c *NodeController) OnUpdates(updates []bapi.Update)
  • func (c *NodeController) Run(threadiness int, reconcilerPeriod string, stopCh chan struct{})

Constants

const (
	RateLimitCalicoList   = "calico-list"
	RateLimitK8s          = "k8s"
	RateLimitCalicoDelete = "calico-delete"
)

Functions

func NewNodeController

func NewNodeController(ctx context.Context, k8sClientset *kubernetes.Clientset, calicoClient client.Interface, cfg *config.Config) 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.

func (*NodeController) OnStatusUpdated

func (c *NodeController) OnStatusUpdated(status bapi.SyncStatus)

func (*NodeController) OnUpdates

func (c *NodeController) OnUpdates(updates []bapi.Update)

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. We ignore reconcilerPeriod and threadiness as this controller does not use a cache and runs only one worker thread.