Versions in this module Expand all Collapse all v1 v1.16.3 Oct 23, 2019 Changes in this version + const DefaultBindAllHostIP + func CreateNodeNameToInfoMap(pods []*v1.Pod, nodes []*v1.Node) map[string]*NodeInfo + func GetPodKey(pod *v1.Pod) (string, error) + type HostPortInfo map[string]map[ProtocolPort]struct + func (h HostPortInfo) Add(ip, protocol string, port int32) + func (h HostPortInfo) CheckConflict(ip, protocol string, port int32) bool + func (h HostPortInfo) Len() int + func (h HostPortInfo) Remove(ip, protocol string, port int32) + type ImageStateSummary struct + NumNodes int + Size int64 + type NodeInfo struct + TransientInfo *TransientSchedulerInfo + 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) Filter(pod *v1.Pod) bool + func (n *NodeInfo) FilterOutPods(pods []*v1.Pod) []*v1.Pod + func (n *NodeInfo) GetGeneration() int64 + func (n *NodeInfo) ImageStates() map[string]*ImageStateSummary + 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) SetGeneration(newGeneration int64) + func (n *NodeInfo) SetImageStates(newImageStates map[string]*ImageStateSummary) + func (n *NodeInfo) SetNode(node *v1.Node) error + func (n *NodeInfo) SetNonZeroRequest(newResource *Resource) + func (n *NodeInfo) SetPods(pods []*v1.Pod) + func (n *NodeInfo) SetRequestedResource(newResource *Resource) + func (n *NodeInfo) SetTaints(newTaints []v1.Taint) + func (n *NodeInfo) SetUsedPorts(newUsedPorts HostPortInfo) + func (n *NodeInfo) String() string + func (n *NodeInfo) Taints() ([]v1.Taint, error) + func (n *NodeInfo) UpdateUsedPorts(pod *v1.Pod, add bool) + func (n *NodeInfo) UsedPorts() HostPortInfo + func (n *NodeInfo) VolumeLimits() map[v1.ResourceName]int64 + type ProtocolPort struct + Port int32 + Protocol string + func NewProtocolPort(protocol string, port int32) *ProtocolPort + type Resource struct + AllowedPodNumber int + EphemeralStorage int64 + Memory int64 + MilliCPU 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) SetMaxResource(rl v1.ResourceList) + func (r *Resource) SetScalar(name v1.ResourceName, quantity int64) + type Snapshot struct + Generation int64 + NodeInfoList []*NodeInfo + NodeInfoMap map[string]*NodeInfo + func NewSnapshot() *Snapshot + func (s *Snapshot) ListNodes() []*v1.Node + type TransientSchedulerInfo struct + TransNodeInfo nodeTransientInfo + TransientLock sync.Mutex + func NewTransientSchedulerInfo() *TransientSchedulerInfo + func (transientSchedInfo *TransientSchedulerInfo) ResetTransientSchedulerInfo()
Go to main page