controller

Documentation

Index

• func NewNodeController(controllerContext context.Context, kubeClientset kubernetes.Interface, ...) (*controller.CloudNetworkConfigController, error)
• type NodeController
  • func (n *NodeController) SetNodeEgressIPConfigAnnotation(node *corev1.Node, ...) error
  • func (n *NodeController) SyncHandler(key string) error

Functions

func NewNodeController

func NewNodeController(
	controllerContext context.Context,
	kubeClientset kubernetes.Interface,
	cloudProviderClient cloudprovider.CloudProviderIntf,
	nodeInformer coreinformers.NodeInformer,
	cloudPrivateIPConfigInformer cloudnetworkinformers.CloudPrivateIPConfigInformer) (*controller.CloudNetworkConfigController, error)

NewNodeController returns a new Node controller

Types

type NodeController

type NodeController struct {
	controller.CloudNetworkConfigController
	// contains filtered or unexported fields
}

NodeController is the controller implementation for Node resources This controller is used to annotate nodes for the purposes of the cloud network config controller

func (*NodeController) SetNodeEgressIPConfigAnnotation

func (n *NodeController) SetNodeEgressIPConfigAnnotation(node *corev1.Node, nodeEgressIPConfigs []*cloudprovider.NodeEgressIPConfiguration) error

SetCloudPrivateIPConfigAnnotationOnNode annotates the corev1.Node with the cloud subnet information and capacity

func (*NodeController) SyncHandler

func (n *NodeController) SyncHandler(key string) error

syncHandler compares the actual state with the desired, and attempts to converge the two. It then updates the Status block of the Node resource with the current status of the resource.