api

Sep 19, 2024

Changes in this version

+ const PodReasonSchedulerError

type FitError

+ Status StatusSets

+ func NewFitErrWithStatus(task *TaskInfo, node *NodeInfo, sts ...*Status) *FitError

type FitErrors

+ func (f *FitErrors) GetUnschedulableAndUnresolvableNodes() map[string]sets.Empty

type JobInfo

+ func (ji *JobInfo) DeductSchGatedResources(res *Resource) *Resource

+ func (ji *JobInfo) FitFailedRoles() map[string]struct{}

+ func (ji *JobInfo) GetSchGatedPodResources() *Resource

+ func (ji *JobInfo) NeedContinueAllocating() bool

+ func (ji *JobInfo) ParseMinMemberInfo(pg *PodGroup)

+ func (ji *JobInfo) TaskHasFitErrors(task *TaskInfo) bool

type Resource

+ func (r *Resource) LessEqualWithDimension(rr *Resource, req *Resource) bool

type Status

+ Plugin string

+ func ConvertPredicateStatus(status *k8sframework.Status) *Status

+ type StatusSets []*Status

+ func (s StatusSets) ContainsErrorSkipOrWait() bool

+ func (s StatusSets) ContainsUnschedulable() bool

+ func (s StatusSets) ContainsUnschedulableAndUnresolvable() bool

+ func (s StatusSets) Message() string

+ func (s StatusSets) Reasons() []string

type TaskInfo

+ HasRestartableInitContainer bool

+ SchGated bool

+ TaskRole string

type TransactionContext

+ EvictionOccurred bool

+ type ValidateWithCandidateFn func(interface{}, interface{}) bool

May 20, 2024 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

type Devices

+ ScoreNode func(pod *v1.Pod, policy string) float64

type JobInfo

+ PgUID types.UID

+ func (ji *JobInfo) IsPipelined() bool

+ func (ji *JobInfo) IsReady() bool

+ func (ji *JobInfo) IsStarving() bool

+ func (ji *JobInfo) PendingBestEffortTaskNum() int32

type Resource

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

Feb 2, 2024 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Jan 9, 2024 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

+ func BuildResourceList(cpu string, memory string, scalarResources ...ScalarResource) v1.ResourceList

+ func BuildResourceListWithGPU(cpu string, memory string, GPU string, scalarResources ...ScalarResource) v1.ResourceList

+ func IsIgnoredScalarResource(name v1.ResourceName) bool

+ func PreemptableStatus(status TaskStatus) bool

type NodeUsage

+ MetricsTime time.Time

+ type ScalarResource struct

+ Name string

+ Value string

Sep 25, 2023 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

type Status

+ func (s Status) String() string

type TaskInfo

+ CustomBindErrHandler func() error

+ CustomBindErrHandlerSucceeded bool

Aug 8, 2023 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

+ const Error

+ const GPUSharingDevice

+ const Skip

+ const Success

+ const Unschedulable

+ const UnschedulableAndUnresolvable

+ const Wait

+ var IgnoredDevicesList []string

+ var RegisteredDevices = []string

+ func WrapInsufficientResourceReason(resources []string) string

+ type Devices interface

+ AddResource func(pod *v1.Pod)

+ Allocate func(kubeClient kubernetes.Interface, pod *v1.Pod) error

+ FilterNode func(pod *v1.Pod) (int, string, error)

+ GetIgnoredDevices func() []string

+ GetStatus func() string

+ HasDeviceRequest func(pod *v1.Pod) bool

+ Release func(kubeClient kubernetes.Interface, pod *v1.Pod) error

+ SubResource func(pod *v1.Pod)

type JobInfo

+ func (ji *JobInfo) HasPendingTasks() bool

type NodeInfo

+ Capacity *Resource

+ func (ni *NodeInfo) CloneImageSummary() map[string]*k8sframework.ImageStateSummary

+ func (ni *NodeInfo) CloneOthers() map[string]interface{}

type Resource

+ func (r *Resource) LessEqualWithResourcesName(rr *Resource, defaultValue DimensionDefaultValue) (bool, []string)

+ type Status struct

+ Code int

+ Reason string

Jul 13, 2023 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Dec 30, 2022 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

+ func GetGPUMemoryOfPod(pod *v1.Pod) uint

+ func GetGPUNumberOfPod(pod *v1.Pod) int

type NodeInfo

+ ImageStates map[string]*k8sframework.ImageStateSummary

+ func (ni *NodeInfo) CloneImageSumary() map[string]*k8sframework.ImageStateSummary

+ func (ni *NodeInfo) GetDevicesIdleGPUs() []int

+ type PrePredicateFn func(*TaskInfo) error

Dec 28, 2022 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Aug 5, 2022 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

+ type CSINodeStatusInfo struct

+ CSINodeName string

+ DriverStatus map[string]bool

+ func (cs *CSINodeStatusInfo) Clone() *CSINodeStatusInfo

type ClusterInfo

+ CSINodesStatus map[string]*CSINodeStatusInfo

Aug 5, 2022 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Aug 1, 2022 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Jun 11, 2022 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

+ const UnhealthyGPUIDs

+ func IsCountQuota(name v1.ResourceName) bool

type JobInfo

+ func (ji *JobInfo) CheckTaskPipelined() bool

+ func (ji *JobInfo) CheckTaskReady() bool

+ func (ji *JobInfo) CheckTaskStarving() bool

+ func (ji *JobInfo) CheckTaskValid() bool

+ func (ji *JobInfo) GetElasticResources() *Resource

type NamespaceCollection

+ QuotaStatus map[string]v1.ResourceQuotaStatus

type NamespaceInfo

+ QuotaStatus map[string]v1.ResourceQuotaStatus

type NodeInfo

+ ResourceUsage *NodeUsage

+ type NodeUsage struct

+ CPUUsageAvg map[string]float64

+ MEMUsageAvg map[string]float64

+ func (nu *NodeUsage) DeepCopy() *NodeUsage

type NumaChgFlag

+ const DefaultMaxNodeScore

+ type ScoredNode struct

+ NodeName string

+ Score int64

Jun 9, 2022 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Mar 15, 2022 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

+ type AllocatableFn func(*QueueInfo, *TaskInfo) bool

Mar 13, 2022 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Feb 20, 2022 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

+ const TaskPriorityAnnotation

+ func GetPodResourceNumaInfo(ti *TaskInfo) map[int]v1.ResourceList

+ func ResFloat642Quantity(resName v1.ResourceName, quantity float64) resource.Quantity

+ func ResQuantity2Float64(resName v1.ResourceName, quantity resource.Quantity) float64

+ type AllocateFailError struct

+ Reason string

+ func (o *AllocateFailError) Error() string

type JobInfo

+ func (ji *JobInfo) CheckTaskMinAvailablePipelined() bool

+ func (ji *JobInfo) CheckTaskMinAvailableReady() bool

type NumatopoInfo

+ func (info *NumatopoInfo) AddTask(ti *TaskInfo)

+ func (info *NumatopoInfo) RemoveTask(ti *TaskInfo)

type PodGroup

+ func (pg *PodGroup) Clone() *PodGroup

+ type PodResourceDecision struct

+ NUMAResources map[int]v1.ResourceList

type ResourceInfo

+ AllocatablePerNuma map[int]float64

+ UsedPerNuma map[int]float64

type TaskInfo

+ BestEffort bool

+ NumaInfo *TopologyInfo

+ func (ti *TaskInfo) GetTaskSpecKey() TaskID

+ func (ti *TaskInfo) SetPodResourceDecision() error

+ func (ti *TaskInfo) UnsetPodResourceDecision()

+ type TopologyInfo struct

+ Policy string

+ ResMap map[int]v1.ResourceList

+ func GetPodTopologyInfo(pod *v1.Pod) *TopologyInfo

+ func (info *TopologyInfo) Clone() *TopologyInfo

Dec 31, 2021 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Feb 20, 2022 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Sep 18, 2021 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

+ const OfflineJobEvicting

+ const OversubscriptionCPU

+ const OversubscriptionMemory

+ const OversubscriptionNode

+ const PodReasonSchedulable

+ const PodReasonUndetermined

+ const PodReasonUnschedulable

+ func GenerateNodeResNumaSets(nodes map[string]*NodeInfo) map[string]ResNumaSets

+ func GenerateNumaNodes(nodes map[string]*NodeInfo) map[string][]int

+ func GetMinResource() float64

+ func GetPodTopologyPolicy(pod *v1.Pod) string

+ func ParseResourceList(m map[string]string) (v1.ResourceList, error)

+ type ClusterID types.UID

type ClusterInfo

+ NodeList []string

+ type DimensionDefaultValue string

+ const Infinity

+ const Zero

+ type JobEnqueuedFn func(interface{})

type JobInfo

+ func (ji *JobInfo) IsPending() bool

+ func (ji *JobInfo) TaskSchedulingReason(tid TaskID) (reason string, msg string)

type NodeInfo

+ NumaChgFlag NumaChgFlag

+ NumaInfo *NumatopoInfo

+ NumaSchedulerInfo *NumatopoInfo

+ OfflineJobEvicting bool

+ OversubscriptionNode bool

+ OversubscriptionResource *Resource

+ func (ni *NodeInfo) GetNodeAllocatable() *Resource

+ func (ni *NodeInfo) RefreshNumaSchedulerInfoByCrd()

+ type NumaChgFlag int

+ const NumaInfoLessFlag

+ const NumaInfoMoreFlag

+ const NumaInfoResetFlag

+ type NumatopoInfo struct

+ CPUDetail topology.CPUDetails

+ Name string

+ Namespace string

+ NumaResMap map[string]*ResourceInfo

+ Policies map[nodeinfov1alpha1.PolicyName]string

+ ResReserved v1.ResourceList

+ func (info *NumatopoInfo) Allocate(resSets ResNumaSets)

+ func (info *NumatopoInfo) Compare(newInfo *NumatopoInfo) bool

+ func (info *NumatopoInfo) DeepCopy() *NumatopoInfo

+ func (info *NumatopoInfo) Release(resSets ResNumaSets)

+ type ResNumaSets map[string]cpuset.CPUSet

+ func (resSets ResNumaSets) Allocate(taskSets ResNumaSets)

+ func (resSets ResNumaSets) Clone() ResNumaSets

+ func (resSets ResNumaSets) Release(taskSets ResNumaSets)

type Resource

+ func (r *Resource) Equal(rr *Resource, defaultValue DimensionDefaultValue) bool

+ func (r *Resource) LessEqualPartly(rr *Resource, defaultValue DimensionDefaultValue) bool

+ func (r *Resource) LessPartly(rr *Resource, defaultValue DimensionDefaultValue) bool

+ type ResourceInfo struct

+ Allocatable cpuset.CPUSet

+ Capacity int

+ type ResourceNameList []v1.ResourceName

+ func (r ResourceNameList) Contains(rr ResourceNameList) bool

+ type SiloClusterInfo struct

+ Cluster *scheduling.Cluster

+ UID ClusterID

+ func NewSiloClusterInfo(cluster *scheduling.Cluster) *SiloClusterInfo

type TaskInfo

+ LastTransaction *TransactionContext

+ TopologyPolicy string

+ func (ti *TaskInfo) ClearLastTxContext()

+ func (ti *TaskInfo) GenerateLastTxContext()

+ func (ti *TaskInfo) GetTransactionContext() TransactionContext

+ type TransactionContext struct

+ NodeName string

+ Status TaskStatus

+ func (ctx *TransactionContext) Clone() *TransactionContext

+ type UnderUsedResourceFn func(*QueueInfo) ResourceNameList

Sep 3, 2021 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

May 26, 2021 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

type JobInfo

+ TaskMinAvailable map[TaskID]int32

+ TaskMinAvailableTotal int32

+ func (ji *JobInfo) CheckTaskMinAvailable() bool

+ func (ji *JobInfo) GetMinResources() *Resource

type NodeInfo

+ func (ni *NodeInfo) AddBindingTask(task TaskID)

+ func (ni *NodeInfo) GetBindingTasks() []TaskID

+ func (ni *NodeInfo) RemoveBindingTask(task TaskID)

type TaskInfo

+ PodVolumes *volumescheduling.PodVolumes

Feb 23, 2021 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

+ const JobWaitingTime

+ func GetJobPreemptable(pg *PodGroup) bool

+ func GetJobRevocableZone(pg *PodGroup) string

+ func GetPodPreemptable(pod *v1.Pod) bool

+ func GetPodRevocableZone(pod *v1.Pod) string

+ func GetWaitingTime(pg *PodGroup) (*time.Duration, error)

type ClusterInfo

+ RevocableNodes map[string]*NodeInfo

+ type DisruptionBudget struct

+ MaxUnavilable string

+ MinAvailable string

+ func GetBudget(pg *PodGroup) *DisruptionBudget

+ func NewDisruptionBudget(minAvailable, maxUnavilable string) *DisruptionBudget

+ func (db *DisruptionBudget) Clone() *DisruptionBudget

type JobInfo

+ Budget *DisruptionBudget

+ Preemptable bool

+ RevocableZone string

+ WaitingTime *time.Duration

type NodeInfo

+ RevocableZone string

type TaskInfo

+ Preemptable bool

+ RevocableZone string

+ type VictimTasksFn func() []*TaskInfo

+ type VoteFn func(interface{}) int

Jan 8, 2021 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Dec 31, 2020 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

type Resource

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

Oct 30, 2020 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

type JobInfo

+ ScheduleStartTimestamp metav1.Time

type QueueInfo

+ Hierarchy string

+ Weights string

+ type ReservedNodesFn func()

type Resource

+ func (r *Resource) Scale(scale float64) *Resource

+ type TargetJobFn func([]*JobInfo) *JobInfo

Oct 30, 2020 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Jul 30, 2020 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Jul 8, 2020 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

+ const GPUIndex

+ const PredicateTime

+ const VolcanoGPUNumber

+ const VolcanoGPUResource

+ func AddGPUIndexPatch(id int) string

+ func GetGPUIndex(pod *v1.Pod) int

+ func GetGPUResourceOfPod(pod *v1.Pod) uint

+ func RemoveGPUIndexPatch() string

+ type GPUDevice struct

+ ID int

+ Memory uint

+ PodMap map[string]*v1.Pod

+ func NewGPUDevice(id int, mem uint) *GPUDevice

type NodeInfo

+ GPUDevices map[int]*GPUDevice

+ func (ni *NodeInfo) AddGPUResource(pod *v1.Pod)

+ func (ni *NodeInfo) GetDevicesIdleGPUMemory() map[int]uint

+ func (ni *NodeInfo) SubGPUResource(pod *v1.Pod)

Aug 4, 2020 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Jul 14, 2020 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

+ type BestNodeFn func(*TaskInfo, map[float64][]*NodeInfo) *NodeInfo

Apr 8, 2020 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Apr 9, 2020 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

Changes in this version

+ const PodGroupVersionV1Beta1

Feb 21, 2020 GO-2024-3034

  GO-2024-3034: Volcano has insecure permissions in volcano.sh/volcano

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