util

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)

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

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

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

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

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 ConvertRes2ResList(res *api.Resource) v1.ResourceList

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

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

+ 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)

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

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

+ type PredicateHelper interface

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

+ func NewPredicateHelper() PredicateHelper

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

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 FakeVolumeBinder

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

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

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

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

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

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

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

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

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{})