util

package

Go to main page

Versions in this module

v1

v1.11.0

Jan 24, 2025

Changes in this version

+ func BuildPodWithPreeemptionPolicy(namespace, name, nodeName string, p v1.PodPhase, req v1.ResourceList, ...) *v1.Pod

+ func BuildPriorityClassWithPreemptionPolicy(name string, value int32, preemptionPolicy v1.PreemptionPolicy) *schedulingv1.PriorityClass

v1.11.0-network-topology-preview.0

Jan 23, 2025

v1.10.0

Sep 19, 2024

Changes in this version

+ func BuildPodGroupWithAnno(name, ns, queue string, minMember int32, taskMinMember map[string]int32, ...) *schedulingv1beta1.PodGroup

+ func BuildPodGroupWithMinResources(name, ns, queue string, minMember int32, taskMinMember map[string]int32, ...) *schedulingv1beta1.PodGroup

+ func BuildQueueWithPriorityAndResourcesQuantity(qname string, priority int32, deserved, cap v1.ResourceList) *schedulingv1beta1.Queue

+ func BuildResourceQuota(name, ns string, hard v1.ResourceList) *v1.ResourceQuota

type FakeBinder

+ func NewFakeBinder(buffer int) *FakeBinder

+ func (fb *FakeBinder) Length() int

type FakeEvictor

+ func NewFakeEvictor(buffer int) *FakeEvictor

+ func (fe *FakeEvictor) Length() int

type FakeStatusUpdater

+ func (ftsu *FakeStatusUpdater) UpdatePodStatus(pod *v1.Pod) (*v1.Pod, error)

v1.10.0-alpha.0

Jul 9, 2024

v1.9.0

May 20, 2024 GO-2024-3034

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

Changes in this version

+ func BuildPodGroup(name, ns, queue string, minMember int32, taskMinMember map[string]int32, ...) *schedulingv1beta1.PodGroup

+ func BuildPodGroupWithPrio(name, ns, queue string, minMember int32, taskMinMember map[string]int32, ...) *schedulingv1beta1.PodGroup

+ func BuildPriorityClass(name string, value int32) *schedulingv1.PriorityClass

+ func BuildQueue(qname string, weight int32, cap v1.ResourceList) *schedulingv1beta1.Queue

+ func BuildQueueWithAnnos(qname string, weight int32, cap v1.ResourceList, annos map[string]string) *schedulingv1beta1.Queue

+ func BuildQueueWithResourcesQuantity(qname string, deserved, cap v1.ResourceList) *schedulingv1beta1.Queue

type FakeStatusUpdater

+ func (ftsu *FakeStatusUpdater) UpdateQueueStatus(queue *api.QueueInfo) error

v1.9.0-alpha.0

Feb 2, 2024 GO-2024-3034

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

v1.8.2

Jan 9, 2024 GO-2024-3034

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

v1.8.1

Sep 25, 2023 GO-2024-3034

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

Changes in this version

type StatusSets

+ func (s StatusSets) Message() string

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

v1.8.0

Aug 8, 2023 GO-2024-3034

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

Changes in this version

+ type StatusSets []*api.Status

+ func (s StatusSets) ContainsErrorSkipOrWait() bool

+ func (s StatusSets) ContainsUnschedulable() bool

+ func (s StatusSets) ContainsUnschedulableAndUnresolvable() bool

v1.8.0-alpha.0

Jul 13, 2023 GO-2024-3034

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

v1.7.0

Dec 30, 2022 GO-2024-3034

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

Changes in this version

+ func ConvertRes2ResList(res *api.Resource) v1.ResourceList

v1.7.0-beta.0

Dec 28, 2022 GO-2024-3034

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

v1.6.1

Aug 5, 2022 GO-2024-3034

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

v1.6.1-beta.0

Aug 5, 2022 GO-2024-3034

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

v1.6.1-alpha.0

Aug 1, 2022 GO-2024-3034

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

v1.6.0

Jun 11, 2022 GO-2024-3034

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

Changes in this version

+ func BuildBestEffortPod(namespace, name, nodeName string, p v1.PodPhase, groupName string, ...) *v1.Pod

+ func BuildDynamicPVC(namespace, name string, req v1.ResourceList) (*v1.PersistentVolumeClaim, *v1.PersistentVolume, *storagev1.StorageClass)

+ func BuildPodWithPVC(namespace, name, nodename string, p v1.PodPhase, req v1.ResourceList, ...) *v1.Pod

+ func BuildPodWithPriority(namespace, name, nodeName string, p v1.PodPhase, req v1.ResourceList, ...) *v1.Pod

type FakeVolumeBinder

+ Actions map[string][]string

+ func NewFakeVolumeBinder(kubeClient kubernetes.Interface) *FakeVolumeBinder

+ func (fvb *FakeVolumeBinder) RevertVolumes(task *api.TaskInfo, podVolumes *volumescheduling.PodVolumes)

v1.6.0-alpha.0

Jun 9, 2022 GO-2024-3034

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

v1.5.1

Mar 15, 2022 GO-2024-3034

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

v1.5.1-beta.0

Mar 13, 2022 GO-2024-3034

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

v1.5.0

Feb 20, 2022 GO-2024-3034

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

Changes in this version

+ type PredicateHelper interface

+ PredicateNodes func(task *api.TaskInfo, nodes []*api.NodeInfo, fn api.PredicateFn) ([]*api.NodeInfo, *api.FitErrors)

+ func NewPredicateHelper() PredicateHelper

v1.5.0-Beta

Dec 31, 2021 GO-2024-3034

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

v1.4.1

Feb 20, 2022 GO-2024-3034

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

v1.4.0

Sep 18, 2021 GO-2024-3034

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

v1.4.0-Beta

Sep 3, 2021 GO-2024-3034

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

v1.3.0

May 26, 2021 GO-2024-3034

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

Changes in this version

type FakeVolumeBinder

+ func (fvb *FakeVolumeBinder) GetPodVolumes(task *api.TaskInfo, node *v1.Node) (*volumescheduling.PodVolumes, error)

v1.2.0

Feb 23, 2021 GO-2024-3034

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

Changes in this version

+ func GetMinInt(vals ...int) int

v1.1.2

Jan 8, 2021 GO-2024-3034

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

v1.1.1

Dec 31, 2020 GO-2024-3034

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

v1.1.0

Oct 30, 2020 GO-2024-3034

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

Changes in this version

+ type ResourceReservation struct

+ LockedNodes map[string]*api.NodeInfo

+ TargetJob *api.JobInfo

+ var Reservation *ResourceReservation

+ func NewResourceReservation() *ResourceReservation

v1.1.0-beta.0

Oct 30, 2020 GO-2024-3034

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

v1.0.1

Jul 30, 2020 GO-2024-3034

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

v1.0.0

Jul 8, 2020 GO-2024-3034

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

v0

v0.4.2

Aug 4, 2020 GO-2024-3034

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

v0.4.1

Jul 14, 2020 GO-2024-3034

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

v0.4.1-alpha.0

Apr 8, 2020 GO-2024-3034

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

v0.4.0

Apr 9, 2020 GO-2024-3034

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

Changes in this version

+ func ValidateVictims(preemptor *api.TaskInfo, node *api.NodeInfo, victims []*api.TaskInfo) error

v0.3.0

Feb 21, 2020 GO-2024-3034

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

Changes in this version

+ func BuildNode(name string, alloc v1.ResourceList, labels map[string]string) *v1.Node

+ func BuildPod(namespace, name, nodename string, p v1.PodPhase, req v1.ResourceList, ...) *v1.Pod

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

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

+ func CalculateNumOfFeasibleNodesToFind(numAllNodes int32) (numNodes int32)

+ func GetNodeList(nodes map[string]*api.NodeInfo) []*api.NodeInfo

+ func PredicateNodes(task *api.TaskInfo, nodes []*api.NodeInfo, fn api.PredicateFn) ([]*api.NodeInfo, *api.FitErrors)

+ func PrioritizeNodes(task *api.TaskInfo, nodes []*api.NodeInfo, batchFn api.BatchNodeOrderFn, ...) map[float64][]*api.NodeInfo

+ func SelectBestNode(nodeScores map[float64][]*api.NodeInfo) *api.NodeInfo

+ func SortNodes(nodeScores map[float64][]*api.NodeInfo) []*api.NodeInfo

+ type FakeBinder struct

+ Binds map[string]string

+ Channel chan string

+ func (fb *FakeBinder) Bind(p *v1.Pod, hostname string) error

+ type FakeEvictor struct

+ Channel chan string

+ func (fe *FakeEvictor) Evict(p *v1.Pod) error

+ func (fe *FakeEvictor) Evicts() []string

+ type FakeStatusUpdater struct

+ func (ftsu *FakeStatusUpdater) UpdatePodCondition(pod *v1.Pod, podCondition *v1.PodCondition) (*v1.Pod, error)

+ func (ftsu *FakeStatusUpdater) UpdatePodGroup(pg *api.PodGroup) (*api.PodGroup, error)

+ type FakeVolumeBinder struct

+ func (fvb *FakeVolumeBinder) AllocateVolumes(task *api.TaskInfo, hostname string) error

+ func (fvb *FakeVolumeBinder) BindVolumes(task *api.TaskInfo) error

+ type PriorityQueue struct

+ func NewPriorityQueue(lessFn api.LessFn) *PriorityQueue

+ func (q *PriorityQueue) Empty() bool

+ func (q *PriorityQueue) Len() int

+ func (q *PriorityQueue) Pop() interface{}

+ func (q *PriorityQueue) Push(it interface{})

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