Documentation
¶
Index ¶
- type Controller
- func (_m *Controller) ApplyConfigMap(ctx context.Context, namespace string, configMap *cluster.ConfigMap) error
- func (_m *Controller) ApplyIstioVirtualService(ctx context.Context, routerEndpoint *cluster.VirtualService) error
- func (_m *Controller) ApplyPersistentVolumeClaim(ctx context.Context, namespace string, pvc *cluster.PersistentVolumeClaim) error
- func (_m *Controller) ApplyPodDisruptionBudget(ctx context.Context, namespace string, pdb cluster.PodDisruptionBudget) (*v1.PodDisruptionBudget, error)
- func (_m *Controller) CreateJob(ctx context.Context, namespace string, job cluster.Job) (*batchv1.Job, error)
- func (_m *Controller) CreateNamespace(ctx context.Context, name string) error
- func (_m *Controller) CreateRole(ctx context.Context, namespace string, role *cluster.Role) (*rbacv1.Role, error)
- func (_m *Controller) CreateRoleBinding(ctx context.Context, namespace string, roleBinding *cluster.RoleBinding) (*rbacv1.RoleBinding, error)
- func (_m *Controller) CreateSecret(ctx context.Context, secret *cluster.Secret) error
- func (_m *Controller) CreateServiceAccount(ctx context.Context, namespace string, serviceAccount *cluster.ServiceAccount) (*corev1.ServiceAccount, error)
- func (_m *Controller) CreateSparkApplication(ctx context.Context, namespace string, request *cluster.CreateSparkRequest) (*v1beta2.SparkApplication, error)
- func (_m *Controller) DeleteConfigMap(ctx context.Context, name string, namespace string, ignoreNotFound bool) error
- func (_m *Controller) DeleteIstioVirtualService(ctx context.Context, svcName string, namespace string) error
- func (_m *Controller) DeleteJob(ctx context.Context, namespace string, jobName string) error
- func (_m *Controller) DeleteKnativeService(ctx context.Context, svcName string, namespace string, ignoreNotFound bool) error
- func (_m *Controller) DeleteKubernetesDeployment(ctx context.Context, name string, namespace string, ignoreNotFound bool) error
- func (_m *Controller) DeleteKubernetesService(ctx context.Context, svcName string, namespace string, ignoreNotFound bool) error
- func (_m *Controller) DeletePersistentVolumeClaim(ctx context.Context, pvcName string, namespace string, ignoreNotFound bool) error
- func (_m *Controller) DeletePodDisruptionBudget(ctx context.Context, namespace string, pdbName string) error
- func (_m *Controller) DeleteSecret(ctx context.Context, secretName string, namespace string, ignoreNotFound bool) error
- func (_m *Controller) DeleteSparkApplication(ctx context.Context, namespace string, appName string) error
- func (_m *Controller) DeployKnativeService(ctx context.Context, svc *cluster.KnativeService) error
- func (_m *Controller) DeployKubernetesService(ctx context.Context, svc *cluster.KubernetesService) error
- func (_m *Controller) GetJob(ctx context.Context, namespace string, jobName string) (*batchv1.Job, error)
- func (_m *Controller) GetKnativeServiceDesiredReplicas(ctx context.Context, svcName string, namespace string) (int, error)
- func (_m *Controller) GetKnativeServiceURL(ctx context.Context, svcName string, namespace string) string
- func (_m *Controller) GetSparkApplication(ctx context.Context, namespace string, appName string) (*v1beta2.SparkApplication, error)
- func (_m *Controller) ListPodLogs(ctx context.Context, namespace string, podName string, ...) (io.ReadCloser, error)
- func (_m *Controller) ListPods(ctx context.Context, namespace string, labelSelector string) (*corev1.PodList, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
Controller is an autogenerated mock type for the Controller type
func NewController ¶
func NewController(t mockConstructorTestingTNewController) *Controller
NewController creates a new instance of Controller. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Controller) ApplyConfigMap ¶
func (_m *Controller) ApplyConfigMap(ctx context.Context, namespace string, configMap *cluster.ConfigMap) error
ApplyConfigMap provides a mock function with given fields: ctx, namespace, configMap
func (*Controller) ApplyIstioVirtualService ¶
func (_m *Controller) ApplyIstioVirtualService(ctx context.Context, routerEndpoint *cluster.VirtualService) error
ApplyIstioVirtualService provides a mock function with given fields: ctx, routerEndpoint
func (*Controller) ApplyPersistentVolumeClaim ¶
func (_m *Controller) ApplyPersistentVolumeClaim(ctx context.Context, namespace string, pvc *cluster.PersistentVolumeClaim) error
ApplyPersistentVolumeClaim provides a mock function with given fields: ctx, namespace, pvc
func (*Controller) ApplyPodDisruptionBudget ¶
func (_m *Controller) ApplyPodDisruptionBudget(ctx context.Context, namespace string, pdb cluster.PodDisruptionBudget) (*v1.PodDisruptionBudget, error)
ApplyPodDisruptionBudget provides a mock function with given fields: ctx, namespace, pdb
func (*Controller) CreateJob ¶
func (_m *Controller) CreateJob(ctx context.Context, namespace string, job cluster.Job) (*batchv1.Job, error)
CreateJob provides a mock function with given fields: ctx, namespace, job
func (*Controller) CreateNamespace ¶
func (_m *Controller) CreateNamespace(ctx context.Context, name string) error
CreateNamespace provides a mock function with given fields: ctx, name
func (*Controller) CreateRole ¶
func (_m *Controller) CreateRole(ctx context.Context, namespace string, role *cluster.Role) (*rbacv1.Role, error)
CreateRole provides a mock function with given fields: ctx, namespace, role
func (*Controller) CreateRoleBinding ¶
func (_m *Controller) CreateRoleBinding(ctx context.Context, namespace string, roleBinding *cluster.RoleBinding) (*rbacv1.RoleBinding, error)
CreateRoleBinding provides a mock function with given fields: ctx, namespace, roleBinding
func (*Controller) CreateSecret ¶
CreateSecret provides a mock function with given fields: ctx, secret
func (*Controller) CreateServiceAccount ¶
func (_m *Controller) CreateServiceAccount(ctx context.Context, namespace string, serviceAccount *cluster.ServiceAccount) (*corev1.ServiceAccount, error)
CreateServiceAccount provides a mock function with given fields: ctx, namespace, serviceAccount
func (*Controller) CreateSparkApplication ¶
func (_m *Controller) CreateSparkApplication(ctx context.Context, namespace string, request *cluster.CreateSparkRequest) (*v1beta2.SparkApplication, error)
CreateSparkApplication provides a mock function with given fields: ctx, namespace, request
func (*Controller) DeleteConfigMap ¶
func (_m *Controller) DeleteConfigMap(ctx context.Context, name string, namespace string, ignoreNotFound bool) error
DeleteConfigMap provides a mock function with given fields: ctx, name, namespace, ignoreNotFound
func (*Controller) DeleteIstioVirtualService ¶
func (_m *Controller) DeleteIstioVirtualService(ctx context.Context, svcName string, namespace string) error
DeleteIstioVirtualService provides a mock function with given fields: ctx, svcName, namespace
func (*Controller) DeleteJob ¶
DeleteJob provides a mock function with given fields: ctx, namespace, jobName
func (*Controller) DeleteKnativeService ¶
func (_m *Controller) DeleteKnativeService(ctx context.Context, svcName string, namespace string, ignoreNotFound bool) error
DeleteKnativeService provides a mock function with given fields: ctx, svcName, namespace, ignoreNotFound
func (*Controller) DeleteKubernetesDeployment ¶
func (_m *Controller) DeleteKubernetesDeployment(ctx context.Context, name string, namespace string, ignoreNotFound bool) error
DeleteKubernetesDeployment provides a mock function with given fields: ctx, name, namespace, ignoreNotFound
func (*Controller) DeleteKubernetesService ¶
func (_m *Controller) DeleteKubernetesService(ctx context.Context, svcName string, namespace string, ignoreNotFound bool) error
DeleteKubernetesService provides a mock function with given fields: ctx, svcName, namespace, ignoreNotFound
func (*Controller) DeletePersistentVolumeClaim ¶
func (_m *Controller) DeletePersistentVolumeClaim(ctx context.Context, pvcName string, namespace string, ignoreNotFound bool) error
DeletePersistentVolumeClaim provides a mock function with given fields: ctx, pvcName, namespace, ignoreNotFound
func (*Controller) DeletePodDisruptionBudget ¶
func (_m *Controller) DeletePodDisruptionBudget(ctx context.Context, namespace string, pdbName string) error
DeletePodDisruptionBudget provides a mock function with given fields: ctx, namespace, pdbName
func (*Controller) DeleteSecret ¶
func (_m *Controller) DeleteSecret(ctx context.Context, secretName string, namespace string, ignoreNotFound bool) error
DeleteSecret provides a mock function with given fields: ctx, secretName, namespace, ignoreNotFound
func (*Controller) DeleteSparkApplication ¶
func (_m *Controller) DeleteSparkApplication(ctx context.Context, namespace string, appName string) error
DeleteSparkApplication provides a mock function with given fields: ctx, namespace, appName
func (*Controller) DeployKnativeService ¶
func (_m *Controller) DeployKnativeService(ctx context.Context, svc *cluster.KnativeService) error
DeployKnativeService provides a mock function with given fields: ctx, svc
func (*Controller) DeployKubernetesService ¶
func (_m *Controller) DeployKubernetesService(ctx context.Context, svc *cluster.KubernetesService) error
DeployKubernetesService provides a mock function with given fields: ctx, svc
func (*Controller) GetJob ¶
func (_m *Controller) GetJob(ctx context.Context, namespace string, jobName string) (*batchv1.Job, error)
GetJob provides a mock function with given fields: ctx, namespace, jobName
func (*Controller) GetKnativeServiceDesiredReplicas ¶
func (_m *Controller) GetKnativeServiceDesiredReplicas(ctx context.Context, svcName string, namespace string) (int, error)
GetKnativeServiceDesiredReplicas provides a mock function with given fields: ctx, svcName, namespace
func (*Controller) GetKnativeServiceURL ¶
func (_m *Controller) GetKnativeServiceURL(ctx context.Context, svcName string, namespace string) string
GetKnativeServiceURL provides a mock function with given fields: ctx, svcName, namespace
func (*Controller) GetSparkApplication ¶
func (_m *Controller) GetSparkApplication(ctx context.Context, namespace string, appName string) (*v1beta2.SparkApplication, error)
GetSparkApplication provides a mock function with given fields: ctx, namespace, appName
func (*Controller) ListPodLogs ¶
func (_m *Controller) ListPodLogs(ctx context.Context, namespace string, podName string, opts *corev1.PodLogOptions) (io.ReadCloser, error)
ListPodLogs provides a mock function with given fields: ctx, namespace, podName, opts
Source Files