Documentation ¶
Index ¶
- Constants
- Variables
- func AssignMicroTopology(node framework.NodeInfo, pod *v1.Pod) error
- func NewCache(handler handler.CacheHandler) commonstores.CommonStore
- func NewSnapshot(handler handler.CacheHandler) commonstores.CommonStore
- type NodeStore
- func (s *NodeStore) Add(nodeName string, nodeInfo framework.NodeInfo)
- func (s *NodeStore) AddCNR(cnr *katalystv1alpha1.CustomNodeResource) error
- func (s *NodeStore) AddNMNode(nmNode *nodev1alpha1.NMNode) error
- func (s *NodeStore) AddNode(node *v1.Node) error
- func (s *NodeStore) AddPod(pod *v1.Pod) error
- func (s *NodeStore) AllNodesClone() map[string]framework.NodeInfo
- func (s *NodeStore) AssumePod(podInfo *framework.CachePodInfo) error
- func (s *NodeStore) Delete(nodeName string, nodeInfo framework.NodeInfo)
- func (s *NodeStore) ForgetPod(podInfo *framework.CachePodInfo) error
- func (s *NodeStore) Get(nodeName string) framework.NodeInfo
- func (s *NodeStore) GetNodeInfo(nodeName string) framework.NodeInfo
- func (s *NodeStore) Len() int
- func (c *NodeStore) Name() commonstores.StoreName
- func (s *NodeStore) NodeInThisPartition(nodeName string) bool
- func (s *NodeStore) RemoveCNR(cnr *katalystv1alpha1.CustomNodeResource) error
- func (s *NodeStore) RemoveNMNode(nmNode *nodev1alpha1.NMNode) error
- func (s *NodeStore) RemoveNode(node *v1.Node) error
- func (s *NodeStore) RemovePod(pod *v1.Pod) error
- func (s *NodeStore) Set(nodeName string, nodeInfo framework.NodeInfo)
- func (s *NodeStore) SetNodeInPartition(nodeName string) error
- func (s *NodeStore) SetNodeOutOfPartition(nodeName string) error
- func (s *NodeStore) UpdateCNR(oldCNR, newCNR *katalystv1alpha1.CustomNodeResource) error
- func (s *NodeStore) UpdateNMNode(oldNMNode, newNMNode *nodev1alpha1.NMNode) error
- func (s *NodeStore) UpdateNode(oldNode, newNode *v1.Node) error
- func (s *NodeStore) UpdatePod(oldPod, newPod *v1.Pod) error
- func (cacheStore *NodeStore) UpdateSnapshot(store commonstores.CommonStore) error
Constants ¶
View Source
const Name commonstores.StoreName = "NodeStore"
Variables ¶
View Source
var GlobalNodeInfoPlaceHolder = framework.NewNodeInfo()
Functions ¶
func AssignMicroTopology ¶
-------------------------------------- topology --------------------------------------
func NewCache ¶
func NewCache(handler handler.CacheHandler) commonstores.CommonStore
func NewSnapshot ¶
func NewSnapshot(handler handler.CacheHandler) commonstores.CommonStore
Types ¶
type NodeStore ¶
type NodeStore struct { commonstores.BaseStore Store generationstore.Store // Holds all nodes including those that have been Deleted but still have residual pods. // `Deleted` holds all the nodes: // 1. that have been deleted but still have residual pods. // 2. that its pod comes before its own, so we can't use it to schedule. Deleted sets.String AfterAdd func(framework.NodeInfo) // Triggered by a call to the NodeStore.Add function, used to maintain additional information about the node. AfterDelete func(framework.NodeInfo) // Triggered by a call to the NodeStore.Delete function, used to maintain additional information about the node. // contains filtered or unexported fields }
-------------------------------------- NodeStore --------------------------------------
func (*NodeStore) AddCNR ¶
func (s *NodeStore) AddCNR(cnr *katalystv1alpha1.CustomNodeResource) error
func (*NodeStore) AllNodesClone ¶
AllNodesClone return all nodes's deepcopy and organize them in map.
func (*NodeStore) Name ¶
func (c *NodeStore) Name() commonstores.StoreName
func (*NodeStore) NodeInThisPartition ¶
func (*NodeStore) RemoveCNR ¶
func (s *NodeStore) RemoveCNR(cnr *katalystv1alpha1.CustomNodeResource) error
RemoveCNR removes custom node resource. The node might be still in the node tree because their deletion events didn't arrive yet.
func (*NodeStore) RemoveNMNode ¶
func (s *NodeStore) RemoveNMNode(nmNode *nodev1alpha1.NMNode) error
func (*NodeStore) SetNodeInPartition ¶
func (*NodeStore) SetNodeOutOfPartition ¶
func (*NodeStore) UpdateCNR ¶
func (s *NodeStore) UpdateCNR(oldCNR, newCNR *katalystv1alpha1.CustomNodeResource) error
func (*NodeStore) UpdateNMNode ¶
func (s *NodeStore) UpdateNMNode(oldNMNode, newNMNode *nodev1alpha1.NMNode) error
func (*NodeStore) UpdateSnapshot ¶
func (cacheStore *NodeStore) UpdateSnapshot(store commonstores.CommonStore) error
Click to show internal directories.
Click to hide internal directories.