testing

Documentation

Index

• func MakeFactory(ctor Ctor) Factory
• func NewCronJob(s *v1alpha1.CronJobSource, options ...CronJobOption) *batchv1beta1.CronJob
• func NewCronJobSource(name string, options ...CronJobSourceOption) *v1alpha1.CronJobSource
• func NewJob(js *v1alpha1.JobSource, options ...JobOption) *batchv1.Job
• func NewJobSource(name string, options ...JobSourceOption) *v1alpha1.JobSource
• func NewScheme() *runtime.Scheme
• func NewService(s *v1alpha1.ServiceSource, options ...ServiceOption) *servingv1beta1.Service
• func NewServiceSource(name string, options ...ServiceSourceOption) *v1alpha1.ServiceSource
• func WithFakeCronJobSpec(s *v1alpha1.CronJobSource)
• func WithFakeJobContainer(js *v1alpha1.JobSource)
• func WithMinServiceSpec(s *v1alpha1.ServiceSource)
• type CronJobOption
• type CronJobSourceOption
• type Ctor
• type JobOption
• type JobSourceOption
• type Listers
  • func NewListers(objs []runtime.Object) Listers
  • func (l *Listers) GetAllObjects() []runtime.Object
  • func (l *Listers) GetConfigMapLister() corev1listers.ConfigMapLister
  • func (l *Listers) GetCronJobSourceLister() sourceslisters.CronJobSourceLister
  • func (l *Listers) GetCustomResourceDefinitionLister() apiextensionsv1beta1listers.CustomResourceDefinitionLister
  • func (l *Listers) GetDeploymentLister() appsv1listers.DeploymentLister
  • func (l *Listers) GetEndpointsLister() corev1listers.EndpointsLister
  • func (l *Listers) GetEventingObjects() []runtime.Object
  • func (l *Listers) GetJobSourceLister() sourceslisters.JobSourceLister
  • func (l *Listers) GetK8sServiceLister() corev1listers.ServiceLister
  • func (l *Listers) GetKubeObjects() []runtime.Object
  • func (l *Listers) GetNamespaceLister() corev1listers.NamespaceLister
  • func (l *Listers) GetObjectsFrom(getters ...func() []runtime.Object) []runtime.Object
  • func (l *Listers) GetRoleBindingLister() rbacv1listers.RoleBindingLister
  • func (l *Listers) GetServiceAccountLister() corev1listers.ServiceAccountLister
  • func (l *Listers) GetServiceLister() corev1listers.ServiceLister
  • func (l *Listers) GetServiceSourceLister() sourceslisters.ServiceSourceLister
  • func (l *Listers) GetServingObjects() []runtime.Object
  • func (l *Listers) GetSharedObjects() []runtime.Object
  • func (l *Listers) GetSinkObjects() []runtime.Object
  • func (l *Listers) GetSourcesObjects() []runtime.Object
• type ServiceOption
• type ServiceSourceOption

Functions

func MakeFactory

func MakeFactory(ctor Ctor) Factory

MakeFactory creates a reconciler factory with fake clients and controller created by `ctor`.

func NewCronJob

func NewCronJob(s *v1alpha1.CronJobSource, options ...CronJobOption) *batchv1beta1.CronJob

func NewCronJobSource

func NewCronJobSource(name string, options ...CronJobSourceOption) *v1alpha1.CronJobSource

func NewJob

func NewJob(js *v1alpha1.JobSource, options ...JobOption) *batchv1.Job

func NewJobSource

func NewJobSource(name string, options ...JobSourceOption) *v1alpha1.JobSource

func NewScheme

func NewScheme() *runtime.Scheme

func NewService

func NewService(s *v1alpha1.ServiceSource, options ...ServiceOption) *servingv1beta1.Service

func NewServiceSource

func NewServiceSource(name string, options ...ServiceSourceOption) *v1alpha1.ServiceSource

func WithFakeCronJobSpec

func WithFakeCronJobSpec(s *v1alpha1.CronJobSource)

func WithFakeJobContainer

func WithFakeJobContainer(js *v1alpha1.JobSource)

func WithMinServiceSpec

func WithMinServiceSpec(s *v1alpha1.ServiceSource)

Types

type CronJobOption

type CronJobOption func(*batchv1beta1.CronJob)

type CronJobSourceOption

type CronJobSourceOption func(*v1alpha1.CronJobSource)

type Ctor

type Ctor func(context.Context, *Listers, configmap.Watcher) controller.Reconciler

Ctor functions create a k8s controller with given params.

type JobOption

type JobOption func(*batchv1.Job)

type JobSourceOption

type JobSourceOption func(*v1alpha1.JobSource)

type Listers

type Listers struct {
	// contains filtered or unexported fields
}

func NewListers

func NewListers(objs []runtime.Object) Listers

func (*Listers) GetAllObjects

func (l *Listers) GetAllObjects() []runtime.Object

func (*Listers) GetConfigMapLister

func (l *Listers) GetConfigMapLister() corev1listers.ConfigMapLister

func (*Listers) GetCronJobSourceLister

func (l *Listers) GetCronJobSourceLister() sourceslisters.CronJobSourceLister

func (*Listers) GetCustomResourceDefinitionLister

func (l *Listers) GetCustomResourceDefinitionLister() apiextensionsv1beta1listers.CustomResourceDefinitionLister

func (*Listers) GetDeploymentLister

func (l *Listers) GetDeploymentLister() appsv1listers.DeploymentLister

func (*Listers) GetEndpointsLister

func (l *Listers) GetEndpointsLister() corev1listers.EndpointsLister

func (*Listers) GetEventingObjects

func (l *Listers) GetEventingObjects() []runtime.Object

func (*Listers) GetJobSourceLister

func (l *Listers) GetJobSourceLister() sourceslisters.JobSourceLister

func (*Listers) GetK8sServiceLister

func (l *Listers) GetK8sServiceLister() corev1listers.ServiceLister

func (*Listers) GetKubeObjects

func (l *Listers) GetKubeObjects() []runtime.Object

func (*Listers) GetNamespaceLister

func (l *Listers) GetNamespaceLister() corev1listers.NamespaceLister

func (*Listers) GetObjectsFrom

func (l *Listers) GetObjectsFrom(getters ...func() []runtime.Object) []runtime.Object

func (*Listers) GetRoleBindingLister

func (l *Listers) GetRoleBindingLister() rbacv1listers.RoleBindingLister

func (*Listers) GetServiceAccountLister

func (l *Listers) GetServiceAccountLister() corev1listers.ServiceAccountLister

func (*Listers) GetServiceLister

func (l *Listers) GetServiceLister() corev1listers.ServiceLister

func (*Listers) GetServiceSourceLister

func (l *Listers) GetServiceSourceLister() sourceslisters.ServiceSourceLister

func (*Listers) GetServingObjects

func (l *Listers) GetServingObjects() []runtime.Object

func (*Listers) GetSharedObjects

func (l *Listers) GetSharedObjects() []runtime.Object

func (*Listers) GetSinkObjects

func (l *Listers) GetSinkObjects() []runtime.Object

func (*Listers) GetSourcesObjects

func (l *Listers) GetSourcesObjects() []runtime.Object

type ServiceOption

type ServiceOption func(*servingv1beta1.Service)

type ServiceSourceOption

type ServiceSourceOption func(*v1alpha1.ServiceSource)