testing

package

Go to main page

Versions in this module

v2

v2.2.0

Mar 19, 2026

Changes in this version

type JobSetWrapper

+ func (j *JobSetWrapper) ContainerSecurityContext(rJobName, containerName string, securityContext corev1.SecurityContext) *JobSetWrapper

+ func (j *JobSetWrapper) PodSecurityContext(rJobName string, securityContext corev1.PodSecurityContext) *JobSetWrapper

type MLPolicySourceWrapper

+ func (w *MLPolicySourceWrapper) JAXPolicy() *MLPolicySourceWrapper

+ func (w *MLPolicySourceWrapper) XGBoostPolicy() *MLPolicySourceWrapper

type TrainJobWrapper

+ func (t *TrainJobWrapper) ActiveDeadlineSeconds(deadline int64) *TrainJobWrapper

+ func (t *TrainJobWrapper) RuntimePatches(patches []trainer.RuntimePatch) *TrainJobWrapper

v2.2.0-rc.1

Mar 18, 2026

v2.2.0-rc.0

Mar 13, 2026

v2.1.0

Nov 7, 2025

Changes in this version

type JobSetWrapper

+ func (j *JobSetWrapper) Affinity(rJobName string, affinity corev1.Affinity) *JobSetWrapper

+ func (j *JobSetWrapper) ImagePullSecrets(rJobName string, imagePullSecrets ...corev1.LocalObjectReference) *JobSetWrapper

+ func (j *JobSetWrapper) PodAnnotation(key, value string) *JobSetWrapper

+ func (j *JobSetWrapper) PodAnnotationForJobs(key, value string, rJobNames ...string) *JobSetWrapper

+ func (j *JobSetWrapper) PodLabelForJobs(key, value string, rJobNames ...string) *JobSetWrapper

+ func (j *JobSetWrapper) PodPriorityClassName(value string) *JobSetWrapper

+ func (j *JobSetWrapper) ReplaceContainer(rJobName, containerName, newContainerName, image string, ...) *JobSetWrapper

+ func (j *JobSetWrapper) ReplicatedJobsStatuses(statuses []jobsetv1alpha2.ReplicatedJobStatus) *JobSetWrapper

type TrainJobWrapper

+ func (t *TrainJobWrapper) PodTemplateOverrides(podTemplateOverrides []trainer.PodTemplateOverride) *TrainJobWrapper

+ type VolcanoPodGroupWrapper struct

+ func MakeVolcanoPodGroup(namespace, name string) *VolcanoPodGroupWrapper

+ func (p *VolcanoPodGroupWrapper) ControllerReference(gvk schema.GroupVersionKind, name, uid string) *VolcanoPodGroupWrapper

+ func (p *VolcanoPodGroupWrapper) MinMember(members int32) *VolcanoPodGroupWrapper

+ func (p *VolcanoPodGroupWrapper) MinResources(resources *corev1.ResourceList) *VolcanoPodGroupWrapper

+ func (p *VolcanoPodGroupWrapper) NetworkTopology(mode volcanov1beta1.NetworkTopologyMode, highestTier int) *VolcanoPodGroupWrapper

+ func (p *VolcanoPodGroupWrapper) Obj() *volcanov1beta1.PodGroup

+ func (p *VolcanoPodGroupWrapper) PriorityClassName(pc string) *VolcanoPodGroupWrapper

+ func (p *VolcanoPodGroupWrapper) Queue(queue string) *VolcanoPodGroupWrapper

v2.1.0-rc.1

Nov 3, 2025

v2.1.0-rc.0

Oct 21, 2025

v2.0.1

Sep 29, 2025

v2.0.0

Jul 17, 2025

Changes in this version

+ const ForbiddenError

+ const InvalidError

+ const NotFoundError

+ var PodSetEndpointsCmpOpts = cmp.Transformer("Seq", func(a iter.Seq[string]) []string { ... })

+ var TrainJobUpdateReconcileRequestCmpOpts = cmp.Transformer("SeqTrainJobUpdateReconcileRequest", ...)

+ func AsIndex(builder *fake.ClientBuilder) client.FieldIndexer

+ func BeAPIError(name errorMatcher) types.GomegaMatcher

+ func BeForbiddenError() types.GomegaMatcher

+ func BeInvalidError() types.GomegaMatcher

+ func BeNotFoundError() types.GomegaMatcher

+ func MPISecretDataComparer(a, b map[string][]byte) bool

+ func NewClientBuilder(addToSchemes ...func(s *runtime.Scheme) error) *fake.ClientBuilder

+ func ToObject(s *runtime.Scheme, objects ...any) ([]runtime.Object, error)

+ type ClusterTrainingRuntimeWrapper struct

+ func MakeClusterTrainingRuntimeWrapper(name string) *ClusterTrainingRuntimeWrapper

+ func (r *ClusterTrainingRuntimeWrapper) DeletionTimestamp(t metav1.Time) *ClusterTrainingRuntimeWrapper

+ func (r *ClusterTrainingRuntimeWrapper) Finalizers(f ...string) *ClusterTrainingRuntimeWrapper

+ func (r *ClusterTrainingRuntimeWrapper) Obj() *trainer.ClusterTrainingRuntime

+ func (r *ClusterTrainingRuntimeWrapper) RuntimeSpec(spec trainer.TrainingRuntimeSpec) *ClusterTrainingRuntimeWrapper

+ type ConfigMapWrapper struct

+ func MakeConfigMapWrapper(name, ns string) *ConfigMapWrapper

+ func (c *ConfigMapWrapper) ControllerReference(gvk schema.GroupVersionKind, name, uid string) *ConfigMapWrapper

+ func (c *ConfigMapWrapper) Obj() *corev1.ConfigMap

+ func (c *ConfigMapWrapper) WithData(data map[string]string) *ConfigMapWrapper

+ type JobSetWrapper struct

+ func MakeJobSetWrapper(namespace, name string) *JobSetWrapper

+ func (j *JobSetWrapper) Annotation(key, value string) *JobSetWrapper

+ func (j *JobSetWrapper) Completions(c int32, rJobNames ...string) *JobSetWrapper

+ func (j *JobSetWrapper) Conditions(conditions ...metav1.Condition) *JobSetWrapper

+ func (j *JobSetWrapper) Container(rJobName, containerName, image string, command []string, args []string, ...) *JobSetWrapper

+ func (j *JobSetWrapper) ContainerTrainerPorts(ports []corev1.ContainerPort) *JobSetWrapper

+ func (j *JobSetWrapper) ControllerReference(gvk schema.GroupVersionKind, name, uid string) *JobSetWrapper

+ func (j *JobSetWrapper) DependsOn(rJobName string, dependsOn ...jobsetv1alpha2.DependsOn) *JobSetWrapper

+ func (j *JobSetWrapper) Env(rJobName, containerName string, envs ...corev1.EnvVar) *JobSetWrapper

+ func (j *JobSetWrapper) EnvFrom(rJobName, containerName string, envFrom ...corev1.EnvFromSource) *JobSetWrapper

+ func (j *JobSetWrapper) InitContainer(rJobName, containerName, image string, envs ...corev1.EnvVar) *JobSetWrapper

+ func (j *JobSetWrapper) Label(key, value string) *JobSetWrapper

+ func (j *JobSetWrapper) LauncherReplica() *JobSetWrapper

+ func (j *JobSetWrapper) NodeSelector(rJobName string, selector map[string]string) *JobSetWrapper

+ func (j *JobSetWrapper) NumNodes(numNodes int32) *JobSetWrapper

+ func (j *JobSetWrapper) Obj() *jobsetv1alpha2.JobSet

+ func (j *JobSetWrapper) Parallelism(p int32, rJobNames ...string) *JobSetWrapper

+ func (j *JobSetWrapper) PodLabel(key, value string) *JobSetWrapper

+ func (j *JobSetWrapper) Replicas(replicas int32, rJobNames ...string) *JobSetWrapper

+ func (j *JobSetWrapper) ReplicatedJobLabel(key, value string, rJobNames ...string) *JobSetWrapper

+ func (j *JobSetWrapper) SchedulingGates(rJobName string, schedulingGates ...corev1.PodSchedulingGate) *JobSetWrapper

+ func (j *JobSetWrapper) ServiceAccountName(rJobName string, serviceAccountName string) *JobSetWrapper

+ func (j *JobSetWrapper) Suspend(suspend bool) *JobSetWrapper

+ func (j *JobSetWrapper) Tolerations(rJobName string, tolerations ...corev1.Toleration) *JobSetWrapper

+ func (j *JobSetWrapper) VolumeMounts(rJobName, containerName string, vms ...corev1.VolumeMount) *JobSetWrapper

+ func (j *JobSetWrapper) Volumes(rJobName string, v ...corev1.Volume) *JobSetWrapper

+ type MLPolicySourceWrapper struct

+ func MakeMLPolicySourceWrapper() *MLPolicySourceWrapper

+ func (m *MLPolicySourceWrapper) MPIPolicy(numProcPerNode *int32, MPImplementation *trainer.MPIImplementation, ...) *MLPolicySourceWrapper

+ func (m *MLPolicySourceWrapper) Obj() *trainer.MLPolicySource

+ func (m *MLPolicySourceWrapper) TorchPolicy(numProcPerNode *intstr.IntOrString, elasticPolicy *trainer.TorchElasticPolicy) *MLPolicySourceWrapper

+ type MLPolicyWrapper struct

+ func MakeMLPolicyWrapper() *MLPolicyWrapper

+ func (m *MLPolicyWrapper) Obj() *trainer.MLPolicy

+ func (m *MLPolicyWrapper) WithMLPolicySource(source trainer.MLPolicySource) *MLPolicyWrapper

+ func (m *MLPolicyWrapper) WithNumNodes(numNodes int32) *MLPolicyWrapper

+ type SchedulerPluginsPodGroupWrapper struct

+ func MakeSchedulerPluginsPodGroup(namespace, name string) *SchedulerPluginsPodGroupWrapper

+ func (p *SchedulerPluginsPodGroupWrapper) ControllerReference(gvk schema.GroupVersionKind, name, uid string) *SchedulerPluginsPodGroupWrapper

+ func (p *SchedulerPluginsPodGroupWrapper) MinMember(members int32) *SchedulerPluginsPodGroupWrapper

+ func (p *SchedulerPluginsPodGroupWrapper) MinResources(resources corev1.ResourceList) *SchedulerPluginsPodGroupWrapper

+ func (p *SchedulerPluginsPodGroupWrapper) Obj() *schedulerpluginsv1alpha1.PodGroup

+ func (p *SchedulerPluginsPodGroupWrapper) SchedulingTimeout(timeout int32) *SchedulerPluginsPodGroupWrapper

+ type SecretWrapper struct

+ func MakeSecretWrapper(name, ns string) *SecretWrapper

+ func (s *SecretWrapper) ControllerReference(gvk schema.GroupVersionKind, name, uid string) *SecretWrapper

+ func (s *SecretWrapper) Obj() *corev1.Secret

+ func (s *SecretWrapper) WithData(data map[string][]byte) *SecretWrapper

+ func (s *SecretWrapper) WithImmutable(immutable bool) *SecretWrapper

+ func (s *SecretWrapper) WithType(t corev1.SecretType) *SecretWrapper

+ type TrainJobDatasetInitializerWrapper struct

+ func MakeTrainJobDatasetInitializerWrapper() *TrainJobDatasetInitializerWrapper

+ func (t *TrainJobDatasetInitializerWrapper) Env(env ...corev1.EnvVar) *TrainJobDatasetInitializerWrapper

+ func (t *TrainJobDatasetInitializerWrapper) Obj() *trainer.DatasetInitializer

+ func (t *TrainJobDatasetInitializerWrapper) SecretRef(secretRef corev1.LocalObjectReference) *TrainJobDatasetInitializerWrapper

+ func (t *TrainJobDatasetInitializerWrapper) StorageUri(storageUri string) *TrainJobDatasetInitializerWrapper

+ type TrainJobInitializerWrapper struct

+ func MakeTrainJobInitializerWrapper() *TrainJobInitializerWrapper

+ func (t *TrainJobInitializerWrapper) DatasetInitializer(datasetInitializer *trainer.DatasetInitializer) *TrainJobInitializerWrapper

+ func (t *TrainJobInitializerWrapper) ModelInitializer(modelInitializer *trainer.ModelInitializer) *TrainJobInitializerWrapper

+ func (t *TrainJobInitializerWrapper) Obj() *trainer.Initializer

+ type TrainJobModelInitializerWrapper struct

+ func MakeTrainJobModelInitializerWrapper() *TrainJobModelInitializerWrapper

+ func (t *TrainJobModelInitializerWrapper) Env(env ...corev1.EnvVar) *TrainJobModelInitializerWrapper

+ func (t *TrainJobModelInitializerWrapper) Obj() *trainer.ModelInitializer

+ func (t *TrainJobModelInitializerWrapper) SecretRef(secretRef corev1.LocalObjectReference) *TrainJobModelInitializerWrapper

+ func (t *TrainJobModelInitializerWrapper) StorageUri(storageUri string) *TrainJobModelInitializerWrapper

+ type TrainJobTrainerWrapper struct

+ func MakeTrainJobTrainerWrapper() *TrainJobTrainerWrapper

+ func (t *TrainJobTrainerWrapper) Container(image string, command []string, args []string, resRequests corev1.ResourceList) *TrainJobTrainerWrapper

+ func (t *TrainJobTrainerWrapper) Env(env ...corev1.EnvVar) *TrainJobTrainerWrapper

+ func (t *TrainJobTrainerWrapper) NumNodes(numNodes int32) *TrainJobTrainerWrapper

+ func (t *TrainJobTrainerWrapper) NumProcPerNode(numProcPerNode intstr.IntOrString) *TrainJobTrainerWrapper

+ func (t *TrainJobTrainerWrapper) Obj() *trainer.Trainer

+ type TrainJobWrapper struct

+ func MakeTrainJobWrapper(namespace, name string) *TrainJobWrapper

+ func (t *TrainJobWrapper) Initializer(initializer *trainer.Initializer) *TrainJobWrapper

+ func (t *TrainJobWrapper) ManagedBy(m string) *TrainJobWrapper

+ func (t *TrainJobWrapper) Obj() *trainer.TrainJob

+ func (t *TrainJobWrapper) PodSpecOverrides(podSpecOverrides []trainer.PodSpecOverride) *TrainJobWrapper

+ func (t *TrainJobWrapper) RuntimeRef(gvk schema.GroupVersionKind, name string) *TrainJobWrapper

+ func (t *TrainJobWrapper) SpecAnnotation(key, value string) *TrainJobWrapper

+ func (t *TrainJobWrapper) SpecLabel(key, value string) *TrainJobWrapper

+ func (t *TrainJobWrapper) Suspend(suspend bool) *TrainJobWrapper

+ func (t *TrainJobWrapper) Trainer(trainer *trainer.Trainer) *TrainJobWrapper

+ func (t *TrainJobWrapper) UID(uid string) *TrainJobWrapper

+ type TrainingRuntimeSpecWrapper struct

+ func MakeTrainingRuntimeSpecWrapper(spec trainer.TrainingRuntimeSpec) *TrainingRuntimeSpecWrapper

+ func (s *TrainingRuntimeSpecWrapper) Container(rJobName, containerName, image string, command []string, args []string, ...) *TrainingRuntimeSpecWrapper

+ func (s *TrainingRuntimeSpecWrapper) Env(rJobName, containerName string, envs ...corev1.EnvVar) *TrainingRuntimeSpecWrapper

+ func (s *TrainingRuntimeSpecWrapper) InitContainer(rJobName, containerName, image string, envs ...corev1.EnvVar) *TrainingRuntimeSpecWrapper

+ func (s *TrainingRuntimeSpecWrapper) JobSetSpec(spec jobsetv1alpha2.JobSetSpec) *TrainingRuntimeSpecWrapper

+ func (s *TrainingRuntimeSpecWrapper) LauncherReplica() *TrainingRuntimeSpecWrapper

+ func (s *TrainingRuntimeSpecWrapper) Obj() trainer.TrainingRuntimeSpec

+ func (s *TrainingRuntimeSpecWrapper) PodGroupPolicyCoscheduling(src *trainer.CoschedulingPodGroupPolicySource) *TrainingRuntimeSpecWrapper

+ func (s *TrainingRuntimeSpecWrapper) PodGroupPolicyCoschedulingSchedulingTimeout(timeout int32) *TrainingRuntimeSpecWrapper

+ func (s *TrainingRuntimeSpecWrapper) Replicas(replicas int32, rJobNames ...string) *TrainingRuntimeSpecWrapper

+ func (s *TrainingRuntimeSpecWrapper) WithMLPolicy(mlPolicy *trainer.MLPolicy) *TrainingRuntimeSpecWrapper

+ type TrainingRuntimeWrapper struct

+ func MakeTrainingRuntimeWrapper(namespace, name string) *TrainingRuntimeWrapper

+ func (r *TrainingRuntimeWrapper) Annotation(key, value string) *TrainingRuntimeWrapper

+ func (r *TrainingRuntimeWrapper) DeletionTimestamp(t metav1.Time) *TrainingRuntimeWrapper

+ func (r *TrainingRuntimeWrapper) Finalizers(f ...string) *TrainingRuntimeWrapper

+ func (r *TrainingRuntimeWrapper) Label(key, value string) *TrainingRuntimeWrapper

+ func (r *TrainingRuntimeWrapper) Obj() *trainer.TrainingRuntime

+ func (r *TrainingRuntimeWrapper) RuntimeSpec(spec trainer.TrainingRuntimeSpec) *TrainingRuntimeWrapper

v2.0.0-rc.1

Jul 3, 2025

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