testing

package
v1.9.1 Latest Latest
Warning

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

 Go to latest Published: Mar 24, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	NotFoundError errorMatcher = iota
	ForbiddenError
	InvalidError
)

Variables

This section is empty.

Functions

func AsIndex 

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

func BeAPIError 

func BeAPIError(name errorMatcher) types.GomegaMatcher

func BeForbiddenError 

func BeForbiddenError() types.GomegaMatcher

func BeInvalidError 

func BeInvalidError() types.GomegaMatcher

func BeNotFoundError 

func BeNotFoundError() types.GomegaMatcher

func NewClientBuilder 

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

Types

type ClusterTrainingRuntimeWrapper 

type ClusterTrainingRuntimeWrapper struct {
	kubeflowv2.ClusterTrainingRuntime
}

func MakeClusterTrainingRuntimeWrapper 

func MakeClusterTrainingRuntimeWrapper(name string) *ClusterTrainingRuntimeWrapper

func (*ClusterTrainingRuntimeWrapper) Obj 

func (r *ClusterTrainingRuntimeWrapper) Obj() *kubeflowv2.ClusterTrainingRuntime

func (*ClusterTrainingRuntimeWrapper) RuntimeSpec 

func (r *ClusterTrainingRuntimeWrapper) RuntimeSpec(spec kubeflowv2.TrainingRuntimeSpec) *ClusterTrainingRuntimeWrapper

type JobSetWrapper 

type JobSetWrapper struct {
	jobsetv1alpha2.JobSet
}

func MakeJobSetWrapper 

func MakeJobSetWrapper(namespace, name string) *JobSetWrapper

func (*JobSetWrapper) Annotation 

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

func (*JobSetWrapper) Conditions 

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

func (*JobSetWrapper) ContainerTrainer 

func (j *JobSetWrapper) ContainerTrainer(image string, command []string, args []string, res corev1.ResourceList) *JobSetWrapper

func (*JobSetWrapper) ContainerTrainerEnv 

func (j *JobSetWrapper) ContainerTrainerEnv(env []corev1.EnvVar) *JobSetWrapper

func (*JobSetWrapper) ContainerTrainerPorts 

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

func (*JobSetWrapper) ControllerReference 

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

func (*JobSetWrapper) InitContainerDatasetInitializerEnv 

func (j *JobSetWrapper) InitContainerDatasetInitializerEnv(env []corev1.EnvVar) *JobSetWrapper

func (*JobSetWrapper) InitContainerDatasetInitializerEnvFrom 

func (j *JobSetWrapper) InitContainerDatasetInitializerEnvFrom(envFrom []corev1.EnvFromSource) *JobSetWrapper

func (*JobSetWrapper) InitContainerDatasetModelInitializer 

func (j *JobSetWrapper) InitContainerDatasetModelInitializer(image string, command []string, args []string, res corev1.ResourceList) *JobSetWrapper

func (*JobSetWrapper) InitContainerModelInitializerEnv 

func (j *JobSetWrapper) InitContainerModelInitializerEnv(env []corev1.EnvVar) *JobSetWrapper

func (*JobSetWrapper) InitContainerModelInitializerEnvFrom 

func (j *JobSetWrapper) InitContainerModelInitializerEnvFrom(envFrom []corev1.EnvFromSource) *JobSetWrapper

func (*JobSetWrapper) Label 

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

func (*JobSetWrapper) NumNodes 

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

func (*JobSetWrapper) Obj 

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

func (*JobSetWrapper) PodLabel 

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

func (*JobSetWrapper) Replicas 

func (j *JobSetWrapper) Replicas(replicas int32) *JobSetWrapper

func (*JobSetWrapper) Suspend 

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

type SchedulerPluginsPodGroupWrapper 

type SchedulerPluginsPodGroupWrapper struct {
	schedulerpluginsv1alpha1.PodGroup
}

func MakeSchedulerPluginsPodGroup 

func MakeSchedulerPluginsPodGroup(namespace, name string) *SchedulerPluginsPodGroupWrapper

func (*SchedulerPluginsPodGroupWrapper) ControllerReference 

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

func (*SchedulerPluginsPodGroupWrapper) MinMember 

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

func (*SchedulerPluginsPodGroupWrapper) MinResources 

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

func (*SchedulerPluginsPodGroupWrapper) Obj 

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

func (*SchedulerPluginsPodGroupWrapper) SchedulingTimeout 

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

type TrainJobDatasetConfigWrapper 

type TrainJobDatasetConfigWrapper struct {
	kubeflowv2.DatasetConfig
}

func MakeTrainJobDatasetConfigWrapper 

func MakeTrainJobDatasetConfigWrapper() *TrainJobDatasetConfigWrapper

func (*TrainJobDatasetConfigWrapper) ContainerEnv 

func (t *TrainJobDatasetConfigWrapper) ContainerEnv(env []corev1.EnvVar) *TrainJobDatasetConfigWrapper

func (*TrainJobDatasetConfigWrapper) Obj 

func (t *TrainJobDatasetConfigWrapper) Obj() *kubeflowv2.DatasetConfig

func (*TrainJobDatasetConfigWrapper) SecretRef 

func (t *TrainJobDatasetConfigWrapper) SecretRef(secretRef corev1.LocalObjectReference) *TrainJobDatasetConfigWrapper

func (*TrainJobDatasetConfigWrapper) StorageUri 

func (t *TrainJobDatasetConfigWrapper) StorageUri(storageUri string) *TrainJobDatasetConfigWrapper

type TrainJobModelConfigWrapper 

type TrainJobModelConfigWrapper struct {
	kubeflowv2.ModelConfig
}

func MakeTrainJobModelConfigWrapper 

func MakeTrainJobModelConfigWrapper() *TrainJobModelConfigWrapper

func (*TrainJobModelConfigWrapper) ContainerEnv 

func (t *TrainJobModelConfigWrapper) ContainerEnv(env []corev1.EnvVar) *TrainJobModelConfigWrapper

func (*TrainJobModelConfigWrapper) Obj 

func (t *TrainJobModelConfigWrapper) Obj() *kubeflowv2.ModelConfig

func (*TrainJobModelConfigWrapper) SecretRef 

func (t *TrainJobModelConfigWrapper) SecretRef(secretRef corev1.LocalObjectReference) *TrainJobModelConfigWrapper

func (*TrainJobModelConfigWrapper) StorageUri 

func (t *TrainJobModelConfigWrapper) StorageUri(storageUri string) *TrainJobModelConfigWrapper

type TrainJobTrainerWrapper 

type TrainJobTrainerWrapper struct {
	kubeflowv2.Trainer
}

func MakeTrainJobTrainerWrapper 

func MakeTrainJobTrainerWrapper() *TrainJobTrainerWrapper

func (*TrainJobTrainerWrapper) Container 

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

func (*TrainJobTrainerWrapper) ContainerEnv 

func (t *TrainJobTrainerWrapper) ContainerEnv(env []corev1.EnvVar) *TrainJobTrainerWrapper

func (*TrainJobTrainerWrapper) NumNodes 

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

func (*TrainJobTrainerWrapper) NumProcPerNode 

func (t *TrainJobTrainerWrapper) NumProcPerNode(numProcPerNode string) *TrainJobTrainerWrapper

func (*TrainJobTrainerWrapper) Obj 

func (t *TrainJobTrainerWrapper) Obj() *kubeflowv2.Trainer

type TrainJobWrapper 

type TrainJobWrapper struct {
	kubeflowv2.TrainJob
}

func MakeTrainJobWrapper 

func MakeTrainJobWrapper(namespace, name string) *TrainJobWrapper

func (*TrainJobWrapper) DatasetConfig 

func (t *TrainJobWrapper) DatasetConfig(datasetConfig *kubeflowv2.DatasetConfig) *TrainJobWrapper

func (*TrainJobWrapper) ManagedBy 

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

func (*TrainJobWrapper) ModelConfig 

func (t *TrainJobWrapper) ModelConfig(modelConfig *kubeflowv2.ModelConfig) *TrainJobWrapper

func (*TrainJobWrapper) Obj 

func (t *TrainJobWrapper) Obj() *kubeflowv2.TrainJob

func (*TrainJobWrapper) RuntimeRef 

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

func (*TrainJobWrapper) SpecAnnotation 

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

func (*TrainJobWrapper) SpecLabel 

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

func (*TrainJobWrapper) Suspend 

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

func (*TrainJobWrapper) Trainer 

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

func (*TrainJobWrapper) UID 

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

type TrainingRuntimeSpecWrapper 

type TrainingRuntimeSpecWrapper struct {
	kubeflowv2.TrainingRuntimeSpec
}

func MakeTrainingRuntimeSpecWrapper 

func MakeTrainingRuntimeSpecWrapper(spec kubeflowv2.TrainingRuntimeSpec) *TrainingRuntimeSpecWrapper

func (*TrainingRuntimeSpecWrapper) ContainerTrainer 

func (s *TrainingRuntimeSpecWrapper) ContainerTrainer(image string, command []string, args []string, res corev1.ResourceList) *TrainingRuntimeSpecWrapper

func (*TrainingRuntimeSpecWrapper) ContainerTrainerEnv 

func (s *TrainingRuntimeSpecWrapper) ContainerTrainerEnv(env []corev1.EnvVar) *TrainingRuntimeSpecWrapper

func (*TrainingRuntimeSpecWrapper) InitContainerDatasetModelInitializer 

func (s *TrainingRuntimeSpecWrapper) InitContainerDatasetModelInitializer(image string, command []string, args []string, res corev1.ResourceList) *TrainingRuntimeSpecWrapper

func (*TrainingRuntimeSpecWrapper) NumNodes 

func (s *TrainingRuntimeSpecWrapper) NumNodes(numNodes int32) *TrainingRuntimeSpecWrapper

func (*TrainingRuntimeSpecWrapper) Obj 

func (s *TrainingRuntimeSpecWrapper) Obj() kubeflowv2.TrainingRuntimeSpec

func (*TrainingRuntimeSpecWrapper) PodGroupPolicyCoscheduling 

func (s *TrainingRuntimeSpecWrapper) PodGroupPolicyCoscheduling(src *kubeflowv2.CoschedulingPodGroupPolicySource) *TrainingRuntimeSpecWrapper

func (*TrainingRuntimeSpecWrapper) PodGroupPolicyCoschedulingSchedulingTimeout 

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

func (*TrainingRuntimeSpecWrapper) TorchPolicy 

func (s *TrainingRuntimeSpecWrapper) TorchPolicy(numNodes int32, numProcPerNode string) *TrainingRuntimeSpecWrapper

type TrainingRuntimeWrapper 

type TrainingRuntimeWrapper struct {
	kubeflowv2.TrainingRuntime
}

func MakeTrainingRuntimeWrapper 

func MakeTrainingRuntimeWrapper(namespace, name string) *TrainingRuntimeWrapper

func (*TrainingRuntimeWrapper) Annotation 

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

func (*TrainingRuntimeWrapper) Label 

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

func (*TrainingRuntimeWrapper) Obj 

func (r *TrainingRuntimeWrapper) Obj() *kubeflowv2.TrainingRuntime

func (*TrainingRuntimeWrapper) RuntimeSpec 

func (r *TrainingRuntimeWrapper) RuntimeSpec(spec kubeflowv2.TrainingRuntimeSpec) *TrainingRuntimeWrapper

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.