api

package

Go to main page

Versions in this module

v0

v0.5.0

Jul 25, 2019

Changes in this version

+ const PodGroupPending

+ const PodGroupRunning

+ const PodGroupUnknown

+ const PodGroupVersionV1Alpha1

+ const PodGroupVersionV1Alpha2

+ const QueueVersionV1Alpha1

+ const QueueVersionV1Alpha2

+ func ConvertPodGroupInfoToV1Alpha(pg *PodGroup) (*v1alpha1.PodGroup, error)

+ func ConvertPodGroupInfoToV2Alpha(pg *PodGroup) (*v1alpha2.PodGroup, error)

type JobInfo

+ func (ji *JobInfo) Pipelined() bool

+ func (ji *JobInfo) Ready() bool

+ func (ji *JobInfo) ReadyTaskNum() int32

+ func (ji *JobInfo) ValidTaskNum() int32

+ func (ji *JobInfo) WaitingTaskNum() int32

type NodeInfo

+ State NodeState

+ func (ni *NodeInfo) Ready() bool

+ type NodePhase int

+ const NotReady

+ const Ready

+ func (np NodePhase) String() string

+ type NodeState struct

+ Phase NodePhase

+ Reason string

+ type PodGroup struct

+ Spec PodGroupSpec

+ Status PodGroupStatus

+ Version string

+ func ConvertV1Alpha1ToPodGroupInfo(pg *v1alpha1.PodGroup) (*PodGroup, error)

+ func ConvertV1Alpha2ToPodGroupInfo(pg *v1alpha2.PodGroup) (*PodGroup, error)

+ type PodGroupCondition struct

+ LastTransitionTime metav1.Time

+ Message string

+ Reason string

+ Status v1.ConditionStatus

+ TransitionID string

+ Type PodGroupConditionType

+ type PodGroupConditionType string

+ const PodGroupUnschedulableType

+ type PodGroupPhase string

+ type PodGroupSpec struct

+ MinMember int32

+ PriorityClassName string

+ Queue string

+ type PodGroupStatus struct

+ Conditions []PodGroupCondition

+ Failed int32

+ Phase PodGroupPhase

+ Running int32

+ Succeeded int32

+ type Queue struct

+ Spec QueueSpec

+ Status QueueStatus

+ Version string

+ type QueueSpec struct

+ Capability v1.ResourceList

+ Weight int32

+ type QueueStatus struct

+ Pending int32

+ Running int32

+ Unknown int32

type Resource

+ ScalarResources map[v1.ResourceName]float64

+ func (r *Resource) AddScalar(name v1.ResourceName, quantity float64)

+ func (r *Resource) Diff(rr *Resource) (*Resource, *Resource)

+ func (r *Resource) ResourceNames() []v1.ResourceName

+ func (r *Resource) SetScalar(name v1.ResourceName, quantity float64)

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL