cache

Documentation

Index

• Constants
• func GetCache() *overcommitCache
• func RegisterCNRHandler()
• func RegisterPodHandler()
• type NodeCache
  • func New() *NodeCache
  • func (n *NodeCache) AddPod(key string, pod *v1.Pod)
  • func (n *NodeCache) GetGuaranteedCPUs() int
  • func (n *NodeCache) HintProvidersAvailable() (CPUManager, MemoryManager bool)
  • func (n *NodeCache) RemovePod(key string, pod *v1.Pod)

Constants

const (
	OvercommitPodHandler = "OvercommitPodHandler"
	OvercommitCNRHandler = "OvercommitCNRHandler"
)

Functions

func GetCache

func GetCache() *overcommitCache

func RegisterCNRHandler

func RegisterCNRHandler()

RegisterCNRHandler register handler to scheduler event handlers

func RegisterPodHandler

func RegisterPodHandler()

RegisterPodHandler register handler to scheduler event handlers

Types

type NodeCache

type NodeCache struct {
	sync.RWMutex

	PodResources map[string]int

	// kubelet topology hint providers from CNR annotation.
	// provider will be cached only if provider policy is available.
	// only used for node resource overcommitment.
	HintProviders map[string]struct{}

	// total guaranteed cpus on node
	GuaranteedCPUs int
}

func New

func New() *NodeCache

func (*NodeCache) AddPod

func (n *NodeCache) AddPod(key string, pod *v1.Pod)

func (*NodeCache) GetGuaranteedCPUs

func (n *NodeCache) GetGuaranteedCPUs() int

func (*NodeCache) HintProvidersAvailable

func (n *NodeCache) HintProvidersAvailable() (CPUManager, MemoryManager bool)

func (*NodeCache) RemovePod

func (n *NodeCache) RemovePod(key string, pod *v1.Pod)