job_controller

package

Versions in this module

v0

v0.5.0

Dec 5, 2022

Changes in this version

+ func OnOwnerCreateFunc(scheme *runtime.Scheme, fieldExtractFunc FieldExtractFunc, logger logr.Logger, ...) func(event.CreateEvent) bool

+ func OnOwnerDeleteFunc(jc JobController, fieldExtractFunc FieldExtractFunc, logger logr.Logger) func(e event.DeleteEvent) bool

+ func OnOwnerUpdateFunc(scheme *runtime.Scheme, fieldExtractFunc FieldExtractFunc, logger logr.Logger, ...) func(e event.UpdateEvent) bool

+ type FieldExtractFunc func(object client.Object) (replicas map[v1.ReplicaType]*v1.ReplicaSpec, status *v1.JobStatus, ...)

v0.4.3

Dec 5, 2022

Changes in this version

+ const AnnotationAIMasterEnableErrorMonitoring

+ const AnnotationImmediatelyRestartPod

+ const AnnotationImmediatelyStartWorker

+ const AnnotationLastFailoverTimestamp

+ func ContainsReplicaType(rspecs map[v1.ReplicaType]*v1.ReplicaSpec, rtypes ...v1.ReplicaType) bool

+ func EnableErrorMonitoring(job client.Object) bool

+ func ShouldPodFailOver(rspec *v1.ReplicaSpec, pod *corev1.Pod, exitCode int32) bool

+ type FailOverAction string

+ const FailOverInPlaceRestart

+ const FailOverRecreate

type JobController

+ func (jc *JobController) DoFailOver(job client.Object, jobStatus *v1.JobStatus, rtype v1.ReplicaType, ...) error

+ func (jc *JobController) DoFailOverByAction(job client.Object, pods []*corev1.Pod, action FailOverAction) (err error)

+ func (jc *JobController) RecreatePods(job client.Object, pods []*corev1.Pod) error

+ func (jc *JobController) RestartPod(job client.Object, pod *corev1.Pod) (completed bool, err error)

+ func (jc *JobController) RestartPods(job client.Object, pods []*corev1.Pod) error

type PodControl

+ func (r PodControl) CreatePodsWithGenerateName(namespace string, template *v1.PodTemplateSpec, object runtime.Object, ...) error

v0.4.2

May 10, 2022

Changes in this version

type JobController

+ APIReader client.Reader

+ PodControl controller.PodControlInterface

+ Scheme *runtime.Scheme

+ ServiceControl ServiceControlInterface

+ func (jc *JobController) ReconcileCron(meta metav1.Object, runtimeObj runtime.Object, policy *apiv1.RunPolicy) error

v0.4.1

Jan 4, 2022

Changes in this version

type JobController

+ func (jc *JobController) AdoptAndClaimPods(job metav1.Object, podList *v1.PodList) ([]*v1.Pod, error)

+ func (jc *JobController) AdoptAndClaimServices(job metav1.Object, serviceList *v1.ServiceList) ([]*v1.Service, error)

+ func (jc *JobController) DeleteExpectations(job metav1.Object, specs map[apiv1.ReplicaType]*apiv1.ReplicaSpec)

v0.4.0

Aug 16, 2021

Changes in this version

+ func ReplicaTypes(specs map[v1.ReplicaType]*v1.ReplicaSpec) []v1.ReplicaType

type JobController

+ Client client.Client

+ func (jc *JobController) CreatePodReplica(job interface{}, rt, index string, podTemplate *v1.PodTemplateSpec, ...) error

+ func (jc *JobController) CreateService(job interface{}, service *v1.Service) error

+ func (jc *JobController) DeletePod(job runtime.Object, pod *v1.Pod) error

+ func (jc *JobController) DeleteService(job runtime.Object, name string, namespace string) error

+ func (jc *JobController) SortPodsByReplicaType(pods []*v1.Pod, rtypes []apiv1.ReplicaType) map[apiv1.ReplicaType][]*v1.Pod

type TestJobController

+ func (t TestJobController) GetNodeForModelOutput(pods []*corev1.Pod) (nodeName string)

v0.3.0

Apr 12, 2021

v0.2.0

Apr 9, 2021

Changes in this version

+ func EnableHostNetwork(job metav1.Object) bool

+ func GetHostNetworkPortFromContext(ctx context.Context, rtype, index string) (int32, bool)

type JobController

+ func (jc *JobController) CreateCommonService(job metav1.Object, rtype apiv1.ReplicaType, service *v1.Service, index string) error

+ func (jc *JobController) CreatePod(job interface{}, rt, index string, podTemplate *v1.PodTemplateSpec, ...) error

v0.1.0

Oct 20, 2020

Changes in this version

+ const FailedCreatePodReason

+ const FailedCreateServiceReason

+ const FailedDeleteJobReason

+ const FailedDeletePodReason

+ const FailedDeleteServiceReason

+ const SuccessfulCreatePodReason

+ const SuccessfulCreateServiceReason

+ const SuccessfulDeleteJobReason

+ 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 GetPortFromJob(spec map[v1.ReplicaType]*v1.ReplicaSpec, rtype v1.ReplicaType, ...) (int32, error)

+ func NewPodControl(client client.Client, recorder record.EventRecorder) controller.PodControlInterface

+ 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

+ BackoffStatesQueue workqueue.RateLimitingInterface

+ Config JobControllerConfiguration

+ Controller apiv1.ControllerInterface

+ Expectations controller.ControllerExpectationsInterface

+ GangScheduler gang_schedule.GangScheduler

+ Metrics *metrics.JobMetrics

+ Recorder record.EventRecorder

+ func NewJobController(controllerImpl apiv1.ControllerInterface, config JobControllerConfiguration, ...) JobController

+ func (jc *JobController) CreateGang(job metav1.Object, replicas map[apiv1.ReplicaType]*apiv1.ReplicaSpec) (runtime.Object, error)

+ 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) DeleteGang(job metav1.Object) error

+ 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) OnPodCreateFunc(e event.CreateEvent) bool

+ func (jc *JobController) OnPodDeleteFunc(e event.DeleteEvent) bool

+ func (jc *JobController) OnPodUpdateFunc(e event.UpdateEvent) bool

+ func (jc *JobController) OnServiceCreateFunc(e event.CreateEvent) bool

+ func (jc *JobController) OnServiceDeleteFunc(e event.DeleteEvent) bool

+ func (jc *JobController) OnServiceUpdateFunc(e event.UpdateEvent) bool

+ func (jc *JobController) ReconcileJobs(job interface{}, replicas map[apiv1.ReplicaType]*apiv1.ReplicaSpec, ...) (result reconcile.Result, err 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) SatisfyExpectations(job metav1.Object, specs map[apiv1.ReplicaType]*apiv1.ReplicaSpec) bool

+ type JobControllerConfiguration struct

+ EnableGangScheduling bool

+ GangSchedulerName string

+ MaxConcurrentReconciles int

+ ReconcilerSyncLoopPeriod metav1.Duration

+ type PodControl struct

+ func (r PodControl) CreatePods(namespace string, template *v1.PodTemplateSpec, object runtime.Object) error

+ func (r PodControl) CreatePodsOnNode(nodeName, namespace string, template *v1.PodTemplateSpec, ...) error

+ func (r PodControl) CreatePodsWithControllerRef(namespace string, template *v1.PodTemplateSpec, ...) error

+ func (r PodControl) DeletePod(namespace string, name string, object runtime.Object) error

+ func (r PodControl) PatchPod(namespace, name string, data []byte) error

+ type ServiceControl struct

+ func NewServiceControl(client client.Client, recorder record.EventRecorder) *ServiceControl

+ func (r ServiceControl) CreateServices(namespace string, service *v1.Service, object runtime.Object) error

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

+ func (r ServiceControl) DeleteService(namespace, name string, object runtime.Object) error

+ func (r ServiceControl) 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

+ type TestJobController struct

+ func (TestJobController) ControllerName() string

+ func (TestJobController) GetAPIGroupVersion() schema.GroupVersion

+ func (TestJobController) GetAPIGroupVersionKind() schema.GroupVersionKind

+ func (TestJobController) GetDefaultContainerPortName() string

+ func (TestJobController) GetDefaultContainerPortNumber() int32

+ func (TestJobController) GetGroupNameLabelValue() string

+ func (TestJobController) GetJobRoleKey() string

+ func (t *TestJobController) CreatePod(job interface{}, pod *corev1.Pod) error

+ func (t *TestJobController) CreateService(job interface{}, service *corev1.Service) error

+ func (t *TestJobController) DeleteJob(job interface{}) error

+ func (t *TestJobController) DeletePod(job interface{}, pod *corev1.Pod) error

+ func (t *TestJobController) DeleteService(job interface{}, name string, namespace string) error

+ func (t *TestJobController) GetDefaultContainerName() string

+ func (t *TestJobController) GetJobFromAPIClient(namespace, name string) (v1.Object, error)

+ func (t *TestJobController) GetJobFromInformerCache(namespace, name string) (v1.Object, error)

+ func (t *TestJobController) IsMasterRole(replicas map[apiv1.ReplicaType]*apiv1.ReplicaSpec, rtype apiv1.ReplicaType, ...) bool

+ func (t *TestJobController) SetClusterSpec(job interface{}, podTemplate *corev1.PodTemplateSpec, rtype, index string) error

+ func (t *TestJobController) UpdateJobStatusInApiServer(job interface{}, jobStatus *apiv1.JobStatus) error

+ func (t TestJobController) GetPodsForJob(job interface{}) ([]*corev1.Pod, error)

+ func (t TestJobController) GetReconcileOrders() []apiv1.ReplicaType

+ func (t TestJobController) GetServicesForJob(job interface{}) ([]*corev1.Service, error)

+ func (t TestJobController) UpdateJobStatus(job interface{}, replicas map[apiv1.ReplicaType]*apiv1.ReplicaSpec, ...) error

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