package cloud

import "k8s.io/kubernetes/pkg/controller/cloud"

Index ¶

• Variables
• type CloudNodeController
• func NewCloudNodeController( nodeInformer coreinformers.NodeInformer, kubeClient clientset.Interface, cloud cloudprovider.Interface, nodeMonitorPeriod time.Duration, nodeStatusUpdateFrequency time.Duration) *CloudNodeController
• func (cnc *CloudNodeController) AddCloudNode(obj interface{})
• func (cnc *CloudNodeController) MonitorNode()
• func (cnc *CloudNodeController) Run()
• func (cnc *CloudNodeController) UpdateCloudNode(_, newObj interface{})
• func (cnc *CloudNodeController) UpdateNodeStatus()
• type PersistentVolumeLabelController
• func NewPersistentVolumeLabelController( kubeClient kubernetes.Interface, cloud cloudprovider.Interface) *PersistentVolumeLabelController
• func (pvlc *PersistentVolumeLabelController) Run(threadiness int, stopCh <-chan struct{})

Variables ¶

var UpdateNodeSpecBackoff = wait.Backoff{
	Steps:    20,
	Duration: 50 * time.Millisecond,
	Jitter:   1.0,
}

Types ¶

type CloudNodeController ¶

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

func NewCloudNodeController ¶

func NewCloudNodeController(
	nodeInformer coreinformers.NodeInformer,
	kubeClient clientset.Interface,
	cloud cloudprovider.Interface,
	nodeMonitorPeriod time.Duration,
	nodeStatusUpdateFrequency time.Duration) *CloudNodeController

NewCloudNodeController creates a CloudNodeController object

func (*CloudNodeController) AddCloudNode ¶

func (cnc *CloudNodeController) AddCloudNode(obj interface{})

This processes nodes that were added into the cluster, and cloud initialize them if appropriate

func (*CloudNodeController) MonitorNode ¶

func (cnc *CloudNodeController) MonitorNode()

Monitor node queries the cloudprovider for non-ready nodes and deletes them if they cannot be found in the cloud provider

func (*CloudNodeController) Run ¶

func (cnc *CloudNodeController) Run()

This controller deletes a node if kubelet is not reporting and the node is gone from the cloud provider.

func (*CloudNodeController) UpdateCloudNode ¶

func (cnc *CloudNodeController) UpdateCloudNode(_, newObj interface{})

func (*CloudNodeController) UpdateNodeStatus ¶

func (cnc *CloudNodeController) UpdateNodeStatus()

UpdateNodeStatus updates the node status, such as node addresses

type PersistentVolumeLabelController ¶

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

PersistentVolumeLabelController handles adding labels to persistent volumes when they are created

func NewPersistentVolumeLabelController ¶

func NewPersistentVolumeLabelController(
	kubeClient kubernetes.Interface,
	cloud cloudprovider.Interface) *PersistentVolumeLabelController

NewPersistentVolumeLabelController creates a PersistentVolumeLabelController object

func (*PersistentVolumeLabelController) Run ¶

func (pvlc *PersistentVolumeLabelController) Run(threadiness int, stopCh <-chan struct{})

Run starts a controller that adds labels to persistent volumes

Source Files ¶

node_controller.go pvlcontroller.go