mocks

Documentation

Index

• type Controller
  • func NewController(t interface{ ... }) *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) ApplyPodDisruptionBudget(ctx context.Context, 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) DeleteKubernetesService(ctx context.Context, svcName string, namespace string, ignoreNotFound bool) error
  • func (_m *Controller) DeleteKubernetesStatefulSet(ctx context.Context, name string, namespace string, ignoreNotFound bool) error
  • func (_m *Controller) DeletePVCs(ctx context.Context, listOptions metav1.ListOptions, namespace string, ...) 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)

Types

type Controller

type Controller struct {
	mock.Mock
}

Controller is an autogenerated mock type for the Controller type

func NewController

func NewController(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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) ApplyPodDisruptionBudget

func (_m *Controller) ApplyPodDisruptionBudget(ctx context.Context, pdb cluster.PodDisruptionBudget) (*v1.PodDisruptionBudget, error)

ApplyPodDisruptionBudget provides a mock function with given fields: ctx, 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

func (_m *Controller) CreateSecret(ctx context.Context, secret *cluster.Secret) error

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

func (_m *Controller) DeleteJob(ctx context.Context, namespace string, jobName string) error

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) 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) DeleteKubernetesStatefulSet

func (_m *Controller) DeleteKubernetesStatefulSet(ctx context.Context, name string, namespace string, ignoreNotFound bool) error

DeleteKubernetesStatefulSet provides a mock function with given fields: ctx, name, namespace, ignoreNotFound

func (*Controller) DeletePVCs

func (_m *Controller) DeletePVCs(ctx context.Context, listOptions metav1.ListOptions, namespace string, ignoreNotFound bool) error

DeletePVCs provides a mock function with given fields: ctx, listOptions, 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

func (*Controller) ListPods

func (_m *Controller) ListPods(ctx context.Context, namespace string, labelSelector string) (*corev1.PodList, error)

ListPods provides a mock function with given fields: ctx, namespace, labelSelector