testing

Documentation

Overview

Package testing contains test helpers for reconcilers.

Index

• func MakeFactory(ctor Ctor) rt.Factory
• func NewARN(service, resource string) apis.ARN
• func NewConfigMap(name string, data map[string]string) *corev1.ConfigMap
• func NewRoleBinding(sa *corev1.ServiceAccount) func() *rbacv1.RoleBinding
• func NewScheme() *runtime.Scheme
• func NewServiceAccount(src kmeta.OwnerRefable) serviceAccountCtorWithOptions
• func NewTestDeploymentReconciler(ctx context.Context, ls *Listers) common.GenericDeploymentReconciler
• func NewTestServiceReconciler(ctx context.Context, ls *Listers) common.GenericServiceReconciler
• func Populate(srcCpy v1alpha1.EventSource)
• func SetEnvVar(t *testing.T, name, val string) (unset func())
• func TestControllerConstructor(t *testing.T, ctor injection.ControllerConstructor)
• func TestControllerConstructorFailures(t *testing.T, ctor injection.ControllerConstructor)
• func TestReconcileAdapter(t *testing.T, ctor Ctor, src v1alpha1.EventSource, adapterBuilder interface{})
• func ToUnstructured(t *testing.T, objs []runtime.Object) (unstr []runtime.Object)
• type Ctor
• type Listers
  • func NewListers(scheme *runtime.Scheme, objs []runtime.Object) Listers
  • func (l *Listers) GetAWSCloudWatchLogsSourceLister() listersv1alpha1.AWSCloudWatchLogsSourceLister
  • func (l *Listers) GetAWSCloudWatchSourceLister() listersv1alpha1.AWSCloudWatchSourceLister
  • func (l *Listers) GetAWSCodeCommitSourceLister() listersv1alpha1.AWSCodeCommitSourceLister
  • func (l *Listers) GetAWSCognitoIdentitySourceLister() listersv1alpha1.AWSCognitoIdentitySourceLister
  • func (l *Listers) GetAWSCognitoUserPoolSourceLister() listersv1alpha1.AWSCognitoUserPoolSourceLister
  • func (l *Listers) GetAWSDynamoDBSourceLister() listersv1alpha1.AWSDynamoDBSourceLister
  • func (l *Listers) GetAWSKinesisSourceLister() listersv1alpha1.AWSKinesisSourceLister
  • func (l *Listers) GetAWSSNSSourceLister() listersv1alpha1.AWSSNSSourceLister
  • func (l *Listers) GetAWSSQSSourceLister() listersv1alpha1.AWSSQSSourceLister
  • func (l *Listers) GetDeploymentLister() appslistersv1.DeploymentLister
  • func (l *Listers) GetKubeObjects() []runtime.Object
  • func (l *Listers) GetRoleBindingLister() rbaclistersv1.RoleBindingLister
  • func (l *Listers) GetServiceAccountLister() corelistersv1.ServiceAccountLister
  • func (l *Listers) GetServiceLister() servinglistersv1.ServiceLister
  • func (l *Listers) GetServingObjects() []runtime.Object
  • func (l *Listers) GetSourcesObjects() []runtime.Object
  • func (l *Listers) IndexerFor(obj runtime.Object) cache.Indexer

Functions

func MakeFactory

func MakeFactory(ctor Ctor) rt.Factory

MakeFactory creates a testing factory for our controller.Reconciler, and initializes a Reconciler using the given Ctor as part of the process.

func NewARN

func NewARN(service, resource string) apis.ARN

NewARN returns a ARN with the given attributes.

func NewConfigMap

func NewConfigMap(name string, data map[string]string) *corev1.ConfigMap

NewConfigMap returns a ConfigMap object.

func NewRoleBinding

func NewRoleBinding(sa *corev1.ServiceAccount) func() *rbacv1.RoleBinding

func NewScheme

func NewScheme() *runtime.Scheme

NewScheme returns a new scheme populated with the types defined in clientSetSchemes.

func NewServiceAccount

func NewServiceAccount(src kmeta.OwnerRefable) serviceAccountCtorWithOptions

func NewTestDeploymentReconciler

func NewTestDeploymentReconciler(ctx context.Context, ls *Listers) common.GenericDeploymentReconciler

NewTestDeploymentReconciler returns a GenericServiceReconciler initialized with test clients.

func NewTestServiceReconciler

func NewTestServiceReconciler(ctx context.Context, ls *Listers) common.GenericServiceReconciler

NewTestServiceReconciler returns a GenericServiceReconciler initialized with test clients.

func Populate

func Populate(srcCpy v1alpha1.EventSource)

Populate populates an event source with generic attributes.

func SetEnvVar

func SetEnvVar(t *testing.T, name, val string) (unset func())

SetEnvVar sets the value of an env var and returns a function that can be deferred to unset that variable.

func TestControllerConstructor

func TestControllerConstructor(t *testing.T, ctor injection.ControllerConstructor)

TestControllerConstructor tests that a controller constructor meets our requirements.

func TestControllerConstructorFailures

func TestControllerConstructorFailures(t *testing.T, ctor injection.ControllerConstructor)

TestControllerConstructorFailures tests that a controller constructor fails when various requirements are not met.

func TestReconcileAdapter

func TestReconcileAdapter(t *testing.T, ctor Ctor, src v1alpha1.EventSource, adapterBuilder interface{})

Test the Reconcile() method of the controller.Reconciler implemented by source Reconcilers, with focus on the generic ReconcileSource logic executed by the generic adapter reconciler embedded in every source Reconciler.

The environment for each test case is set up as follows:

1. MakeFactory initializes fake clients with the objects declared in the test case
2. MakeFactory injects those clients into a context along with fake event recorders, etc.
3. A Reconciler is constructed via a Ctor function using the values injected above
4. The Reconciler returned by MakeFactory is used to run the test case

func ToUnstructured

func ToUnstructured(t *testing.T, objs []runtime.Object) (unstr []runtime.Object)

ToUnstructured takes a list of k8s resources and converts them to Unstructured objects. We must pass objects as Unstructured to the dynamic client fake, or it won't handle them properly.

Types

type Ctor

type Ctor func(*testing.T, context.Context, *rt.TableRow, *Listers) controller.Reconciler

Ctor constructs a controller.Reconciler.

type Listers

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

Listers returns listers and objects filtered from those listers.

func NewListers

func NewListers(scheme *runtime.Scheme, objs []runtime.Object) Listers

NewListers returns a new instance of Listers initialized with the given objects.

func (*Listers) GetAWSCloudWatchLogsSourceLister

func (l *Listers) GetAWSCloudWatchLogsSourceLister() listersv1alpha1.AWSCloudWatchLogsSourceLister

GetAWSCloudWatchLogsSourceLister returns a Lister for AWSCloudWatchSource objects.

func (*Listers) GetAWSCloudWatchSourceLister

func (l *Listers) GetAWSCloudWatchSourceLister() listersv1alpha1.AWSCloudWatchSourceLister

GetAWSCloudWatchSourceLister returns a Lister for AWSCloudWatchSource objects.

func (*Listers) GetAWSCodeCommitSourceLister

func (l *Listers) GetAWSCodeCommitSourceLister() listersv1alpha1.AWSCodeCommitSourceLister

GetAWSCodeCommitSourceLister returns a Lister for AWSCodeCommitSource objects.

func (*Listers) GetAWSCognitoIdentitySourceLister

func (l *Listers) GetAWSCognitoIdentitySourceLister() listersv1alpha1.AWSCognitoIdentitySourceLister

GetAWSCognitoIdentitySourceLister returns a Lister for AWSCognitoUserPoolSource objects.

func (*Listers) GetAWSCognitoUserPoolSourceLister

func (l *Listers) GetAWSCognitoUserPoolSourceLister() listersv1alpha1.AWSCognitoUserPoolSourceLister

GetAWSCognitoUserPoolSourceLister returns a Lister for AWSCognitoIdentitySource objects.

func (*Listers) GetAWSDynamoDBSourceLister

func (l *Listers) GetAWSDynamoDBSourceLister() listersv1alpha1.AWSDynamoDBSourceLister

GetAWSDynamoDBSourceLister returns a Lister for AWSDynamoDBSource objects.

func (*Listers) GetAWSKinesisSourceLister

func (l *Listers) GetAWSKinesisSourceLister() listersv1alpha1.AWSKinesisSourceLister

GetAWSKinesisSourceLister returns a Lister for AWSKinesisSource objects.

func (*Listers) GetAWSSNSSourceLister

func (l *Listers) GetAWSSNSSourceLister() listersv1alpha1.AWSSNSSourceLister

GetAWSSNSSourceLister returns a Lister for AWSSNSSource objects.

func (*Listers) GetAWSSQSSourceLister

func (l *Listers) GetAWSSQSSourceLister() listersv1alpha1.AWSSQSSourceLister

GetAWSSQSSourceLister returns a Lister for AWSSQSSource objects.

func (*Listers) GetDeploymentLister

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

GetDeploymentLister returns a lister for Deployment objects.

func (*Listers) GetKubeObjects

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

GetKubeObjects returns objects from Kubernetes APIs.

func (*Listers) GetRoleBindingLister

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

GetRoleBindingLister returns a lister for RoleBinding objects

func (*Listers) GetServiceAccountLister

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

GetServiceAccountLister returns a lister for ServiceAccount objects.

func (*Listers) GetServiceLister

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

GetServiceLister returns a lister for Knative Service objects.

func (*Listers) GetServingObjects

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

GetServingObjects returns objects from the serving API.

func (*Listers) GetSourcesObjects

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

GetSourcesObjects returns objects from the sources API.

func (*Listers) IndexerFor

func (l *Listers) IndexerFor(obj runtime.Object) cache.Indexer

IndexerFor returns the indexer for the given object.