Documentation ¶
Index ¶
- type TestJobController
- func (TestJobController) ControllerName() string
- func (t *TestJobController) DeleteJob(job interface{}) error
- func (TestJobController) GetAPIGroupVersion() schema.GroupVersion
- func (TestJobController) GetAPIGroupVersionKind() schema.GroupVersionKind
- func (t *TestJobController) GetDefaultContainerName() string
- func (TestJobController) GetDefaultContainerPortName() string
- 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 (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 ¶
type TestJobController struct { commonv1.ControllerInterface Job *v1.TestJob Pods []*corev1.Pod Services []*corev1.Service }
func (TestJobController) ControllerName ¶
func (TestJobController) ControllerName() string
func (*TestJobController) DeleteJob ¶
func (t *TestJobController) DeleteJob(job interface{}) 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) 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) 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.