Documentation
¶
Index ¶
- Constants
- type Store
- func (s *Store) AddBindResult(namespace, podName, pluginName, status string)
- func (s *Store) AddCustomResult(namespace, podName, annotationKey, result string)
- func (s *Store) AddFilterResult(namespace, podName, nodeName, pluginName, reason string)
- func (s *Store) AddNormalizedScoreResult(namespace, podName, nodeName, pluginName string, normalizedscore int64)
- func (s *Store) AddPermitResult(namespace, podName, pluginName, status string, timeout time.Duration)
- func (s *Store) AddPostFilterResult(namespace, podName, nominatedNodeName, pluginName string, nodeNames []string)
- func (s *Store) AddPreBindResult(namespace, podName, pluginName, status string)
- func (s *Store) AddPreFilterResult(namespace, podName, pluginName, reason string, ...)
- func (s *Store) AddPreScoreResult(namespace, podName, pluginName, reason string)
- func (s *Store) AddReserveResult(namespace, podName, pluginName, status string)
- func (s *Store) AddScoreResult(namespace, podName, nodeName, pluginName string, score int64)
- func (s *Store) AddSelectedNode(namespace, podName, nodeName string)
- func (s *Store) DeleteData(pod v1.Pod)
- func (s *Store) GetStoredResult(pod *v1.Pod) map[string]string
Constants ¶
const ( // PassedFilterMessage is used when a node pass the filter plugin. PassedFilterMessage = "passed" // SuccessMessage is used when no error is retured from the plugin. SuccessMessage = "success" // WaitMessage is used when wait status is retured from the plugin. WaitMessage = "wait" // PostFilterNominatedMessage is used when a postFilter plugin returns success. PostFilterNominatedMessage = "preemption victim" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store has results of scheduling. It manages all scheduling results and reflects all results on the pod annotation when the scheduling is finished.
func (*Store) AddBindResult ¶
func (*Store) AddCustomResult ¶
AddCustomResult adds user defined data. The results added through this func is reflected on the Pod's annotation eventually like other scheduling results. This function is intended to be called from the plugin.PluginExtender; allow users to export some internal state on Pods for debugging purpose. For example, Calling AddCustomResult in NodeAffinity's PreFilterPluginExtender: AddCustomResult("namespace", "incomingPod", "node-affinity-filter-internal-state-anno-key", "internal-state") Then, "incomingPod" Pod will get {"node-affinity-filter-internal-state-anno-key": "internal-state"} annotation after scheduling.
func (*Store) AddFilterResult ¶
AddFilterResult adds filtering result to pod annotation.
func (*Store) AddNormalizedScoreResult ¶
func (s *Store) AddNormalizedScoreResult(namespace, podName, nodeName, pluginName string, normalizedscore int64)
AddNormalizedScoreResult adds final score result to pod annotation.
func (*Store) AddPermitResult ¶
func (*Store) AddPostFilterResult ¶
func (s *Store) AddPostFilterResult(namespace, podName, nominatedNodeName, pluginName string, nodeNames []string)
AddPostFilterResult adds post filter result to the pod annotaiton.
- nominatedNodeName represents the node name which nominated by the postFilter plugin. Otherwise, the string "" would be stored in this arg.
func (*Store) AddPreBindResult ¶
func (*Store) AddPreFilterResult ¶
func (s *Store) AddPreFilterResult(namespace, podName, pluginName, reason string, preFilterResult *framework.PreFilterResult)
func (*Store) AddPreScoreResult ¶
func (*Store) AddReserveResult ¶
func (*Store) AddScoreResult ¶
AddScoreResult adds scoring result to pod annotation.
func (*Store) AddSelectedNode ¶
func (*Store) DeleteData ¶
DeleteData deletes the data corresponding to the specified Pod.
Source Files