Versions in this module Expand all Collapse all v0 v0.4.2 Mar 29, 2019 v0.4.1 Mar 11, 2019 Changes in this version + const GPUResourceName + func AllocatedStatus(status TaskStatus) bool + func JobTerminated(job *JobInfo) bool + func MergeErrors(errs ...error) error + func ResourceNames() []v1.ResourceName + type ClusterInfo struct + Jobs []*JobInfo + Nodes []*NodeInfo + func (ci ClusterInfo) String() string + type CompareFn func(interface{}, interface{}) int + type JobID types.UID + type JobInfo struct + Allocated *Resource + Candidates []*NodeInfo + MinAvailable int + Name string + Namespace string + NodeSelector map[string]string + PDB *policyv1.PodDisruptionBudget + Priority int + SchedSpec *arbv1.SchedulingSpec + TaskStatusIndex map[TaskStatus]tasksMap + Tasks tasksMap + TotalRequest *Resource + UID JobID + func NewJobInfo(uid JobID) *JobInfo + func (ps *JobInfo) AddTaskInfo(pi *TaskInfo) + func (ps *JobInfo) Clone() *JobInfo + func (ps *JobInfo) DeleteTaskInfo(pi *TaskInfo) error + func (ps *JobInfo) GetTasks(statuses ...TaskStatus) []*TaskInfo + func (ps *JobInfo) SetPDB(pbd *policyv1.PodDisruptionBudget) + func (ps *JobInfo) SetSchedulingSpec(spec *arbv1.SchedulingSpec) + func (ps *JobInfo) UnsetPDB() + func (ps *JobInfo) UnsetSchedulingSpec() + func (ps *JobInfo) UpdateTaskStatus(task *TaskInfo, status TaskStatus) error + func (ps JobInfo) String() string + type LessFn func(interface{}, interface{}) bool + type NodeInfo struct + Allocatable *Resource + Capability *Resource + Idle *Resource + Name string + Node *v1.Node + Releasing *Resource + 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) PipelineTask(task *TaskInfo) error + 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 Resource struct + GPU int64 + Memory float64 + MilliCPU float64 + func EmptyResource() *Resource + func NewResource(rl v1.ResourceList) *Resource + func (r *Resource) Add(rr *Resource) *Resource + func (r *Resource) Clone() *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) String() string + func (r *Resource) Sub(rr *Resource) *Resource + type TaskID types.UID + func PodKey(pod *v1.Pod) TaskID + type TaskInfo struct + Job JobID + Name string + Namespace string + NodeName string + Pod *v1.Pod + Priority int32 + Resreq *Resource + Status TaskStatus + UID TaskID + func NewTaskInfo(pod *v1.Pod) *TaskInfo + func (pi *TaskInfo) Clone() *TaskInfo + func (pi 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 ValidateFn func(interface{}) bool
Go to main page