cloud

Documentation

Index

• Variables
• type CloudNodeController
  • func NewCloudNodeController(nodeInformer coreinformers.NodeInformer, kubeClient clientset.Interface, ...) (*CloudNodeController, error)
  • func (cnc *CloudNodeController) AddCloudNode(ctx context.Context, obj interface{})
  • func (cnc *CloudNodeController) Run(stopCh <-chan struct{})
  • func (cnc *CloudNodeController) UpdateCloudNode(ctx context.Context, _, newObj interface{})
  • func (cnc *CloudNodeController) UpdateNodeStatus(ctx context.Context)

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,
	nodeStatusUpdateFrequency time.Duration) (*CloudNodeController, error)

NewCloudNodeController creates a CloudNodeController object

func (*CloudNodeController) AddCloudNode

func (cnc *CloudNodeController) AddCloudNode(ctx context.Context, obj interface{})

AddCloudNode handles initializing new nodes registered with the cloud taint.

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

func (cnc *CloudNodeController) UpdateCloudNode(ctx context.Context, _, newObj interface{})

func (*CloudNodeController) UpdateNodeStatus

func (cnc *CloudNodeController) UpdateNodeStatus(ctx context.Context)

UpdateNodeStatus updates the node status, such as node addresses