framework

Jan 24, 2025

Changes in this version

type Event

+ Err error

type Session

+ TotalGuarantee *api.Resource

+ func (ssn *Session) AddVictimQueueOrderFn(name string, vcf api.VictimCompareFn)

+ func (ssn *Session) VictimQueueOrderFn(l, r, preemptor interface{}) bool

+ func (ssn Session) VCClient() vcclient.Interface

type Statement

+ func (s *Statement) UnAllocate(task *api.TaskInfo) error

Sep 19, 2024

Changes in this version

type Session

+ func (ssn *Session) GetUnschedulableAndUnresolvableNodesForTask(task *api.TaskInfo) []*api.NodeInfo

+ func (ssn *Session) PredicateForAllocateAction(task *api.TaskInfo, node *api.NodeInfo) error

+ func (ssn *Session) PredicateForPreemptAction(task *api.TaskInfo, node *api.NodeInfo) error

May 20, 2024 GO-2024-3034

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

Changes in this version

type Session

+ func (ssn *Session) AddPreemptiveFn(name string, fn api.ValidateFn)

+ func (ssn *Session) BuildVictimsPriorityQueue(victims []*api.TaskInfo) *util.PriorityQueue

+ func (ssn *Session) Preemptive(queue *api.QueueInfo) bool

type Statement

+ func (s *Statement) UnPipeline(task *api.TaskInfo) 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

Aug 8, 2023 GO-2024-3034

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

Changes in this version

+ func ConvertPredicateStatus(status *k8sframework.Status) (*api.Status, error)

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

+ func HaveAffinity(pod *v1.Pod) bool

+ type CachedNodeInfo struct

+ Session *Session

+ func (c *CachedNodeInfo) GetNodeInfo(name string) (*v1.Node, error)

+ type NodeLister struct

+ Session *Session

+ func (nl *NodeLister) List() ([]*v1.Node, error)

+ type PodAffinityLister struct

+ func (pal *PodAffinityLister) FilteredList(podFilter PodFilter, selector labels.Selector) ([]*v1.Pod, error)

+ func (pal *PodAffinityLister) List(selector labels.Selector) ([]*v1.Pod, error)

+ type PodFilter func(*v1.Pod) bool

+ type PodLister struct

+ CachedPods map[api.TaskID]*v1.Pod

+ Session *Session

+ TaskWithAffinity map[api.TaskID]*api.TaskInfo

+ Tasks map[api.TaskID]*api.TaskInfo

+ func NewPodLister(ssn *Session) *PodLister

+ func NewPodListerFromNode(ssn *Session) *PodLister

+ func (pl *PodLister) AffinityFilteredList(podFilter PodFilter, selector labels.Selector) ([]*v1.Pod, error)

+ func (pl *PodLister) AffinityLister() *PodAffinityLister

+ func (pl *PodLister) FilteredList(podFilter PodFilter, selector labels.Selector) ([]*v1.Pod, error)

+ func (pl *PodLister) GetPod(task *api.TaskInfo) *v1.Pod

+ func (pl *PodLister) List(selector labels.Selector) ([]*v1.Pod, error)

+ func (pl *PodLister) UpdateTask(task *api.TaskInfo, nodeName string) *v1.Pod

+ type PodsLister interface

+ FilteredList func(podFilter PodFilter, selector labels.Selector) ([]*v1.Pod, error)

+ List func(labels.Selector) ([]*v1.Pod, error)

type Session

+ NodeMap map[string]*k8sframework.NodeInfo

+ PodLister *PodLister

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

type Session

+ func (ssn *Session) AddPrePredicateFn(name string, pf api.PrePredicateFn)

+ func (ssn *Session) PrePredicateFn(task *api.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 Session

+ CSINodesStatus map[string]*api.CSINodeStatusInfo

+ func (ssn Session) ClientConfig() *rest.Config

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

type Session

+ func (ssn Session) RecordPodGroupEvent(podGroup *schedulingapi.PodGroup, eventType, reason, msg string)

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 Session

+ func (ssn *Session) AddAllocatableFn(name string, fn api.AllocatableFn)

+ func (ssn *Session) Allocatable(queue *api.QueueInfo, candidate *api.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

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

type Session

+ NodeList []*api.NodeInfo

+ TotalResource *api.Resource

+ func (ssn *Session) AddClusterOrderFn(name string, qf api.CompareFn)

+ func (ssn *Session) AddJobEnqueuedFn(name string, fn api.JobEnqueuedFn)

+ func (ssn *Session) AddUnderusedResourceFn(name string, fn api.UnderUsedResourceFn)

+ func (ssn *Session) BindPodGroup(job *api.JobInfo, cluster string) error

+ func (ssn *Session) ClusterOrderFn(l, r interface{}) bool

+ func (ssn *Session) JobEnqueued(obj interface{})

+ func (ssn *Session) UnderusedResources(queue *api.QueueInfo) api.ResourceNameList

+ func (ssn *Session) UpdateSchedulerNumaInfo(AllocatedSets map[string]api.ResNumaSets)

+ func (ssn Session) InformerFactory() informers.SharedInformerFactory

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

Feb 23, 2021 GO-2024-3034

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

Changes in this version

type Session

+ RevocableNodes map[string]*api.NodeInfo

+ func (ssn *Session) AddJobStarvingFns(name string, fn api.ValidateFn)

+ func (ssn *Session) AddVictimTasksFns(name string, fn api.VictimTasksFn)

+ func (ssn *Session) JobStarving(obj interface{}) bool

+ func (ssn *Session) VictimTasks() []*api.TaskInfo

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

+ func LoadCustomPlugins(pluginsDir string) error

Oct 30, 2020 GO-2024-3034

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

Changes in this version

type Session

+ func (ssn *Session) AddReservedNodesFn(name string, fn api.ReservedNodesFn)

+ func (ssn *Session) AddTargetJobFn(name string, fn api.TargetJobFn)

+ func (ssn *Session) ReservedNodes()

+ func (ssn *Session) TargetJob(jobs []*api.JobInfo) *api.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 Allocate

+ const Evict

+ const Pipeline

+ func NewFrameworkHandle(pods []*v1.Pod, nodes []*v1.Node) v1alpha1.FrameworkHandle

+ type Operation int8

type Session

+ func (ssn Session) KubeClient() kubernetes.Interface

type Statement

+ func NewStatement(ssn *Session) *Statement

Aug 4, 2020 GO-2024-3034

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

Changes in this version

type Session

+ func (ssn *Session) UpdatePodGroupCondition(jobInfo *api.JobInfo, cond *scheduling.PodGroupCondition) error

Jul 14, 2020 GO-2024-3034

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

Changes in this version

type Session

+ func (ssn *Session) AddBestNodeFn(name string, pf api.BestNodeFn)

+ func (ssn *Session) BestNodeFn(task *api.TaskInfo, nodeScores map[float64][]*api.NodeInfo) *api.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

Feb 21, 2020 GO-2024-3034

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

Changes in this version

+ func CleanupPluginBuilders()

+ func CloseSession(ssn *Session)

+ func RegisterAction(act Action)

+ func RegisterPluginBuilder(name string, pc PluginBuilder)

+ func TimeJitterAfter(new, old time.Time, duration, maxJitter time.Duration) bool

+ type Action interface

+ Execute func(ssn *Session)

+ Initialize func()

+ Name func() string

+ UnInitialize func()

+ func GetAction(name string) (Action, bool)

+ type Arguments map[string]string

+ func GetArgOfActionFromConf(configurations []conf.Configuration, actionName string) Arguments

+ func (a Arguments) GetBool(ptr *bool, key string)

+ func (a Arguments) GetFloat64(ptr *float64, key string)

+ func (a Arguments) GetInt(ptr *int, key string)

+ type Event struct

+ Task *api.TaskInfo

+ type EventHandler struct

+ AllocateFunc func(event *Event)

+ DeallocateFunc func(event *Event)

+ type Plugin interface

+ Name func() string

+ OnSessionClose func(ssn *Session)

+ OnSessionOpen func(ssn *Session)

+ type PluginBuilder func(Arguments) Plugin

+ func GetPluginBuilder(name string) (PluginBuilder, bool)

+ type Session struct

+ Backlog []*api.JobInfo

+ Configurations []conf.Configuration

+ Jobs map[api.JobID]*api.JobInfo

+ NamespaceInfo map[api.NamespaceName]*api.NamespaceInfo

+ Nodes map[string]*api.NodeInfo

+ Queues map[api.QueueID]*api.QueueInfo

+ Tiers []conf.Tier

+ UID types.UID

+ func OpenSession(cache cache.Cache, tiers []conf.Tier, configurations []conf.Configuration) *Session

+ func (ssn *Session) AddBatchNodeOrderFn(name string, pf api.BatchNodeOrderFn)

+ func (ssn *Session) AddEventHandler(eh *EventHandler)

+ func (ssn *Session) AddJobEnqueueableFn(name string, fn api.ValidateFn)

+ func (ssn *Session) AddJobOrderFn(name string, cf api.CompareFn)

+ func (ssn *Session) AddJobPipelinedFn(name string, vf api.ValidateFn)

+ func (ssn *Session) AddJobReadyFn(name string, vf api.ValidateFn)

+ func (ssn *Session) AddJobValidFn(name string, fn api.ValidateExFn)

+ func (ssn *Session) AddNamespaceOrderFn(name string, cf api.CompareFn)

+ func (ssn *Session) AddNodeMapFn(name string, pf api.NodeMapFn)

+ func (ssn *Session) AddNodeOrderFn(name string, pf api.NodeOrderFn)

+ func (ssn *Session) AddNodeReduceFn(name string, pf api.NodeReduceFn)

+ func (ssn *Session) AddOverusedFn(name string, fn api.ValidateFn)

+ func (ssn *Session) AddPredicateFn(name string, pf api.PredicateFn)

+ func (ssn *Session) AddPreemptableFn(name string, cf api.EvictableFn)

+ func (ssn *Session) AddQueueOrderFn(name string, qf api.CompareFn)

+ func (ssn *Session) AddReclaimableFn(name string, rf api.EvictableFn)

+ func (ssn *Session) AddTaskOrderFn(name string, cf api.CompareFn)

+ func (ssn *Session) Allocate(task *api.TaskInfo, hostname string) error

+ func (ssn *Session) BatchNodeOrderFn(task *api.TaskInfo, nodes []*api.NodeInfo) (map[string]float64, error)

+ func (ssn *Session) Evict(reclaimee *api.TaskInfo, reason string) error

+ func (ssn *Session) JobEnqueueable(obj interface{}) bool

+ func (ssn *Session) JobOrderFn(l, r interface{}) bool

+ func (ssn *Session) JobPipelined(obj interface{}) bool

+ func (ssn *Session) JobReady(obj interface{}) bool

+ func (ssn *Session) JobValid(obj interface{}) *api.ValidateResult

+ func (ssn *Session) NamespaceOrderFn(l, r interface{}) bool

+ func (ssn *Session) NodeOrderFn(task *api.TaskInfo, node *api.NodeInfo) (float64, error)

+ func (ssn *Session) NodeOrderMapFn(task *api.TaskInfo, node *api.NodeInfo) (map[string]float64, float64, error)

+ func (ssn *Session) NodeOrderReduceFn(task *api.TaskInfo, ...) (map[string]float64, error)

+ func (ssn *Session) Overused(queue *api.QueueInfo) bool

+ func (ssn *Session) Pipeline(task *api.TaskInfo, hostname string) error

+ func (ssn *Session) PredicateFn(task *api.TaskInfo, node *api.NodeInfo) error

+ func (ssn *Session) Preemptable(preemptor *api.TaskInfo, preemptees []*api.TaskInfo) []*api.TaskInfo

+ func (ssn *Session) QueueOrderFn(l, r interface{}) bool

+ func (ssn *Session) Reclaimable(reclaimer *api.TaskInfo, reclaimees []*api.TaskInfo) []*api.TaskInfo

+ func (ssn *Session) Statement() *Statement

+ func (ssn *Session) TaskCompareFns(l, r interface{}) int

+ func (ssn *Session) TaskOrderFn(l, r interface{}) bool

+ func (ssn *Session) UpdateJobCondition(jobInfo *api.JobInfo, cond *scheduling.PodGroupCondition) error

+ func (ssn Session) String() string

+ type Statement struct

+ func (s *Statement) Allocate(task *api.TaskInfo, hostname string) error

+ func (s *Statement) Commit()

+ func (s *Statement) Discard()

+ func (s *Statement) Evict(reclaimee *api.TaskInfo, reason string) error

+ func (s *Statement) Pipeline(task *api.TaskInfo, hostname string) error