controller

Documentation

Index

• Constants
• func NodeHealth(node v1.Node) bool
• func NodeIP(node v1.Node) (string, error)
• func NodeReady(node v1.Node) bool
• func NodeUnreachable(node v1.Node) bool
• func UpdateNode(node *v1.Node, detail *commoneks.NodeCCMInitResponseData) error
• func UpdateNodeAnnotations(node *v1.Node, detail *commoneks.NodeCCMInitResponseData)
• func UpdateNodeLabels(node *v1.Node, detail *commoneks.NodeCCMInitResponseData)
• func UpdateNodeTaints(node *v1.Node, detail *commoneks.NodeCCMInitResponseData)
• type EndpointsController
  • func NewServiceController() (*EndpointsController, error)
  • func (sc *EndpointsController) Run(ctx context.Context)
• type EndpointsControllerWrapper
  • func NewEndpointsControllerWrapper() *EndpointsControllerWrapper
  • func (e *EndpointsControllerWrapper) StartEndpointsControllerWrapper(initContext app.ControllerInitContext, ...) app.InitFunc
• type NodeController
  • func NewNodeController() NodeController
  • func (n *NodeController) CollectPlayLoad(ctx context.Context) error
  • func (n *NodeController) ListenNodes(ctx context.Context)
  • func (n *NodeController) NotifyNodeDown(ctx context.Context, event *v1.Event)
  • func (n *NodeController) NotifyNodeReady(ctx context.Context, event *v1.Event)
  • func (n *NodeController) Run(ctx context.Context)
  • func (n *NodeController) Update(ctx context.Context) error
  • func (n *NodeController) Validate() error
• type NodeControllerWrapper
  • func NewNodeControllerWrapper() *NodeControllerWrapper
  • func (c *NodeControllerWrapper) StartNodeControllerWrapper(initContext app.ControllerInitContext, ...) app.InitFunc

Constants

const (
	NodeControllerClientName = "node-controller"

	NodeControllerKey = "label-taint"
)

const (
	AnnotationEPUpdated = "service.beta.kubernetes.io/eks-endpoints-updated"
)

const (
	EndpointsControllerName = "endpoints-controller"
)

Functions

func NodeHealth

func NodeHealth(node v1.Node) bool

func NodeIP

func NodeIP(node v1.Node) (string, error)

func NodeReady

func NodeReady(node v1.Node) bool

func NodeUnreachable

func NodeUnreachable(node v1.Node) bool

func UpdateNode

func UpdateNode(node *v1.Node, detail *commoneks.NodeCCMInitResponseData) error

UpdateNode 设置节点的污点

func UpdateNodeAnnotations

func UpdateNodeAnnotations(node *v1.Node, detail *commoneks.NodeCCMInitResponseData)

UpdateNodeAnnotations 修改节点的污点

func UpdateNodeLabels

func UpdateNodeLabels(node *v1.Node, detail *commoneks.NodeCCMInitResponseData)

UpdateNodeLabels 更新节点标签

func UpdateNodeTaints

func UpdateNodeTaints(node *v1.Node, detail *commoneks.NodeCCMInitResponseData)

UpdateNodeTaints 修改节点的污点

Types

type EndpointsController

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

EndpointsController 监听 Endpoints 变化，触发 LoadBalancer 更新

func NewServiceController

func NewServiceController() (*EndpointsController, error)

func (*EndpointsController) Run

func (sc *EndpointsController) Run(ctx context.Context)

Run 启动 Endpoints 监听器

type EndpointsControllerWrapper

type EndpointsControllerWrapper struct{}

EndpointsControllerWrapper 包装 EndpointsController，用于注册到 ControllerInitializers

func NewEndpointsControllerWrapper

func NewEndpointsControllerWrapper() *EndpointsControllerWrapper

func (*EndpointsControllerWrapper) StartEndpointsControllerWrapper

func (e *EndpointsControllerWrapper) StartEndpointsControllerWrapper(
	initContext app.ControllerInitContext,
	completedConfig *cloudcontrollerconfig.CompletedConfig,
	cloud cloudprovider.Interface,
) app.InitFunc

StartEndpointsControllerWrapper 初始化并启动 EndpointsController

type NodeController

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

func NewNodeController

func NewNodeController() NodeController

func (*NodeController) CollectPlayLoad

func (n *NodeController) CollectPlayLoad(ctx context.Context) error

CollectPlayLoad 获取集群节点的负载信息

func (*NodeController) ListenNodes

func (n *NodeController) ListenNodes(ctx context.Context)

func (*NodeController) NotifyNodeDown

func (n *NodeController) NotifyNodeDown(ctx context.Context, event *v1.Event)

func (*NodeController) NotifyNodeReady

func (n *NodeController) NotifyNodeReady(ctx context.Context, event *v1.Event)

func (*NodeController) Run

func (n *NodeController) Run(ctx context.Context)

func (*NodeController) Update

func (n *NodeController) Update(ctx context.Context) error

func (*NodeController) Validate

func (n *NodeController) Validate() error

type NodeControllerWrapper

type NodeControllerWrapper struct{}

func NewNodeControllerWrapper

func NewNodeControllerWrapper() *NodeControllerWrapper

func (*NodeControllerWrapper) StartNodeControllerWrapper

func (c *NodeControllerWrapper) StartNodeControllerWrapper(initContext app.ControllerInitContext, completedConfig *cloudcontrollerconfig.CompletedConfig, cloud cloudprovider.Interface) app.InitFunc