schedulercache

Mar 23, 2018

Changes in this version

+ func CreateNodeNameToInfoMap(pods []*v1.Pod, nodes []*v1.Node) map[string]*NodeInfo

+ type Cache interface

+ AddNode func(node *v1.Node) error

+ AddPDB func(pdb *policy.PodDisruptionBudget) error

+ AddPod func(pod *v1.Pod) error

+ AssumePod func(pod *v1.Pod) error

+ FilteredList func(filter PodFilter, selector labels.Selector) ([]*v1.Pod, error)

+ FinishBinding func(pod *v1.Pod) error

+ ForgetPod func(pod *v1.Pod) error

+ GetPod func(pod *v1.Pod) (*v1.Pod, error)

+ IsAssumedPod func(pod *v1.Pod) (bool, error)

+ List func(labels.Selector) ([]*v1.Pod, error)

+ ListPDBs func(selector labels.Selector) ([]*policy.PodDisruptionBudget, error)

+ RemoveNode func(node *v1.Node) error

+ RemovePDB func(pdb *policy.PodDisruptionBudget) error

+ RemovePod func(pod *v1.Pod) error

+ UpdateNode func(oldNode, newNode *v1.Node) error

+ UpdateNodeNameToInfoMap func(infoMap map[string]*NodeInfo) error

+ UpdatePDB func(oldPDB, newPDB *policy.PodDisruptionBudget) error

+ UpdatePod func(oldPod, newPod *v1.Pod) error

+ func New(ttl time.Duration, stop <-chan struct{}) Cache

+ type NodeInfo struct

+ func NewNodeInfo(pods ...*v1.Pod) *NodeInfo

+ func (n *NodeInfo) AddPod(pod *v1.Pod)

+ func (n *NodeInfo) AllocatableResource() Resource

+ func (n *NodeInfo) AllowedPodNumber() int

+ func (n *NodeInfo) Clone() *NodeInfo

+ func (n *NodeInfo) DiskPressureCondition() v1.ConditionStatus

+ func (n *NodeInfo) Filter(pod *v1.Pod) bool

+ func (n *NodeInfo) FilterOutPods(pods []*v1.Pod) []*v1.Pod

+ func (n *NodeInfo) MemoryPressureCondition() v1.ConditionStatus

+ func (n *NodeInfo) Node() *v1.Node

+ func (n *NodeInfo) NonZeroRequest() Resource

+ func (n *NodeInfo) Pods() []*v1.Pod

+ func (n *NodeInfo) PodsWithAffinity() []*v1.Pod

+ func (n *NodeInfo) RemoveNode(node *v1.Node) error

+ func (n *NodeInfo) RemovePod(pod *v1.Pod) error

+ func (n *NodeInfo) RequestedResource() Resource

+ func (n *NodeInfo) SetAllocatableResource(allocatableResource *Resource)

+ func (n *NodeInfo) SetNode(node *v1.Node) error

+ func (n *NodeInfo) String() string

+ func (n *NodeInfo) Taints() ([]v1.Taint, error)

+ func (n *NodeInfo) UsedPorts() util.HostPortInfo

+ type PodFilter func(*v1.Pod) bool

+ type Resource struct

+ AllowedPodNumber int

+ EphemeralStorage int64

+ Memory int64

+ MilliCPU int64

+ NvidiaGPU int64

+ ScalarResources map[v1.ResourceName]int64

+ func NewResource(rl v1.ResourceList) *Resource

+ func (r *Resource) Add(rl v1.ResourceList)

+ func (r *Resource) AddScalar(name v1.ResourceName, quantity int64)

+ func (r *Resource) Clone() *Resource

+ func (r *Resource) ResourceList() v1.ResourceList

+ func (r *Resource) SetScalar(name v1.ResourceName, quantity int64)