Versions in this module Expand all Collapse all v0 v0.1.0 Oct 9, 2023 Changes in this version + const FailedCreatePodReason + const FailedCreateServiceReason + const FailedDeletePodReason + const FailedDeleteServiceReason + const SuccessfulCreatePodReason + const SuccessfulCreateServiceReason + const SuccessfulDeletePodReason + const SuccessfulDeleteServiceReason + func GetConfigMapFromTemplate(template *v1.ConfigMap, object runtime.Object, ...) (*v1.ConfigMap, error) + func GetPodFromTemplate(template *v1.PodTemplateSpec, parentObject runtime.Object, ...) (*v1.Pod, error) + func GetServiceFromTemplate(template *v1.Service, parentObject runtime.Object, ...) (*v1.Service, error) + func ValidateControllerRef(controllerRef *metav1.OwnerReference) error + type BaseControllerRefManager struct + CanAdoptFunc func() error + Controller metav1.Object + Selector labels.Selector + func (m *BaseControllerRefManager) CanAdopt() error + func (m *BaseControllerRefManager) ClaimObject(obj metav1.Object, match func(metav1.Object) bool, ...) (bool, error) + type ConfigMapControlInterface interface + CreateConfigMap func(namespace string, configmap *v1.ConfigMap, object runtime.Object) error + CreateConfigMapWithControllerRef func(namespace string, configmap *v1.ConfigMap, object runtime.Object, ...) error + DeleteConfigMap func(namespace, configMapID string, object runtime.Object) error + UpdateConfigMap func(namespace string, configmap *v1.ConfigMap) error + type FakePodControl struct + ControllerRefs []metav1.OwnerReference + CreateCallCount int + CreateLimit int + DeletePodName []string + Err error + Patches [][]byte + Templates []v1.PodTemplateSpec + func (f *FakePodControl) Clear() + func (f *FakePodControl) CreatePods(namespace string, spec *v1.PodTemplateSpec, object runtime.Object) error + func (f *FakePodControl) CreatePodsOnNode(nodeName, namespace string, template *v1.PodTemplateSpec, ...) error + func (f *FakePodControl) CreatePodsWithControllerRef(namespace string, spec *v1.PodTemplateSpec, object runtime.Object, ...) error + func (f *FakePodControl) DeletePod(namespace string, podID string, object runtime.Object) error + func (f *FakePodControl) PatchPod(namespace, name string, data []byte) error + type FakeServiceControl struct + ControllerRefs []metav1.OwnerReference + CreateCallCount int + CreateLimit int + DeleteServiceName []string + Err error + Patches [][]byte + Templates []v1.Service + func (f *FakeServiceControl) Clear() + func (f *FakeServiceControl) CreateServices(namespace string, service *v1.Service, object runtime.Object) error + func (f *FakeServiceControl) CreateServicesWithControllerRef(namespace string, service *v1.Service, object runtime.Object, ...) error + func (f *FakeServiceControl) DeleteService(namespace string, serviceID string, object runtime.Object) error + func (f *FakeServiceControl) PatchService(namespace, name string, data []byte) error + type PodControlInterface interface + CreatePods func(namespace string, template *v1.PodTemplateSpec, object runtime.Object) error + CreatePodsOnNode func(nodeName, namespace string, template *v1.PodTemplateSpec, ...) error + CreatePodsWithControllerRef func(namespace string, template *v1.PodTemplateSpec, object runtime.Object, ...) error + DeletePod func(namespace string, podID string, object runtime.Object) error + PatchPod func(namespace, name string, data []byte) error + type PodControllerRefManager struct + func NewPodControllerRefManager(podControl PodControlInterface, controller metav1.Object, ...) *PodControllerRefManager + func (m *PodControllerRefManager) AdoptPod(pod *v1.Pod) error + func (m *PodControllerRefManager) ClaimPods(pods []*v1.Pod, filters ...func(*v1.Pod) bool) ([]*v1.Pod, error) + func (m *PodControllerRefManager) ReleasePod(pod *v1.Pod) error + type PodGroupControlInterface interface + CreatePodGroup func(podGroup client.Object) error + DecoratePodTemplateSpec func(pts *corev1.PodTemplateSpec, cluster metav1.Object, rtype string) + DelayPodCreationDueToPodGroup func(pg metav1.Object) bool + DeletePodGroup func(namespace string, name string) error + GetPodGroup func(namespace string, name string) (metav1.Object, error) + GetSchedulerName func() string + NewEmptyPodGroup func() client.Object + UpdatePodGroup func(podGroup client.Object) error + func NewSchedulerPluginsControl(c client.Client, schedulerName string) PodGroupControlInterface + func NewVolcanoControl(vci volcanoclient.Interface) PodGroupControlInterface + type RealConfigMapControl struct + KubeClient clientset.Interface + Recorder record.EventRecorder + func (r RealConfigMapControl) CreateConfigMap(namespace string, configmap *v1.ConfigMap, object runtime.Object) error + func (r RealConfigMapControl) CreateConfigMapWithControllerRef(namespace string, configmap *v1.ConfigMap, controllerObject runtime.Object, ...) error + func (r RealConfigMapControl) DeleteConfigMap(namespace, configMapID string, object runtime.Object) error + func (r RealConfigMapControl) UpdateConfigMap(namespace string, configmap *v1.ConfigMap) error + type RealPodControl struct + KubeClient clientset.Interface + Recorder record.EventRecorder + func (r RealPodControl) CreatePods(namespace string, template *v1.PodTemplateSpec, object runtime.Object) error + func (r RealPodControl) CreatePodsOnNode(nodeName, namespace string, template *v1.PodTemplateSpec, ...) error + func (r RealPodControl) CreatePodsWithControllerRef(namespace string, template *v1.PodTemplateSpec, ...) error + func (r RealPodControl) DeletePod(namespace string, podID string, object runtime.Object) error + func (r RealPodControl) PatchPod(namespace, name string, data []byte) error + type RealServiceControl struct + KubeClient clientset.Interface + Recorder record.EventRecorder + func (r RealServiceControl) CreateServices(namespace string, service *v1.Service, object runtime.Object) error + func (r RealServiceControl) CreateServicesWithControllerRef(namespace string, service *v1.Service, controllerObject runtime.Object, ...) error + func (r RealServiceControl) DeleteService(namespace, serviceID string, object runtime.Object) error + func (r RealServiceControl) PatchService(namespace, name string, data []byte) error + type SchedulerPluginsControl struct + Client client.Client + SchedulerName string + func (s *SchedulerPluginsControl) CreatePodGroup(podGroup client.Object) error + func (s *SchedulerPluginsControl) DecoratePodTemplateSpec(pts *corev1.PodTemplateSpec, cluster metav1.Object, _ string) + func (s *SchedulerPluginsControl) DelayPodCreationDueToPodGroup(pg metav1.Object) bool + func (s *SchedulerPluginsControl) DeletePodGroup(namespace, name string) error + func (s *SchedulerPluginsControl) GetPodGroup(namespace, name string) (metav1.Object, error) + func (s *SchedulerPluginsControl) GetSchedulerName() string + func (s *SchedulerPluginsControl) NewEmptyPodGroup() client.Object + func (s *SchedulerPluginsControl) UpdatePodGroup(podGroup client.Object) error + type ServiceControlInterface interface + CreateServices func(namespace string, service *v1.Service, object runtime.Object) error + CreateServicesWithControllerRef func(namespace string, service *v1.Service, object runtime.Object, ...) error + DeleteService func(namespace, serviceID string, object runtime.Object) error + PatchService func(namespace, name string, data []byte) error + type ServiceControllerRefManager struct + func NewServiceControllerRefManager(serviceControl ServiceControlInterface, ctr metav1.Object, ...) *ServiceControllerRefManager + func (m *ServiceControllerRefManager) AdoptService(service *v1.Service) error + func (m *ServiceControllerRefManager) ClaimServices(services []*v1.Service, filters ...func(*v1.Service) bool) ([]*v1.Service, error) + func (m *ServiceControllerRefManager) ReleaseService(service *v1.Service) error + type VolcanoControl struct + Client volcanoclient.Interface + func (v *VolcanoControl) CreatePodGroup(podGroup client.Object) error + func (v *VolcanoControl) DecoratePodTemplateSpec(pts *corev1.PodTemplateSpec, cluster metav1.Object, rtype string) + func (v *VolcanoControl) DelayPodCreationDueToPodGroup(pg metav1.Object) bool + func (v *VolcanoControl) DeletePodGroup(namespace string, name string) error + func (v *VolcanoControl) GetPodGroup(namespace string, name string) (metav1.Object, error) + func (v *VolcanoControl) GetSchedulerName() string + func (v *VolcanoControl) NewEmptyPodGroup() client.Object + func (v *VolcanoControl) UpdatePodGroup(podGroup client.Object) error
Go to main page