Versions in this module Expand all Collapse all v0 v0.4.2 Apr 25, 2023 v0.4.1 Apr 25, 2023 Changes in this version + const ErrResourceExists + const MessageResourceExists + const ValidationError + type MPIJobController struct + func NewMPIJobController(kubeClient kubernetes.Interface, kubeflowClient clientset.Interface, ...) *MPIJobController + func NewMPIJobControllerWithClock(kubeClient kubernetes.Interface, kubeflowClient clientset.Interface, ...) *MPIJobController + func (c *MPIJobController) Run(threadiness int, stopCh <-chan struct{}) error + type PodGroupControl interface + PodGroupSharedIndexInformer func() cache.SharedIndexInformer + StartInformerFactory func(stopCh <-chan struct{}) + type SchedulerPluginsCtrl struct + Client schedclientset.Interface + InformerFactory schedinformers.SharedInformerFactory + PodGroupInformer schedinformer.PodGroupInformer + PriorityClassLister schedulinglisters.PriorityClassLister + func NewSchedulerPluginsCtrl(c schedclientset.Interface, watchNamespace, schedulerName string) *SchedulerPluginsCtrl + func (s *SchedulerPluginsCtrl) PodGroupSharedIndexInformer() cache.SharedIndexInformer + func (s *SchedulerPluginsCtrl) StartInformerFactory(stopCh <-chan struct{}) + type VolcanoCtrl struct + Client volcanoclient.Interface + InformerFactory volcanoinformers.SharedInformerFactory + PodGroupInformer volcanopodgroupinformer.PodGroupInformer + func NewVolcanoCtrl(c volcanoclient.Interface, watchNamespace string) *VolcanoCtrl + func (v *VolcanoCtrl) PodGroupSharedIndexInformer() cache.SharedIndexInformer + func (v *VolcanoCtrl) StartInformerFactory(stopCh <-chan struct{})