Documentation
¶
Index ¶
Constants ¶
View Source
const ( RateLimitCalicoList = "calico-list" RateLimitK8s = "k8s" RateLimitCalicoDelete = "calico-delete" )
Variables ¶
This section is empty.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.