Documentation ¶
Index ¶
- type TestJobController
- func (TestJobController) ControllerName() 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 (TestJobController) GetAPIGroupVersion() schema.GroupVersion
- func (TestJobController) GetAPIGroupVersionKind() schema.GroupVersionKind
- func (t *TestJobController) GetDefaultContainerName() string
- func (TestJobController) GetDefaultContainerPortName() string
- func (TestJobController) GetDefaultContainerPortNumber() int32
- func (TestJobController) GetGroupNameLabelValue() string
- func (t *TestJobController) GetJobFromAPIClient(namespace, name string) (metav1.Object, error)
- func (t *TestJobController) GetJobFromInformerCache(namespace, name string) (metav1.Object, error)
- func (TestJobController) GetJobRoleKey() string
- func (t TestJobController) GetPodsForJob(job interface{}) ([]*corev1.Pod, error)
- func (t TestJobController) GetServicesForJob(job interface{}) ([]*corev1.Service, error)
- func (t *TestJobController) IsMasterRole(replicas map[commonv1.ReplicaType]*commonv1.ReplicaSpec, ...) bool
- func (t *TestJobController) SetClusterSpec(job interface{}, podTemplate *corev1.PodTemplateSpec, rtype, index string) error
- func (t *TestJobController) UpdateJobStatus(job interface{}, replicas map[commonv1.ReplicaType]*commonv1.ReplicaSpec, ...) error
- func (t *TestJobController) UpdateJobStatusInApiServer(job interface{}, jobStatus *commonv1.JobStatus) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TestJobController ¶
func (TestJobController) ControllerName ¶
func (TestJobController) ControllerName() string
func (*TestJobController) CreatePod ¶
func (t *TestJobController) CreatePod(job interface{}, pod *corev1.Pod) error
func (*TestJobController) CreateService ¶
func (t *TestJobController) CreateService(job interface{}, service *corev1.Service) error
func (*TestJobController) DeleteJob ¶
func (t *TestJobController) DeleteJob(job interface{}) error
func (*TestJobController) DeletePod ¶
func (t *TestJobController) DeletePod(job interface{}, pod *corev1.Pod) error
func (*TestJobController) DeleteService ¶
func (t *TestJobController) DeleteService(job interface{}, name string, namespace string) error
func (TestJobController) GetAPIGroupVersion ¶
func (TestJobController) GetAPIGroupVersion() schema.GroupVersion
func (TestJobController) GetAPIGroupVersionKind ¶
func (TestJobController) GetAPIGroupVersionKind() schema.GroupVersionKind
func (*TestJobController) GetDefaultContainerName ¶
func (t *TestJobController) GetDefaultContainerName() string
func (TestJobController) GetDefaultContainerPortName ¶
func (TestJobController) GetDefaultContainerPortName() string
func (TestJobController) GetDefaultContainerPortNumber ¶
func (TestJobController) GetDefaultContainerPortNumber() int32
func (TestJobController) GetGroupNameLabelValue ¶
func (TestJobController) GetGroupNameLabelValue() string
func (*TestJobController) GetJobFromAPIClient ¶
func (t *TestJobController) GetJobFromAPIClient(namespace, name string) (metav1.Object, error)
func (*TestJobController) GetJobFromInformerCache ¶
func (t *TestJobController) GetJobFromInformerCache(namespace, name string) (metav1.Object, error)
func (TestJobController) GetJobRoleKey ¶
func (TestJobController) GetJobRoleKey() string
func (TestJobController) GetPodsForJob ¶
func (t TestJobController) GetPodsForJob(job interface{}) ([]*corev1.Pod, error)
func (TestJobController) GetServicesForJob ¶
func (t TestJobController) GetServicesForJob(job interface{}) ([]*corev1.Service, error)
func (*TestJobController) IsMasterRole ¶
func (t *TestJobController) IsMasterRole(replicas map[commonv1.ReplicaType]*commonv1.ReplicaSpec, rtype commonv1.ReplicaType, index int) bool
func (*TestJobController) SetClusterSpec ¶
func (t *TestJobController) SetClusterSpec(job interface{}, podTemplate *corev1.PodTemplateSpec, rtype, index string) error
func (*TestJobController) UpdateJobStatus ¶
func (t *TestJobController) UpdateJobStatus(job interface{}, replicas map[commonv1.ReplicaType]*commonv1.ReplicaSpec, jobStatus *commonv1.JobStatus) error
func (*TestJobController) UpdateJobStatusInApiServer ¶
func (t *TestJobController) UpdateJobStatusInApiServer(job interface{}, jobStatus *commonv1.JobStatus) error
Click to show internal directories.
Click to hide internal directories.