const deleteNodeEvent … const deleteNodeFailedEvent … var ShutdownTaint … type CloudNodeLifecycleController … func NewCloudNodeLifecycleController( nodeInformer coreinformers.NodeInformer, kubeClient clientset.Interface, cloud cloudprovider.Interface, nodeMonitorPeriod time.Duration) (*CloudNodeLifecycleController, error) { … } // Run starts the main loop for this controller. Run is blocking so should // be called via a goroutine func (c *CloudNodeLifecycleController) Run(ctx context.Context, controllerManagerMetrics *controllersmetrics.ControllerManagerMetrics) { … } // MonitorNodes checks to see if nodes in the cluster have been deleted // or shutdown. If deleted, it deletes the node resource. If shutdown it // applies a shutdown taint to the node func (c *CloudNodeLifecycleController) MonitorNodes(ctx context.Context) { … } // getProviderID returns the provider ID for the node. If Node CR has no provider ID, // it will be the one from the cloud provider. func (c *CloudNodeLifecycleController) getProviderID(ctx context.Context, node *v1.Node) (string, error) { … } // shutdownInCloudProvider returns true if the node is shutdown on the cloud provider func (c *CloudNodeLifecycleController) shutdownInCloudProvider(ctx context.Context, node *v1.Node) (bool, error) { … } // ensureNodeExistsByProviderID checks if the instance exists by the provider id, func (c *CloudNodeLifecycleController) ensureNodeExistsByProviderID(ctx context.Context, node *v1.Node) (bool, error) { … }
Codebase Browser
kubernetes