Versions in this module Expand all Collapse all v0 v0.3.0 Feb 21, 2020 Changes in this version + const AllNodeUnavailableMsg + const DefaultNamespaceWeight + const GPUResourceName + const NamespaceWeightKey + const NodePodNumberExceeded + const NodeResourceFitFailed + const PodGroupVersionV1Alpha1 + const PodGroupVersionV1Alpha2 + func AllocatedStatus(status TaskStatus) bool + func JobTerminated(job *JobInfo) bool + func MergeErrors(errs ...error) error + type BatchNodeOrderFn func(*TaskInfo, []*NodeInfo) (map[string]float64, error) + type ClusterInfo struct + Jobs map[JobID]*JobInfo + NamespaceInfo map[NamespaceName]*NamespaceInfo + Nodes map[string]*NodeInfo + Queues map[QueueID]*QueueInfo + func (ci ClusterInfo) String() string + type CompareFn func(interface{}, interface{}) int + type EvictableFn func(*TaskInfo, []*TaskInfo) []*TaskInfo + type FitError struct + NodeName string + Reasons []string + func NewFitError(task *TaskInfo, node *NodeInfo, message ...string) *FitError + func NewFitErrorByReasons(task *TaskInfo, node *NodeInfo, reasons ...algorithm.PredicateFailureReason) *FitError + func (f *FitError) Error() string + type FitErrors struct + func NewFitErrors() *FitErrors + func (f *FitErrors) Error() string + func (f *FitErrors) SetError(err string) + func (f *FitErrors) SetNodeError(nodeName string, err error) + type JobID types.UID + type JobInfo struct + Allocated *Resource + CreationTimestamp metav1.Time + JobFitErrors string + MinAvailable int32 + Name string + Namespace string + NodesFitDelta NodeResourceMap + NodesFitErrors map[TaskID]*FitErrors + PodGroup *PodGroup + Priority int32 + Queue QueueID + TaskStatusIndex map[TaskStatus]tasksMap + Tasks tasksMap + TotalRequest *Resource + UID JobID + func NewJobInfo(uid JobID, tasks ...*TaskInfo) *JobInfo + func (ji *JobInfo) AddTaskInfo(ti *TaskInfo) + func (ji *JobInfo) Clone() *JobInfo + func (ji *JobInfo) DeleteTaskInfo(ti *TaskInfo) error + func (ji *JobInfo) FitError() string + func (ji *JobInfo) Pipelined() bool + func (ji *JobInfo) Ready() bool + func (ji *JobInfo) ReadyTaskNum() int32 + func (ji *JobInfo) SetPodGroup(pg *PodGroup) + func (ji *JobInfo) UnsetPodGroup() + func (ji *JobInfo) UpdateTaskStatus(task *TaskInfo, status TaskStatus) error + func (ji *JobInfo) ValidTaskNum() int32 + func (ji *JobInfo) WaitingTaskNum() int32 + func (ji JobInfo) String() string + type LessFn func(interface{}, interface{}) bool + type NamespaceCollection struct + Name string + func NewNamespaceCollection(name string) *NamespaceCollection + func (n *NamespaceCollection) Delete(quota *v1.ResourceQuota) + func (n *NamespaceCollection) Snapshot() *NamespaceInfo + func (n *NamespaceCollection) Update(quota *v1.ResourceQuota) + type NamespaceInfo struct + Name NamespaceName + Weight int64 + func (n *NamespaceInfo) GetWeight() int64 + type NamespaceName string + type NodeInfo struct + Allocatable *Resource + Capability *Resource + Idle *Resource + Name string + Node *v1.Node + Others map[string]interface{} + Pipelined *Resource + Releasing *Resource + State NodeState + Tasks map[TaskID]*TaskInfo + Used *Resource + func NewNodeInfo(node *v1.Node) *NodeInfo + func (ni *NodeInfo) AddTask(task *TaskInfo) error + func (ni *NodeInfo) Clone() *NodeInfo + func (ni *NodeInfo) FutureIdle() *Resource + func (ni *NodeInfo) Pods() (pods []*v1.Pod) + func (ni *NodeInfo) Ready() bool + func (ni *NodeInfo) RemoveTask(ti *TaskInfo) error + func (ni *NodeInfo) SetNode(node *v1.Node) + func (ni *NodeInfo) UpdateTask(ti *TaskInfo) error + func (ni NodeInfo) String() string + type NodeMapFn func(*TaskInfo, *NodeInfo) (float64, error) + type NodeOrderFn func(*TaskInfo, *NodeInfo) (float64, error) + type NodeOrderMapFn func(*TaskInfo, *NodeInfo) (map[string]float64, float64, error) + type NodeOrderReduceFn func(*TaskInfo, map[string]schedulerapi.HostPriorityList) (map[string]float64, error) + type NodePhase int + const NotReady + const Ready + func (np NodePhase) String() string + type NodeReduceFn func(*TaskInfo, schedulerapi.HostPriorityList) error + type NodeResourceMap map[string]*Resource + type NodeState struct + Phase NodePhase + Reason string + type PodGroup struct + Version string + type PodGroupPhase string + type PredicateFn func(*TaskInfo, *NodeInfo) error + type QueueID types.UID + type QueueInfo struct + Name string + Queue *scheduling.Queue + UID QueueID + Weight int32 + func NewQueueInfo(queue *scheduling.Queue) *QueueInfo + func (q *QueueInfo) Clone() *QueueInfo + func (q *QueueInfo) Reclaimable() bool + type Resource struct + MaxTaskNum int + Memory float64 + MilliCPU float64 + ScalarResources map[v1.ResourceName]float64 + func EmptyResource() *Resource + func GetPodResourceRequest(pod *v1.Pod) *Resource + func GetPodResourceWithoutInitContainers(pod *v1.Pod) *Resource + func NewResource(rl v1.ResourceList) *Resource + func (r *Resource) Add(rr *Resource) *Resource + func (r *Resource) AddScalar(name v1.ResourceName, quantity float64) + func (r *Resource) Clone() *Resource + func (r *Resource) Diff(rr *Resource) (*Resource, *Resource) + func (r *Resource) FitDelta(rr *Resource) *Resource + func (r *Resource) Get(rn v1.ResourceName) float64 + func (r *Resource) IsEmpty() bool + func (r *Resource) IsZero(rn v1.ResourceName) bool + func (r *Resource) Less(rr *Resource) bool + func (r *Resource) LessEqual(rr *Resource) bool + func (r *Resource) LessEqualStrict(rr *Resource) bool + func (r *Resource) Multi(ratio float64) *Resource + func (r *Resource) ResourceNames() []v1.ResourceName + func (r *Resource) SetMaxResource(rr *Resource) + func (r *Resource) SetScalar(name v1.ResourceName, quantity float64) + func (r *Resource) String() string + func (r *Resource) Sub(rr *Resource) *Resource + type TaskID types.UID + func PodKey(pod *v1.Pod) TaskID + type TaskInfo struct + InitResreq *Resource + Job JobID + Name string + Namespace string + NodeName string + Pod *v1.Pod + Priority int32 + Resreq *Resource + Status TaskStatus + UID TaskID + VolumeReady bool + func NewTaskInfo(pod *v1.Pod) *TaskInfo + func (ti *TaskInfo) Clone() *TaskInfo + func (ti TaskInfo) String() string + type TaskStatus int + const Allocated + const Binding + const Bound + const Failed + const Pending + const Pipelined + const Releasing + const Running + const Succeeded + const Unknown + func (ts TaskStatus) String() string + type ValidateExFn func(interface{}) *ValidateResult + type ValidateFn func(interface{}) bool + type ValidateResult struct + Message string + Pass bool + Reason string
Go to main page