Versions in this module Expand all Collapse all v0 v0.1.2 Jun 10, 2021 Changes in this version + const GroupNameLabel + const JobNameLabel + const JobRoleLabel + const ReplicaIndexLabel + const ReplicaTypeLabel + func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition + func RegisterDefaults(scheme *runtime.Scheme) error + type CleanPodPolicy string + const CleanPodPolicyAll + const CleanPodPolicyNone + const CleanPodPolicyRunning + const CleanPodPolicyUndefined + type ControllerInterface interface + ControllerName func() string + CreatePod func(job interface{}, pod *corev1.Pod) error + CreateService func(job interface{}, service *corev1.Service) error + DeleteJob func(job interface{}) error + DeletePod func(job interface{}, pod *corev1.Pod) error + DeleteService func(job interface{}, name string, namespace string) error + GetAPIGroupVersion func() schema.GroupVersion + GetAPIGroupVersionKind func() schema.GroupVersionKind + GetDefaultContainerName func() string + GetDefaultContainerPortName func() string + GetDefaultContainerPortNumber func() int32 + GetGroupNameLabelValue func() string + GetJobFromAPIClient func(namespace, name string) (v1.Object, error) + GetJobFromInformerCache func(namespace, name string) (v1.Object, error) + GetPodsForJob func(job interface{}) ([]*corev1.Pod, error) + GetServicesForJob func(job interface{}) ([]*corev1.Service, error) + IsMasterRole func(replicas map[ReplicaType]*ReplicaSpec, rtype ReplicaType, index int) bool + SetClusterSpec func(job interface{}, podTemplate *corev1.PodTemplateSpec, rtype, index string) error + UpdateJobStatus func(job interface{}, replicas map[ReplicaType]*ReplicaSpec, jobStatus *JobStatus) error + UpdateJobStatusInApiServer func(job interface{}, jobStatus *JobStatus) error + type JobCondition struct + LastTransitionTime metav1.Time + LastUpdateTime metav1.Time + Message string + Reason string + Status v1.ConditionStatus + Type JobConditionType + func (in *JobCondition) DeepCopy() *JobCondition + func (in *JobCondition) DeepCopyInto(out *JobCondition) + type JobConditionType string + const JobCreated + const JobFailed + const JobRestarting + const JobRunning + const JobSucceeded + type JobController struct + Config JobControllerConfiguration + Controller 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 ControllerInterface, reconcilerSyncPeriod metav1.Duration, ...) JobController + type JobControllerConfiguration struct + EnableGangScheduling bool + ReconcilerSyncLoopPeriod metav1.Duration + type JobStatus struct + CompletionTime *metav1.Time + Conditions []JobCondition + LastReconcileTime *metav1.Time + ReplicaStatuses map[ReplicaType]*ReplicaStatus + StartTime *metav1.Time + func (in *JobStatus) DeepCopy() *JobStatus + func (in *JobStatus) DeepCopyInto(out *JobStatus) + type ReplicaSpec struct + Replicas *int32 + RestartPolicy RestartPolicy + Template v1.PodTemplateSpec + func (in *ReplicaSpec) DeepCopy() *ReplicaSpec + func (in *ReplicaSpec) DeepCopyInto(out *ReplicaSpec) + type ReplicaStatus struct + Active int32 + Failed int32 + Succeeded int32 + func (in *ReplicaStatus) DeepCopy() *ReplicaStatus + func (in *ReplicaStatus) DeepCopyInto(out *ReplicaStatus) + type ReplicaType string + type RestartPolicy string + const RestartPolicyAlways + const RestartPolicyExitCode + const RestartPolicyNever + const RestartPolicyOnFailure + type RunPolicy struct + ActiveDeadlineSeconds *int64 + BackoffLimit *int32 + CleanPodPolicy *CleanPodPolicy + SchedulingPolicy *SchedulingPolicy + TTLSecondsAfterFinished *int32 + func (in *RunPolicy) DeepCopy() *RunPolicy + func (in *RunPolicy) DeepCopyInto(out *RunPolicy) + type SchedulingPolicy struct + MinAvailable *int32
Go to main page