helper

Documentation

Index

• Constants
• Variables
• func GetPodsAssignedToNode(nodeName string, podIndexer cache.Indexer) ([]*corev1.Pod, error)
• type CNRTaintHelper
  • func NewTaintHelper(ctx context.Context, emitter metrics.MetricEmitter, ...) *CNRTaintHelper
  • func (t *CNRTaintHelper) Run()
  • func (t *CNRTaintHelper) TryUNTaintCNR(name string) error
• type CNRTaintItem
• type EvictHelper
  • func NewEvictHelper(ctx context.Context, emitter metrics.MetricEmitter, ...) *EvictHelper
  • func (e *EvictHelper) Run()
• type EvictItem
• type HealthzHelper
  • func NewHealthzHelper(ctx context.Context, conf *controller.LifeCycleConfig, ...) *HealthzHelper
  • func (h *HealthzHelper) CheckAgentReady(node string, agent string) bool
  • func (h *HealthzHelper) CheckAllAgentReady(node string) bool
  • func (h *HealthzHelper) Run()

Constants

const NodeNameKeyIndex = "spec.nodeName"

const TaintNameNoScheduler = "TaintNameNoScheduler"

Variables

var TaintNoScheduler = &apis.Taint{
	Key:    corev1.TaintNodeUnschedulable,
	Effect: apis.TaintEffectNoScheduleForReclaimedTasks,
}

Functions

func GetPodsAssignedToNode

func GetPodsAssignedToNode(nodeName string, podIndexer cache.Indexer) ([]*corev1.Pod, error)

GetPodsAssignedToNode returns pods that belong to this node by indexer

Types

type CNRTaintHelper

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

func NewTaintHelper

func NewTaintHelper(ctx context.Context, emitter metrics.MetricEmitter, cnrControl control.CNRControl,
	nodeLister corelisters.NodeLister, cnrLister listers.CustomNodeResourceLister,
	queue *scheduler.RateLimitedTimedQueue, checker *HealthzHelper) *CNRTaintHelper

NewTaintHelper todo add logic here

func (*CNRTaintHelper) Run

func (t *CNRTaintHelper) Run()

func (*CNRTaintHelper) TryUNTaintCNR

func (t *CNRTaintHelper) TryUNTaintCNR(name string) error

TryUNTaintCNR is used to delete taint info from CNR

type CNRTaintItem

type CNRTaintItem struct {
	Taints map[string]*apis.Taint
}

CNRTaintItem records the detailed item to perform cnr-taints

type EvictHelper

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

func NewEvictHelper

func NewEvictHelper(ctx context.Context, emitter metrics.MetricEmitter,
	podControl control.PodEjector, nodeLister corelisters.NodeLister, cnrLister listers.CustomNodeResourceLister,
	queue *scheduler.RateLimitedTimedQueue, checker *HealthzHelper) *EvictHelper

NewEvictHelper todo add logic here

func (*EvictHelper) Run

func (e *EvictHelper) Run()

type EvictItem

type EvictItem struct {
	// PodKeys maps from agent-name to pod-keys (that should be evicted because of the Agents)
	PodKeys map[string][]string
}

EvictItem records the detailed item to perform pod eviction

type HealthzHelper

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

func NewHealthzHelper

func NewHealthzHelper(ctx context.Context, conf *controller.LifeCycleConfig, emitter metrics.MetricEmitter,
	nodeSelector labels.Selector, agentSelectors map[string]labels.Selector, podIndexer cache.Indexer,
	nodeLister corelisters.NodeLister, cnrLister listers.CustomNodeResourceLister) *HealthzHelper

NewHealthzHelper todo add logic here

func (*HealthzHelper) CheckAgentReady

func (h *HealthzHelper) CheckAgentReady(node string, agent string) bool

CheckAgentReady checks whether the given agent is ready

func (*HealthzHelper) CheckAllAgentReady

func (h *HealthzHelper) CheckAllAgentReady(node string) bool

CheckAllAgentReady checks whether all agents are ready

func (*HealthzHelper) Run

func (h *HealthzHelper) Run()