Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

api

package

Go to main page

Versions in this module

v0

v0.4.2

Mar 29, 2019

Changes in this version

type Resource

+ func GetPodResourceRequest(pod *v1.Pod) *Resource

+ func GetPodResourceWithoutInitContainers(pod *v1.Pod) *Resource

+ func (r *Resource) SetMaxResource(rr *Resource)

type TaskInfo

+ InitResreq *Resource

v0.4.1

Mar 11, 2019

Changes in this version

+ type EvictableFn func(*TaskInfo, []*TaskInfo) []*TaskInfo

type JobInfo

+ CreationTimestamp metav1.Time

+ NodesFitDelta NodeResourceMap

+ func (ji *JobInfo) FitError() string

+ type NodeOrderFn func(*TaskInfo, *NodeInfo) (int, error)

+ type NodeResourceMap map[string]*Resource

type Resource

+ MaxTaskNum int

+ func (r *Resource) FitDelta(rr *Resource) *Resource

type TaskInfo

+ VolumeReady bool

+ type ValidateExFn func(interface{}) *ValidateResult

+ type ValidateResult struct

+ Message string

+ Pass bool

+ Reason string

v0.2.0

Oct 15, 2018

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

+ Others []*TaskInfo

+ Queues []*QueueInfo

+ func (ci ClusterInfo) String() string

+ type CompareFn func(interface{}, interface{}) int

+ type JobID types.UID

+ type JobInfo struct

+ Allocated *Resource

+ MinAvailable int32

+ Name string

+ Namespace string

+ NodeSelector map[string]string

+ PDB *policyv1.PodDisruptionBudget

+ PodGroup *arbcorev1.PodGroup

+ Priority int

+ Queue QueueID

+ TaskStatusIndex map[TaskStatus]tasksMap

+ Tasks tasksMap

+ TotalRequest *Resource

+ UID JobID

+ func NewJobInfo(uid JobID) *JobInfo

+ func (ji *JobInfo) AddTaskInfo(ti *TaskInfo)

+ func (ji *JobInfo) Clone() *JobInfo

+ func (ji *JobInfo) DeleteTaskInfo(ti *TaskInfo) error

+ func (ji *JobInfo) GetTasks(statuses ...TaskStatus) []*TaskInfo

+ func (ji *JobInfo) SetPDB(pdb *policyv1.PodDisruptionBudget)

+ func (ji *JobInfo) SetPodGroup(pg *arbcorev1.PodGroup)

+ func (ji *JobInfo) UnsetPDB()

+ func (ji *JobInfo) UnsetPodGroup()

+ func (ji *JobInfo) UpdateTaskStatus(task *TaskInfo, status TaskStatus) error

+ func (ji 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) Pods() (pods []*v1.Pod)

+ 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 PredicateFn func(*TaskInfo, *NodeInfo) error

+ type PreemptableFn func(*TaskInfo, []*TaskInfo) []*TaskInfo

+ type QueueID types.UID

+ type QueueInfo struct

+ Name string

+ Queue *arbcorev1.Queue

+ UID QueueID

+ Weight int32

+ func NewQueueInfo(queue *arbcorev1.Queue) *QueueInfo

+ func (q *QueueInfo) Clone() *QueueInfo

+ type ReclaimableFn func(*TaskInfo, []*TaskInfo) []*TaskInfo

+ type Resource struct

+ Memory float64

+ MilliCPU float64

+ MilliGPU 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) Multi(ratio float64) *Resource

+ 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 (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 ValidateFn func(interface{}) bool