Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ShutdownTaint = &v1.Taint{ Key: schedulerapi.TaintNodeShutdown, Effect: v1.TaintEffectNoSchedule, }
var UpdateNodeSpecBackoff = wait.Backoff{ Steps: 20, Duration: 50 * time.Millisecond, Jitter: 1.0, }
Functions ¶
This section is empty.
Types ¶
type CloudNodeController ¶
type CloudNodeController struct {
// contains filtered or unexported fields
}
func NewCloudNodeController ¶
func NewCloudNodeController( nodeInformer coreinformers.NodeInformer, kubeClient clientset.Interface, cloud cloudprovider.Interface, nodeStatusUpdateFrequency time.Duration) *CloudNodeController
NewCloudNodeController creates a CloudNodeController object
func (*CloudNodeController) AddCloudNode ¶ added in v1.7.0
func (cnc *CloudNodeController) AddCloudNode(obj interface{})
This processes nodes that were added into the cluster, and cloud initialize them if appropriate
func (*CloudNodeController) Run ¶
func (cnc *CloudNodeController) Run(stopCh <-chan struct{})
This controller updates newly registered nodes with information from the cloud provider. This call is blocking so should be called via a goroutine
func (*CloudNodeController) UpdateCloudNode ¶ added in v1.10.0
func (cnc *CloudNodeController) UpdateCloudNode(_, newObj interface{})
func (*CloudNodeController) UpdateNodeStatus ¶ added in v1.7.0
func (cnc *CloudNodeController) UpdateNodeStatus()
UpdateNodeStatus updates the node status, such as node addresses
type CloudNodeLifecycleController ¶
type CloudNodeLifecycleController struct {
// contains filtered or unexported fields
}
CloudNodeLifecycleController is responsible for deleting/updating kubernetes nodes that have been deleted/shutdown on the cloud provider
func NewCloudNodeLifecycleController ¶
func NewCloudNodeLifecycleController( nodeInformer coreinformers.NodeInformer, kubeClient clientset.Interface, cloud cloudprovider.Interface, nodeMonitorPeriod time.Duration) (*CloudNodeLifecycleController, error)
func (*CloudNodeLifecycleController) MonitorNodes ¶
func (c *CloudNodeLifecycleController) MonitorNodes()
MonitorNodes checks to see if nodes in the cluster have been deleted or shutdown. If deleeted, it deletes the node resource. If shutdown it applies a shutdown taint to the node
func (*CloudNodeLifecycleController) Run ¶
func (c *CloudNodeLifecycleController) Run(stopCh <-chan struct{})
Run starts the main loop for this controller. Run is blocking so should be called via a goroutine
type PersistentVolumeLabelController ¶ added in v1.8.0
type PersistentVolumeLabelController struct {
// contains filtered or unexported fields
}
PersistentVolumeLabelController handles adding labels to persistent volumes when they are created
func NewPersistentVolumeLabelController ¶ added in v1.8.0
func NewPersistentVolumeLabelController( kubeClient kubernetes.Interface, cloud cloudprovider.Interface) *PersistentVolumeLabelController
NewPersistentVolumeLabelController creates a PersistentVolumeLabelController object
func (*PersistentVolumeLabelController) Run ¶ added in v1.8.0
func (pvlc *PersistentVolumeLabelController) Run(threadiness int, stopCh <-chan struct{})
Run starts a controller that adds labels to persistent volumes
Source Files