package cloud

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

Index ¶

• type CloudNodeController
• func NewCloudNodeController( nodeInformer coreinformers.NodeInformer, kubeClient clientset.Interface, cloud cloudprovider.Interface, nodeMonitorPeriod time.Duration) (*CloudNodeController, error)
• func (cnc *CloudNodeController) Run()

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) (*CloudNodeController, error)

NewCloudNodeController creates a CloudNodeController object

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.

Source Files ¶

nodecontroller.go