v1alpha1

package
v0.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 29, 2024 License: Apache-2.0 Imports: 5 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SchemeBuilder          = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme            = SchemeBuilder.AddToScheme
	SchemeGroupVersion     = schema.GroupVersion{Group: groupName, Version: version}
	SchemeGroupVersionKind = schema.GroupVersionKind{Group: groupName, Version: version, Kind: kind}
)

Functions

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource.

Types

type ETReplicaSpec 

type ETReplicaSpec struct {
	// Replicas is the desired number of replicas of the given template.
	// If unspecified, defaults to 1.
	Replicas *int32 `json:"Replicas,omitempty"`

	// MaxReplicas is the desired max number of replicas of the given template.
	// If unspecified, MaxReplicas defaults to infinite.
	MaxReplicas *int32 `json:"maxReplicas,omitempty"`

	// MinReplicas is the desired min number of replicas of the given template.
	// If unspecified, MinReplicas defaults to InitReplicas
	MinReplicas *int32 `json:"minReplicas,omitempty"`

	// Template is the object that describes the pod that
	// will be created for this replica. RestartPolicy in PodTemplateSpec
	// will be overide by RestartPolicy in ReplicaSpec
	Template v1.PodTemplateSpec `json:"template,omitempty"`

	// Restart policy for all replicas within the job.
	// One of Always, OnFailure, Never and ExitCode.
	// Default to Never.
	RestartPolicy *common.RestartPolicy `json:"restartPolicy,omitempty"`
}

func (*ETReplicaSpec) DeepCopy 

func (in *ETReplicaSpec) DeepCopy() *ETReplicaSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ETReplicaSpec.

func (*ETReplicaSpec) DeepCopyInto 

func (in *ETReplicaSpec) DeepCopyInto(out *ETReplicaSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ETReplicaSpecs 

type ETReplicaSpecs struct {
	Launcher *common.ReplicaSpec `json:"Launcher"`
	Worker   *ETReplicaSpec      `json:"Worker"`
}

func (*ETReplicaSpecs) DeepCopy 

func (in *ETReplicaSpecs) DeepCopy() *ETReplicaSpecs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ETReplicaSpecs.

func (*ETReplicaSpecs) DeepCopyInto 

func (in *ETReplicaSpecs) DeepCopyInto(out *ETReplicaSpecs)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ETReplicaType 

type ETReplicaType common.ReplicaType

ETReplicaType is the type for ETReplica. 

const (
	// ETReplicaTypeLauncher is the type for launcher replica.
	ETReplicaTypeLauncher ETReplicaType = "Launcher"

	// ETReplicaTypeWorker is the type for worker replicas.
	ETReplicaTypeWorker ETReplicaType = "Worker"
)

type EnvSpec 

type EnvSpec struct {
	Name  string `json:"name,omitempty"`
	Value string `json:"value,omitempty"`
}

func (*EnvSpec) DeepCopy 

func (in *EnvSpec) DeepCopy() *EnvSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EnvSpec.

func (*EnvSpec) DeepCopyInto 

func (in *EnvSpec) DeepCopyInto(out *EnvSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ScaleIn 

type ScaleIn struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec ScaleInSpec `json:"spec,omitempty"`
	// Most recently observed status of the PyTorchJob.
	// Read-only (modified by the system).
	Status common.JobStatus `json:"status,omitempty"`
}

ScaleIn is the Schema for the scaleins API

func (*ScaleIn) DeepCopy 

func (in *ScaleIn) DeepCopy() *ScaleIn

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScaleIn.

func (*ScaleIn) DeepCopyInto 

func (in *ScaleIn) DeepCopyInto(out *ScaleIn)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ScaleIn) DeepCopyObject 

func (in *ScaleIn) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ScaleInList 

type ScaleInList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ScaleIn `json:"items"`
}

ScaleInList contains a list of ScaleIn

func (*ScaleInList) DeepCopy 

func (in *ScaleInList) DeepCopy() *ScaleInList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScaleInList.

func (*ScaleInList) DeepCopyInto 

func (in *ScaleInList) DeepCopyInto(out *ScaleInList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ScaleInList) DeepCopyObject 

func (in *ScaleInList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ScaleInSpec 

type ScaleInSpec struct {
	Script string `json:"script,omitempty"`

	// Optional number of retries to execute script.
	// +optional
	BackoffLimit *int32 `json:"backoffLimit,omitempty"`

	// Optional number of timeout to execute script.
	// +optional
	Timeout *int32 `json:"timeout,omitempty"`

	ToDelete *ToDeleteSpec `json:"toDelete,omitempty"`

	Selector Selector `json:"selector,omitempty"`

	Env []EnvSpec `json:"env,omitempty"`
}

ScaleInSpec defines the desired state of ScaleIn

func (*ScaleInSpec) DeepCopy 

func (in *ScaleInSpec) DeepCopy() *ScaleInSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScaleInSpec.

func (*ScaleInSpec) DeepCopyInto 

func (in *ScaleInSpec) DeepCopyInto(out *ScaleInSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ScaleInStatus 

type ScaleInStatus struct {
}

ScaleInStatus defines the observed state of ScaleIn

func (*ScaleInStatus) DeepCopy 

func (in *ScaleInStatus) DeepCopy() *ScaleInStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScaleInStatus.

func (*ScaleInStatus) DeepCopyInto 

func (in *ScaleInStatus) DeepCopyInto(out *ScaleInStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ScaleOut 

type ScaleOut struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec ScaleOutSpec `json:"spec,omitempty"`
	// Most recently observed status of the PyTorchJob.
	// Read-only (modified by the system).
	Status common.JobStatus `json:"status,omitempty"`
}

ScaleOut is the Schema for the scaleouts API

func (*ScaleOut) DeepCopy 

func (in *ScaleOut) DeepCopy() *ScaleOut

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScaleOut.

func (*ScaleOut) DeepCopyInto 

func (in *ScaleOut) DeepCopyInto(out *ScaleOut)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ScaleOut) DeepCopyObject 

func (in *ScaleOut) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ScaleOutList 

type ScaleOutList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ScaleOut `json:"items"`
}

ScaleOutList contains a list of ScaleOut

func (*ScaleOutList) DeepCopy 

func (in *ScaleOutList) DeepCopy() *ScaleOutList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScaleOutList.

func (*ScaleOutList) DeepCopyInto 

func (in *ScaleOutList) DeepCopyInto(out *ScaleOutList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ScaleOutList) DeepCopyObject 

func (in *ScaleOutList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ScaleOutSpec 

type ScaleOutSpec struct {
	Script string `json:"script,omitempty"`

	// Optional number of retries to execute script.
	// +optional
	BackoffLimit *int32 `json:"backoffLimit,omitempty"`

	// Optional number of timeout to execute script.
	// +optional
	Timeout *int32 `json:"timeout,omitempty"`

	ToAdd *ToAddSpec `json:"toAdd,omitempty"`

	Selector Selector `json:"selector,omitempty"`

	Env []EnvSpec `json:"env,omitempty"`
}

ScaleOutSpec defines the desired state of ScaleOut

func (*ScaleOutSpec) DeepCopy 

func (in *ScaleOutSpec) DeepCopy() *ScaleOutSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScaleOutSpec.

func (*ScaleOutSpec) DeepCopyInto 

func (in *ScaleOutSpec) DeepCopyInto(out *ScaleOutSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ScaleOutStatus 

type ScaleOutStatus struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	ScaleOutStatus string `json:"scaleOutStatus,omitempty"`
}

ScaleOutStatus defines the observed state of ScaleOut

func (*ScaleOutStatus) DeepCopy 

func (in *ScaleOutStatus) DeepCopy() *ScaleOutStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScaleOutStatus.

func (*ScaleOutStatus) DeepCopyInto 

func (in *ScaleOutStatus) DeepCopyInto(out *ScaleOutStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Selector 

type Selector struct {
	Name string `json:"name,omitempty"`
}

func (*Selector) DeepCopy 

func (in *Selector) DeepCopy() *Selector

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Selector.

func (*Selector) DeepCopyInto 

func (in *Selector) DeepCopyInto(out *Selector)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ToAddSpec 

type ToAddSpec struct {
	Count *int32 `json:"count,omitempty"`
}

func (*ToAddSpec) DeepCopy 

func (in *ToAddSpec) DeepCopy() *ToAddSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ToAddSpec.

func (*ToAddSpec) DeepCopyInto 

func (in *ToAddSpec) DeepCopyInto(out *ToAddSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ToDeleteSpec 

type ToDeleteSpec struct {
	Count    int      `json:"count,omitempty"`
	PodNames []string `json:"podNames,omitempty"`
}

func (*ToDeleteSpec) DeepCopy 

func (in *ToDeleteSpec) DeepCopy() *ToDeleteSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ToDeleteSpec.

func (*ToDeleteSpec) DeepCopyInto 

func (in *ToDeleteSpec) DeepCopyInto(out *ToDeleteSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TrainingJob 

type TrainingJob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec TrainingJobSpec `json:"spec,omitempty"`

	// Most recently observed status of the PyTorchJob.
	// Read-only (modified by the system).
	Status common.JobStatus `json:"status,omitempty"`
}

TrainingJob is the Schema for the trainingjobs API

func (*TrainingJob) DeepCopy 

func (in *TrainingJob) DeepCopy() *TrainingJob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TrainingJob.

func (*TrainingJob) DeepCopyInto 

func (in *TrainingJob) DeepCopyInto(out *TrainingJob)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TrainingJob) DeepCopyObject 

func (in *TrainingJob) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type TrainingJobList 

type TrainingJobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []TrainingJob `json:"items"`
}

TrainingJobList contains a list of TrainingJob

func (*TrainingJobList) DeepCopy 

func (in *TrainingJobList) DeepCopy() *TrainingJobList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TrainingJobList.

func (*TrainingJobList) DeepCopyInto 

func (in *TrainingJobList) DeepCopyInto(out *TrainingJobList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TrainingJobList) DeepCopyObject 

func (in *TrainingJobList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type TrainingJobSpec 

type TrainingJobSpec struct {

	// CleanPodPolicy defines the policy that whether to kill pods after the job completes.
	// Defaults to None.
	CleanPodPolicy *common.CleanPodPolicy `json:"cleanPodPolicy,omitempty"`

	// `ETReplicaSpecs` contains maps from `ETReplicaType` to `ReplicaSpec` that
	// specify the ET replicas to run.
	ETReplicaSpecs ETReplicaSpecs `json:"etReplicaSpecs"`

	// Specifies the number of slots per worker used in hostfile.
	// Defaults to 1.
	// +optional
	SlotsPerWorker *int32 `json:"slotsPerWorker,omitempty"`
}

TrainingJobSpec defines the desired state of TrainingJob

func (*TrainingJobSpec) DeepCopy 

func (in *TrainingJobSpec) DeepCopy() *TrainingJobSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TrainingJobSpec.

func (*TrainingJobSpec) DeepCopyInto 

func (in *TrainingJobSpec) DeepCopyInto(out *TrainingJobSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TrainingJobStatus 

type TrainingJobStatus struct {
}

TrainingJobStatus defines the observed state of TrainingJob

func (*TrainingJobStatus) DeepCopy 

func (in *TrainingJobStatus) DeepCopy() *TrainingJobStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TrainingJobStatus.

func (*TrainingJobStatus) DeepCopyInto 

func (in *TrainingJobStatus) DeepCopyInto(out *TrainingJobStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.