v1

package

Go to main page

Versions in this module

v0

v0.5.0

Dec 5, 2022

v0.4.3

Dec 5, 2022

Changes in this version

+ const AnnotationElasticScaleState

+ const AnnotationEnableElasticTraining

+ const ContextFailedPodContents

+ const ElasticScaleDone

+ const ElasticScaleInflight

+ const FinalizerPreemptProtector

+ const LabelGeneration

+ type ElasticScaling interface

+ CheckpointIfNecessary func(job interface{}, activePods []*corev1.Pod) (completed bool, err error)

+ EnableElasticScaling func(job v1.Object, runPolicy *RunPolicy) bool

+ ScaleIn func(job interface{}, replicas map[ReplicaType]*ReplicaSpec, ...) error

+ ScaleOut func(job interface{}, replicas map[ReplicaType]*ReplicaSpec, ...) error

type ReplicaType

+ const JobReplicaTypeAIMaster

v0.4.2

May 10, 2022

Changes in this version

+ const LabelGangSchedulingJobName

+ type ConcurrencyPolicy string

+ const AllowConcurrent

+ const ForbidConcurrent

+ const ReplaceConcurrent

+ type CronPolicy struct

+ ConcurrencyPolicy ConcurrencyPolicy

+ Deadline *metav1.Time

+ HistoryLimit *int32

+ Schedule string

+ Suspend *bool

+ func (in *CronPolicy) DeepCopy() *CronPolicy

+ func (in *CronPolicy) DeepCopyInto(out *CronPolicy)

type DAGCondition

+ func (in *DAGCondition) DeepCopy() *DAGCondition

+ func (in *DAGCondition) DeepCopyInto(out *DAGCondition)

type JobConditionType

+ const JobQueuing

type ReplicaSpec

+ SpotReplicaSpec *SpotReplicaSpec

type RunPolicy

+ CronPolicy *CronPolicy

type SchedulingPolicy

+ Priority *int32

+ PriorityClassName string

+ Queue string

+ type SpotReplicaSpec struct

+ Labels map[string]string

+ PriorityClassName string

+ SpotReplicaNumber int32

+ func (in *SpotReplicaSpec) DeepCopy() *SpotReplicaSpec

+ func (in *SpotReplicaSpec) DeepCopyInto(out *SpotReplicaSpec)

v0.4.1

Jan 4, 2022

Changes in this version

type JobStatus

+ CacheBackendName string

v0.4.0

Aug 16, 2021

Changes in this version

+ const LabelCronName

+ const LabelInferenceName

+ const LabelModelVersion

+ const LabelPredictorName

+ const ResourceNvidiaGPU

type ControllerInterface

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

+ type DAGCondition struct

+ OnPhase v1.PodPhase

+ Upstream ReplicaType

type JobStatus

+ ModelVersionName string

type ReplicaSpec

+ DependOn []DAGCondition

+ type SuccessPolicy string

+ const SuccessPolicyAllWorkers

+ const SuccessPolicyDefault

v0.3.0

Apr 12, 2021

v0.2.0

Apr 9, 2021

Changes in this version

+ const AnnotationNetworkMode

+ const AnnotationTensorBoardConfig

+ const ReplicaNameLabel

+ const ReplicaTypeTensorBoard

+ type NetworkMode string

+ const HostNetworkMode

type ReplicaStatus

+ Evicted int32

v0.1.0

Oct 20, 2020

Changes in this version

+ const AnnotationGitSyncConfig

+ const AnnotationTenancyInfo

+ const DefaultKubeDLNamespace

+ const GroupNameLabel

+ const JobNameLabel

+ const JobRoleLabel

+ const KubeDLPrefix

+ const ReplicaIndexLabel

+ const ReplicaTypeLabel

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

+ GetReconcileOrders func() []ReplicaType

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

+ func (in *SchedulingPolicy) DeepCopy() *SchedulingPolicy

+ func (in *SchedulingPolicy) DeepCopyInto(out *SchedulingPolicy)

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