cache

Sep 19, 2024

Changes in this version

type StatusUpdater

+ UpdatePodStatus func(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

type DefaultBinder

+ func NewDefaultBinder(kbclient kubernetes.Interface, record record.EventRecorder) *DefaultBinder

type Dumper

+ RootDir string

type SchedulerCache

+ func NewCustomMockSchedulerCache(schedulerName string, binder Binder, evictor Evictor, ...) *SchedulerCache

+ func NewDefaultMockSchedulerCache(schedulerName string) *SchedulerCache

+ func (sc *SchedulerCache) SetSharedInformerFactory(factory informers.SharedInformerFactory)

type StatusUpdater

+ UpdateQueueStatus func(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

Changes in this version

+ var DefaultAttachableVolumeQuantity int64 = math.MaxInt32

type SchedulerCache

+ IgnoredCSIProvisioners sets.Set[string]

+ func (sc *SchedulerCache) AddOrUpdateNode(node *v1.Node) error

+ func (sc *SchedulerCache) NewTaskInfo(pod *v1.Pod) (*schedulingapi.TaskInfo, error)

+ func (sc *SchedulerCache) RemoveNode(nodeName string) error

+ func (sc *SchedulerCache) SyncNode(nodeName string) error

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

+ type Dumper struct

+ Cache Cache

+ func (d *Dumper) ListenForSignal(stopCh <-chan struct{})

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 Cache

+ UpdateQueueStatus func(queue *api.QueueInfo) error

type SchedulerCache

+ DeletedJobs workqueue.RateLimitingInterface

+ func (sc *SchedulerCache) UpdateQueueStatus(queue *schedulingapi.QueueInfo) 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 Cache

+ ClientConfig func() *rest.Config

type SchedulerCache

+ CSINodesStatus map[string]*schedulingapi.CSINodeStatusInfo

+ func (sc *SchedulerCache) AddOrUpdateCSINode(obj interface{})

+ func (sc *SchedulerCache) ClientConfig() *rest.Config

+ func (sc *SchedulerCache) DeleteCSINode(obj interface{})

+ func (sc *SchedulerCache) UpdateCSINode(oldObj, newObj interface{})

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 Cache

+ EventRecorder func() record.EventRecorder

+ RevertVolumes func(task *api.TaskInfo, podVolumes *scheduling.PodVolumes)

+ SetMetricsConf func(conf map[string]string)

type SchedulerCache

+ func (sc *SchedulerCache) EventRecorder() record.EventRecorder

+ func (sc *SchedulerCache) GetMetricsData()

+ func (sc *SchedulerCache) RevertVolumes(task *schedulingapi.TaskInfo, podVolumes *volumescheduling.PodVolumes)

+ func (sc *SchedulerCache) SetMetricsConf(conf map[string]string)

type VolumeBinder

+ RevertVolumes func(task *api.TaskInfo, podVolumes *scheduling.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

+ func RegisterBindMethod(binder Binder)

type Binder

+ func GetBindMethod() Binder

type Cache

+ AddBindTask func(task *api.TaskInfo) error

+ type DefaultBinder struct

+ func NewBinder() *DefaultBinder

+ func (db *DefaultBinder) Bind(kubeClient *kubernetes.Clientset, tasks []*schedulingapi.TaskInfo) ([]*schedulingapi.TaskInfo, error)

type SchedulerCache

+ BindFlowChannel chan *schedulingapi.TaskInfo

+ func (sc *SchedulerCache) AddBindTask(taskInfo *schedulingapi.TaskInfo) error

+ func (sc *SchedulerCache) AddJob(obj interface{})

+ func (sc *SchedulerCache) BindTask()

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 BatchBinder interface

+ Bind func(job *api.JobInfo, cluster string) (*api.JobInfo, error)

type Cache

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

+ SharedInformerFactory func() informers.SharedInformerFactory

+ UpdateSchedulerNumaInfo func(sets map[string]api.ResNumaSets) error

type SchedulerCache

+ NodeList []string

+ PodGroupBinder BatchBinder

+ func (sc *SchedulerCache) AddNumaInfoV1alpha1(obj interface{})

+ func (sc *SchedulerCache) BindPodGroup(job *schedulingapi.JobInfo, cluster string) error

+ func (sc *SchedulerCache) DeleteNumaInfoV1alpha1(obj interface{})

+ func (sc *SchedulerCache) SharedInformerFactory() informers.SharedInformerFactory

+ func (sc *SchedulerCache) UpdateNumaInfoV1alpha1(oldObj, newObj interface{})

+ func (sc *SchedulerCache) UpdateSchedulerNumaInfo(AllocatedSets map[string]schedulingapi.ResNumaSets) error

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 Cache

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

type SchedulerCache

+ func (sc *SchedulerCache) GetPodVolumes(task *schedulingapi.TaskInfo, node *v1.Node) (*volumescheduling.PodVolumes, error)

type VolumeBinder

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

Feb 23, 2021 GO-2024-3034

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

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

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

type Cache

+ Client func() kubernetes.Interface

type SchedulerCache

+ func (sc *SchedulerCache) Client() kubernetes.Interface

+ type Snapshot struct

+ func NewEmptySnapshot() *Snapshot

+ func NewSnapshot(pods []*v1.Pod, nodes []*v1.Node) *Snapshot

+ func (s *Snapshot) Get(nodeName string) (*schedulernodeinfo.NodeInfo, error)

+ func (s *Snapshot) HavePodsWithAffinityList() ([]*schedulernodeinfo.NodeInfo, error)

+ func (s *Snapshot) List() ([]*schedulernodeinfo.NodeInfo, error)

+ func (s *Snapshot) NodeInfos() schedulerlisters.NodeInfoLister

+ func (s *Snapshot) Pods() schedulerlisters.PodLister

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

type SchedulerCache

+ func (sc *SchedulerCache) AddPodGroupV1beta1(obj interface{})

+ func (sc *SchedulerCache) AddQueueV1beta1(obj interface{})

+ func (sc *SchedulerCache) DeletePodGroupV1beta1(obj interface{})

+ func (sc *SchedulerCache) DeleteQueueV1beta1(obj interface{})

+ func (sc *SchedulerCache) UpdatePodGroupV1beta1(oldObj, newObj interface{})

+ func (sc *SchedulerCache) UpdateQueueV1beta1(oldObj, newObj interface{})

Feb 21, 2020 GO-2024-3034

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

Changes in this version

+ type Binder interface

+ Bind func(task *v1.Pod, hostname string) error

+ type Cache interface

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

+ Bind func(task *api.TaskInfo, hostname string) error

+ BindVolumes func(task *api.TaskInfo) error

+ Evict func(task *api.TaskInfo, reason string) error

+ RecordJobStatusEvent func(job *api.JobInfo)

+ Run func(stopCh <-chan struct{})

+ Snapshot func() *api.ClusterInfo

+ UpdateJobStatus func(job *api.JobInfo, updatePG bool) (*api.JobInfo, error)

+ WaitForCacheSync func(stopCh <-chan struct{}) bool

+ func New(config *rest.Config, schedulerName string, defaultQueue string) Cache

+ type Evictor interface

+ Evict func(pod *v1.Pod) error

+ type SchedulerCache struct

+ Binder Binder

+ Evictor Evictor

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

+ NamespaceCollection map[string]*schedulingapi.NamespaceCollection

+ Nodes map[string]*schedulingapi.NodeInfo

+ PriorityClasses map[string]*v1beta1.PriorityClass

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

+ Recorder record.EventRecorder

+ StatusUpdater StatusUpdater

+ VolumeBinder VolumeBinder

+ func (sc *SchedulerCache) AddNode(obj interface{})

+ func (sc *SchedulerCache) AddPod(obj interface{})

+ func (sc *SchedulerCache) AddPodGroupV1alpha1(obj interface{})

+ func (sc *SchedulerCache) AddPodGroupV1alpha2(obj interface{})

+ func (sc *SchedulerCache) AddPriorityClass(obj interface{})

+ func (sc *SchedulerCache) AddQueueV1alpha1(obj interface{})

+ func (sc *SchedulerCache) AddQueueV1alpha2(obj interface{})

+ func (sc *SchedulerCache) AddResourceQuota(obj interface{})

+ func (sc *SchedulerCache) AllocateVolumes(task *schedulingapi.TaskInfo, hostname string) error

+ func (sc *SchedulerCache) Bind(taskInfo *schedulingapi.TaskInfo, hostname string) error

+ func (sc *SchedulerCache) BindVolumes(task *schedulingapi.TaskInfo) error

+ func (sc *SchedulerCache) DeleteNode(obj interface{})

+ func (sc *SchedulerCache) DeletePod(obj interface{})

+ func (sc *SchedulerCache) DeletePodGroupV1alpha1(obj interface{})

+ func (sc *SchedulerCache) DeletePodGroupV1alpha2(obj interface{})

+ func (sc *SchedulerCache) DeletePriorityClass(obj interface{})

+ func (sc *SchedulerCache) DeleteQueueV1alpha1(obj interface{})

+ func (sc *SchedulerCache) DeleteQueueV1alpha2(obj interface{})

+ func (sc *SchedulerCache) DeleteResourceQuota(obj interface{})

+ func (sc *SchedulerCache) Evict(taskInfo *schedulingapi.TaskInfo, reason string) error

+ func (sc *SchedulerCache) RecordJobStatusEvent(job *schedulingapi.JobInfo)

+ func (sc *SchedulerCache) Run(stopCh <-chan struct{})

+ func (sc *SchedulerCache) Snapshot() *schedulingapi.ClusterInfo

+ func (sc *SchedulerCache) String() string

+ func (sc *SchedulerCache) UpdateJobStatus(job *schedulingapi.JobInfo, updatePG bool) (*schedulingapi.JobInfo, error)

+ func (sc *SchedulerCache) UpdateNode(oldObj, newObj interface{})

+ func (sc *SchedulerCache) UpdatePod(oldObj, newObj interface{})

+ func (sc *SchedulerCache) UpdatePodGroupV1alpha1(oldObj, newObj interface{})

+ func (sc *SchedulerCache) UpdatePodGroupV1alpha2(oldObj, newObj interface{})

+ func (sc *SchedulerCache) UpdatePriorityClass(oldObj, newObj interface{})

+ func (sc *SchedulerCache) UpdateQueueV1alpha1(oldObj, newObj interface{})

+ func (sc *SchedulerCache) UpdateQueueV1alpha2(oldObj, newObj interface{})

+ func (sc *SchedulerCache) UpdateResourceQuota(oldObj, newObj interface{})

+ func (sc *SchedulerCache) WaitForCacheSync(stopCh <-chan struct{}) bool

+ type StatusUpdater interface

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

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

+ type VolumeBinder interface

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

+ BindVolumes func(task *api.TaskInfo) error