Versions in this module Expand all Collapse all v0 v0.1.2 Jun 10, 2021 Changes in this version + const DefaultContainerName + const DefaultPort + const DefaultPortName + const DefaultRestartPolicy + const EnvKubeflowNamespace + const GroupName + const GroupVersion + const Kind + const Plural + const Singular + const TESTCRD + var AddToScheme = localSchemeBuilder.AddToScheme + var SchemeBuilder runtime.SchemeBuilder + var SchemeGroupVersion = schema.GroupVersion + var SchemeGroupVersionKind = SchemeGroupVersion.WithKind(Kind) + func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition + func Int32(v int32) *int32 + func RegisterDefaults(scheme *runtime.Scheme) error + func Resource(resource string) schema.GroupResource + func SetDefaults_TestJob(testjob *TestJob) + func SetObjectDefaults_TestJob(in *TestJob) + func SetObjectDefaults_TestJobList(in *TestJobList) + type TestJob struct + Spec TestJobSpec + Status apiv1.JobStatus + func (in *TestJob) DeepCopy() *TestJob + func (in *TestJob) DeepCopyInto(out *TestJob) + func (in *TestJob) DeepCopyObject() runtime.Object + type TestJobController struct + Job *TestJob + Pods []*corev1.Pod + Services []*corev1.Service + func (TestJobController) ControllerName() string + func (TestJobController) GetAPIGroupVersion() schema.GroupVersion + func (TestJobController) GetAPIGroupVersionKind() schema.GroupVersionKind + func (TestJobController) GetDefaultContainerPortName() string + func (TestJobController) GetDefaultContainerPortNumber() int32 + func (TestJobController) GetGroupNameLabelValue() string + func (TestJobController) GetJobRoleKey() string + func (t *TestJobController) CreatePod(job interface{}, pod *corev1.Pod) error + func (t *TestJobController) CreateService(job interface{}, service *corev1.Service) error + func (t *TestJobController) DeleteJob(job interface{}) error + func (t *TestJobController) DeletePod(job interface{}, pod *corev1.Pod) error + func (t *TestJobController) DeleteService(job interface{}, name string, namespace string) error + func (t *TestJobController) GetDefaultContainerName() string + func (t *TestJobController) GetJobFromAPIClient(namespace, name string) (v1.Object, error) + func (t *TestJobController) GetJobFromInformerCache(namespace, name string) (v1.Object, error) + func (t *TestJobController) IsMasterRole(replicas map[apiv1.ReplicaType]*apiv1.ReplicaSpec, rtype apiv1.ReplicaType, ...) bool + func (t *TestJobController) SetClusterSpec(job interface{}, podTemplate *corev1.PodTemplateSpec, rtype, index string) error + func (t *TestJobController) UpdateJobStatus(job interface{}, replicas map[apiv1.ReplicaType]*apiv1.ReplicaSpec, ...) error + func (t *TestJobController) UpdateJobStatusInApiServer(job interface{}, jobStatus *apiv1.JobStatus) error + func (t TestJobController) GetPodsForJob(job interface{}) ([]*corev1.Pod, error) + func (t TestJobController) GetServicesForJob(job interface{}) ([]*corev1.Service, error) + type TestJobList struct + Items []TestJob + func (in *TestJobList) DeepCopy() *TestJobList + func (in *TestJobList) DeepCopyInto(out *TestJobList) + func (in *TestJobList) DeepCopyObject() runtime.Object + type TestJobSpec struct + RunPolicy *apiv1.RunPolicy + TestReplicaSpecs map[TestReplicaType]*apiv1.ReplicaSpec + func (in *TestJobSpec) DeepCopy() *TestJobSpec + func (in *TestJobSpec) DeepCopyInto(out *TestJobSpec) + type TestReplicaType apiv1.ReplicaType + const TestReplicaTypeMaster + const TestReplicaTypeWorker
Go to main page