Versions in this module Expand all Collapse all v0 v0.1.1 Jan 16, 2020 v0.1.0 Jun 19, 2019 Changes in this version + const FailedCreatePodReason + const FailedCreateServiceReason + const FailedDeletePodReason + const FailedDeleteServiceReason + const SuccessfulCreatePodReason + const SuccessfulCreateServiceReason + const SuccessfulDeletePodReason + const SuccessfulDeleteServiceReason + var KeyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc + func GenExpectationPodsKey(jobKey, replicaType string) string + func GenExpectationServicesKey(jobKey, replicaType string) string + func GenGeneralName(jobName, rtype, index string) string + func GetPodFromTemplate(template *v1.PodTemplateSpec, parentObject runtime.Object, ...) (*v1.Pod, error) + func RecheckDeletionTimestamp(getObject func() (metav1.Object, error)) func() error + type FakeServiceControl struct + ControllerRefs []metav1.OwnerReference + CreateCallCount int + CreateLimit int + DeleteServiceName []string + Err error + Patches [][]byte + Templates []v1.Service + func (f *FakeServiceControl) Clear() + func (f *FakeServiceControl) CreateServices(namespace string, service *v1.Service, object runtime.Object) error + func (f *FakeServiceControl) CreateServicesWithControllerRef(namespace string, service *v1.Service, object runtime.Object, ...) error + func (f *FakeServiceControl) DeleteService(namespace string, serviceID string, object runtime.Object) error + func (f *FakeServiceControl) PatchService(namespace, name string, data []byte) error + type JobController apiv1.JobController + func (jc *JobController) AddPod(obj interface{}) + func (jc *JobController) AddService(obj interface{}) + func (jc *JobController) CreateNewService(job metav1.Object, rtype apiv1.ReplicaType, spec *apiv1.ReplicaSpec, ...) error + func (jc *JobController) CreateServicesWithControllerRef(namespace string, service *v1.Service, controllerObject runtime.Object, ...) error + func (jc *JobController) DeletePdb(job metav1.Object) error + func (jc *JobController) DeletePod(obj interface{}) + func (jc *JobController) DeletePodGroup(job metav1.Object) error + func (jc *JobController) DeleteService(obj interface{}) + func (jc *JobController) FilterPodsForReplicaType(pods []*v1.Pod, replicaType string) ([]*v1.Pod, error) + func (jc *JobController) FilterServicesForReplicaType(services []*v1.Service, replicaType string) ([]*v1.Service, error) + func (jc *JobController) GenLabels(jobName string) map[string]string + func (jc *JobController) GenOwnerReference(obj metav1.Object) *metav1.OwnerReference + func (jc *JobController) GetPodSlices(pods []*v1.Pod, replicas int, logger *log.Entry) [][]*v1.Pod + func (jc *JobController) GetPortFromJob(spec *apiv1.ReplicaSpec) (int32, error) + func (jc *JobController) GetServiceSlices(services []*v1.Service, replicas int, logger *log.Entry) [][]*v1.Service + func (jc *JobController) ReconcileJobs(job interface{}, replicas map[apiv1.ReplicaType]*apiv1.ReplicaSpec, ...) error + func (jc *JobController) ReconcilePods(job interface{}, jobStatus *apiv1.JobStatus, pods []*v1.Pod, ...) error + func (jc *JobController) ReconcileServices(job metav1.Object, services []*v1.Service, rtype apiv1.ReplicaType, ...) error + func (jc *JobController) SyncPdb(job metav1.Object, minAvailableReplicas int32) (*v1beta1.PodDisruptionBudget, error) + func (jc *JobController) SyncPodGroup(job metav1.Object, minAvailableReplicas int32) (*v1alpha1.PodGroup, error) + func (jc *JobController) UpdatePod(old, cur interface{}) + func (jc *JobController) UpdateService(old, cur interface{}) + type RealPodControl struct + KubeClient clientset.Interface + Recorder record.EventRecorder + func (r RealPodControl) CreatePods(namespace string, template *v1.PodTemplateSpec, object runtime.Object) error + func (r RealPodControl) CreatePodsOnNode(nodeName, namespace string, template *v1.PodTemplateSpec, ...) error + func (r RealPodControl) CreatePodsWithControllerRef(namespace string, template *v1.PodTemplateSpec, ...) error + func (r RealPodControl) DeletePod(namespace string, podID string, object runtime.Object) error + func (r RealPodControl) PatchPod(namespace, name string, data []byte) error + type RealServiceControl struct + KubeClient clientset.Interface + Recorder record.EventRecorder + func (r RealServiceControl) CreateServices(namespace string, service *v1.Service, object runtime.Object) error + func (r RealServiceControl) CreateServicesWithControllerRef(namespace string, service *v1.Service, controllerObject runtime.Object, ...) error + func (r RealServiceControl) DeleteService(namespace, serviceID string, object runtime.Object) error + func (r RealServiceControl) PatchService(namespace, name string, data []byte) error + type ServiceControlInterface interface + CreateServices func(namespace string, service *v1.Service, object runtime.Object) error + CreateServicesWithControllerRef func(namespace string, service *v1.Service, object runtime.Object, ...) error + DeleteService func(namespace, serviceID string, object runtime.Object) error + PatchService func(namespace, name string, data []byte) error + type ServiceControllerRefManager struct + func NewServiceControllerRefManager(serviceControl ServiceControlInterface, ctr metav1.Object, ...) *ServiceControllerRefManager + func (m *ServiceControllerRefManager) AdoptService(service *v1.Service) error + func (m *ServiceControllerRefManager) ClaimServices(services []*v1.Service, filters ...func(*v1.Service) bool) ([]*v1.Service, error) + func (m *ServiceControllerRefManager) ReleaseService(service *v1.Service) error + type TestJobController struct + 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) 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) + func (t TestJobController) UpdateJobStatus(job interface{}, replicas map[apiv1.ReplicaType]*apiv1.ReplicaSpec, ...) error
Go to main page