Versions in this module Expand all Collapse all v0 v0.4.2 Apr 25, 2023 v0.4.1 Apr 25, 2023 Changes in this version + const DefaultLauncherRestartPolicy + const DefaultRestartPolicy + const EnvKubeflowNamespace + const GroupName + const GroupVersion + const Kind + const OperatorName + var AddToScheme = SchemeBuilder.AddToScheme + var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes, addDefaultingFuncs) + var SchemeGroupVersion = schema.GroupVersion + var SchemeGroupVersionKind = schema.GroupVersionKind + func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition + func RegisterDefaults(scheme *runtime.Scheme) error + func Resource(resource string) schema.GroupResource + func SetDefaults_MPIJob(mpiJob *MPIJob) + func SetObjectDefaults_MPIJob(in *MPIJob) + func SetObjectDefaults_MPIJobList(in *MPIJobList) + type CleanPodPolicy string + const CleanPodPolicyAll + const CleanPodPolicyNone + const CleanPodPolicyRunning + const CleanPodPolicyUndefined + 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 + const JobSuspended + type JobStatus struct + CompletionTime *metav1.Time + Conditions []JobCondition + LastReconcileTime *metav1.Time + ReplicaStatuses map[MPIReplicaType]*ReplicaStatus + StartTime *metav1.Time + func (in *JobStatus) DeepCopy() *JobStatus + func (in *JobStatus) DeepCopyInto(out *JobStatus) + type MPIImplementation string + const MPIImplementationIntel + const MPIImplementationOpenMPI + type MPIJob struct + Spec MPIJobSpec + Status JobStatus + func (in *MPIJob) DeepCopy() *MPIJob + func (in *MPIJob) DeepCopyInto(out *MPIJob) + func (in *MPIJob) DeepCopyObject() runtime.Object + type MPIJobList struct + Items []MPIJob + func (in *MPIJobList) DeepCopy() *MPIJobList + func (in *MPIJobList) DeepCopyInto(out *MPIJobList) + func (in *MPIJobList) DeepCopyObject() runtime.Object + type MPIJobSpec struct + MPIImplementation MPIImplementation + MPIReplicaSpecs map[MPIReplicaType]*common.ReplicaSpec + RunPolicy RunPolicy + SSHAuthMountPath string + SlotsPerWorker *int32 + func (in *MPIJobSpec) DeepCopy() *MPIJobSpec + func (in *MPIJobSpec) DeepCopyInto(out *MPIJobSpec) + type MPIReplicaType string + const MPIReplicaTypeLauncher + const MPIReplicaTypeWorker + type ReplicaStatus struct + Active int32 + Failed int32 + LabelSelector *metav1.LabelSelector + Selector string + Succeeded int32 + func (in *ReplicaStatus) DeepCopy() *ReplicaStatus + func (in *ReplicaStatus) DeepCopyInto(out *ReplicaStatus) + type RunPolicy struct + ActiveDeadlineSeconds *int64 + BackoffLimit *int32 + CleanPodPolicy *CleanPodPolicy + SchedulingPolicy *SchedulingPolicy + Suspend *bool + TTLSecondsAfterFinished *int32 + func (in *RunPolicy) DeepCopy() *RunPolicy + func (in *RunPolicy) DeepCopyInto(out *RunPolicy) + type SchedulingPolicy struct + MinAvailable *int32 + MinResources *v1.ResourceList + PriorityClass string + Queue string + ScheduleTimeoutSeconds *int32 + func (in *SchedulingPolicy) DeepCopy() *SchedulingPolicy + func (in *SchedulingPolicy) DeepCopyInto(out *SchedulingPolicy)
Go to main page