common

package

Go to main page

Versions in this module

v0

v0.4.7

Apr 25, 2023

v0.4.6

Jan 20, 2023

Changes in this version

+ var GenNonGangSchedulerSetupFunc = func() GangSchedulingSetupFunc

+ var GenSchedulerPluginsSetupFunc = func(c client.Client) GangSchedulingSetupFunc

+ var GenVolcanoSetupFunc = func(vci volcanoclient.Interface) GangSchedulingSetupFunc

+ type FillPodGroupSpecFunc func(object metav1.Object) error

+ type GangScheduler string

+ const GangSchedulerNone

+ const GangSchedulerSchedulerPlugins

+ const GangSchedulerVolcano

+ type GangSchedulingSetupFunc func(jc *JobController)

type JobController

+ PodGroupControl control.PodGroupControlInterface

type JobControllerConfiguration

+ GangScheduling GangScheduler

v0.4.5

Dec 20, 2022

v0.4.4

Dec 20, 2022

v0.4.3

Jun 9, 2022

v0.4.2

Jun 3, 2022

v0.4.1

Nov 24, 2021

Changes in this version

+ func CalcPGMinResources(minMember int32, replicas map[apiv1.ReplicaType]*apiv1.ReplicaSpec, ...) *v1.ResourceList

+ type PriorityClassGetFunc func(string) (*v1beta1.PriorityClass, error)

v0.4.0

Aug 12, 2021

v0.3.7

Aug 30, 2021

v0.3.6

Jul 23, 2021

v0.3.5

Jul 8, 2021

Changes in this version

type JobController

+ func (jc *JobController) ResetExpectations(jobKey string, replicas map[apiv1.ReplicaType]*apiv1.ReplicaSpec)

v0.3.4

May 18, 2021

Changes in this version

type JobController

+ func (jc *JobController) GetPortsFromJob(spec *apiv1.ReplicaSpec) (map[string]int32, error)

v0.3.3

Mar 31, 2021

Changes in this version

+ func AddResourceList(list, req, limit v1.ResourceList)

type JobController

+ PriorityClassInformerSynced cache.InformerSynced

+ PriorityClassLister schedulinglisters.PriorityClassLister

+ type ReplicaPriority struct

+ type ReplicasPriority []ReplicaPriority

+ func (p ReplicasPriority) Len() int

+ func (p ReplicasPriority) Less(i, j int) bool

+ func (p ReplicasPriority) Swap(i, j int)

v0.3.2

Jan 26, 2021

v0.3.1

May 17, 2020

Changes in this version

type JobController

+ func (jc *JobController) CleanupJob(runPolicy *apiv1.RunPolicy, jobStatus apiv1.JobStatus, job interface{}) error

+ func (jc *JobController) DeletePodsAndServices(runPolicy *apiv1.RunPolicy, job interface{}, pods []*v1.Pod) error

+ func (jc *JobController) PastActiveDeadline(runPolicy *apiv1.RunPolicy, jobStatus apiv1.JobStatus) bool

+ func (jc *JobController) PastBackoffLimit(jobName string, runPolicy *apiv1.RunPolicy, ...) (bool, error)

v0.3.0

May 14, 2020

Changes in this version

type JobController

+ PodControl control.PodControlInterface

+ ServiceControl control.ServiceControlInterface

+ VolcanoClientSet volcanoclient.Interface

+ func (jc *JobController) GetPodsForJob(jobObject interface{}) ([]*v1.Pod, error)

+ func (jc *JobController) GetServicesForJob(jobObject interface{}) ([]*v1.Service, error)

v0.2.0

Apr 13, 2020

Changes in this version

+ const FailedCreatePodReason

+ const FailedCreateServiceReason

+ const FailedDeletePodReason

+ const FailedDeleteServiceReason

+ const SuccessfulCreatePodReason

+ const SuccessfulCreateServiceReason

+ const SuccessfulDeletePodReason

+ const SuccessfulDeleteServiceReason

+ var KeyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc

+ func GenExpectationPodsKey(jobKey, replicaType string) string

+ func GenExpectationServicesKey(jobKey, replicaType string) string

+ func GenGeneralName(jobName, rtype, index string) string

+ func GetPodFromTemplate(template *v1.PodTemplateSpec, parentObject runtime.Object, ...) (*v1.Pod, error)

+ func MaxInt(x, y int) int

+ func RecheckDeletionTimestamp(getObject func() (metav1.Object, error)) func() 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 JobController struct

+ Config JobControllerConfiguration

+ Controller apiv1.ControllerInterface

+ Expectations controller.ControllerExpectationsInterface

+ KubeBatchClientSet kubebatchclient.Interface

+ KubeClientSet kubeclientset.Interface

+ PodInformerSynced cache.InformerSynced

+ PodLister corelisters.PodLister

+ Recorder record.EventRecorder

+ ServiceInformerSynced cache.InformerSynced

+ ServiceLister corelisters.ServiceLister

+ WorkQueue workqueue.RateLimitingInterface

+ func NewJobController(controllerImpl apiv1.ControllerInterface, reconcilerSyncPeriod metav1.Duration, ...) JobController

+ func (jc *JobController) AddPod(obj interface{})

+ func (jc *JobController) AddService(obj interface{})

+ func (jc *JobController) CreateNewService(job metav1.Object, rtype apiv1.ReplicaType, spec *apiv1.ReplicaSpec, ...) error

+ func (jc *JobController) CreateServicesWithControllerRef(namespace string, service *v1.Service, controllerObject runtime.Object, ...) error

+ func (jc *JobController) DeletePdb(job metav1.Object) error

+ func (jc *JobController) DeletePod(obj interface{})

+ func (jc *JobController) DeletePodGroup(job metav1.Object) error

+ func (jc *JobController) DeleteService(obj interface{})

+ func (jc *JobController) FilterPodsForReplicaType(pods []*v1.Pod, replicaType string) ([]*v1.Pod, error)

+ func (jc *JobController) FilterServicesForReplicaType(services []*v1.Service, replicaType string) ([]*v1.Service, error)

+ func (jc *JobController) GenLabels(jobName string) map[string]string

+ func (jc *JobController) GenOwnerReference(obj metav1.Object) *metav1.OwnerReference

+ func (jc *JobController) GetPodSlices(pods []*v1.Pod, replicas int, logger *log.Entry) [][]*v1.Pod

+ func (jc *JobController) GetPortFromJob(spec *apiv1.ReplicaSpec) (*int32, error)

+ func (jc *JobController) GetServiceSlices(services []*v1.Service, replicas int, logger *log.Entry) [][]*v1.Service

+ func (jc *JobController) ReconcileJobs(job interface{}, replicas map[apiv1.ReplicaType]*apiv1.ReplicaSpec, ...) error

+ func (jc *JobController) ReconcilePods(job interface{}, jobStatus *apiv1.JobStatus, pods []*v1.Pod, ...) error

+ func (jc *JobController) ReconcileServices(job metav1.Object, services []*v1.Service, rtype apiv1.ReplicaType, ...) error

+ func (jc *JobController) SyncPdb(job metav1.Object, minAvailableReplicas int32) (*v1beta1.PodDisruptionBudget, error)

+ func (jc *JobController) SyncPodGroup(job metav1.Object, minAvailableReplicas int32) (*v1alpha1.PodGroup, error)

+ func (jc *JobController) UpdatePod(old, cur interface{})

+ func (jc *JobController) UpdateService(old, cur interface{})

+ type JobControllerConfiguration struct

+ EnableGangScheduling bool

+ ReconcilerSyncLoopPeriod metav1.Duration

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL