testing

Documentation

Index

• func MakeFactory(ctor Ctor, unstructured bool, logger *zap.SugaredLogger) Factory
• func NewEventType(name, namespace string, o ...EventTypeOption) *v1beta1.EventType
• func NewScheme() *runtime.Scheme
• func ToUnstructured(t *testing.T, objs []runtime.Object) (us []runtime.Object)
• func WithEventTypeBrokerDoesNotExist(et *v1beta1.EventType)
• func WithEventTypeBrokerExists(et *v1beta1.EventType)
• func WithEventTypeBrokerReady(et *v1beta1.EventType)
• func WithEventTypeDeletionTimestamp(et *v1beta1.EventType)
• func WithInitEventTypeConditions(et *v1beta1.EventType)
• type Ctor
• type EventTypeOption
  • func WithEventTypeBroker(broker string) EventTypeOption
  • func WithEventTypeBrokerFailed(reason, message string) EventTypeOption
  • func WithEventTypeBrokerUnknown(reason, message string) EventTypeOption
  • func WithEventTypeDescription(description string) EventTypeOption
  • func WithEventTypeLabels(labels map[string]string) EventTypeOption
  • func WithEventTypeOwnerReference(ownerRef metav1.OwnerReference) EventTypeOption
  • func WithEventTypeSource(source *apis.URL) EventTypeOption
  • func WithEventTypeType(t string) EventTypeOption
• type Listers
  • func NewListers(objs []runtime.Object) Listers
  • func (l *Listers) GetAPIExtensionObjects() []runtime.Object
  • func (l *Listers) GetAllObjects() []runtime.Object
  • func (l *Listers) GetConfigMapLister() corev1listers.ConfigMapLister
  • func (l *Listers) GetCustomResourceDefinitionLister() apiextensionsv1listers.CustomResourceDefinitionLister
  • func (l *Listers) GetDeploymentLister() appsv1listers.DeploymentLister
  • func (l *Listers) GetEndpointsLister() corev1listers.EndpointsLister
  • func (l *Listers) GetEventTypeLister() eventingv1beta1listers.EventTypeLister
  • func (l *Listers) GetEventingObjects() []runtime.Object
  • func (l *Listers) GetK8sServiceLister() corev1listers.ServiceLister
  • func (l *Listers) GetKubeObjects() []runtime.Object
  • func (l *Listers) GetNamespaceLister() corev1listers.NamespaceLister
  • func (l *Listers) GetRoleBindingLister() rbacv1listers.RoleBindingLister
  • func (l *Listers) GetServiceAccountLister() corev1listers.ServiceAccountLister
  • func (l *Listers) GetServiceLister() corev1listers.ServiceLister
  • func (l *Listers) GetSubscriberObjects() []runtime.Object

Functions

func MakeFactory

func MakeFactory(ctor Ctor, unstructured bool, logger *zap.SugaredLogger) Factory

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

func NewEventType

func NewEventType(name, namespace string, o ...EventTypeOption) *v1beta1.EventType

NewEventType creates a EventType with EventTypeOptions.

func NewScheme

func NewScheme() *runtime.Scheme

func ToUnstructured

func ToUnstructured(t *testing.T, objs []runtime.Object) (us []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.

func WithEventTypeBrokerDoesNotExist

func WithEventTypeBrokerDoesNotExist(et *v1beta1.EventType)

WithEventTypeBrokerNotFound calls .Status.MarkFilterFailed on the EventType.

func WithEventTypeBrokerExists

func WithEventTypeBrokerExists(et *v1beta1.EventType)

WithEventTypeBrokerExists calls .Status.MarkBrokerExists on the EventType.

func WithEventTypeBrokerReady

func WithEventTypeBrokerReady(et *v1beta1.EventType)

WithEventTypeBrokerReady calls .Status.MarkBrokerReady on the EventType.

func WithEventTypeDeletionTimestamp

func WithEventTypeDeletionTimestamp(et *v1beta1.EventType)

func WithInitEventTypeConditions

func WithInitEventTypeConditions(et *v1beta1.EventType)

WithInitEventTypeConditions initializes the EventType's conditions.

Types

type Ctor

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

Ctor functions create a k8s controller with given params.

type EventTypeOption

type EventTypeOption func(*v1beta1.EventType)

EventTypeOption enables further configuration of an EventType.

func WithEventTypeBroker

func WithEventTypeBroker(broker string) EventTypeOption

func WithEventTypeBrokerFailed

func WithEventTypeBrokerFailed(reason, message string) EventTypeOption

func WithEventTypeBrokerUnknown

func WithEventTypeBrokerUnknown(reason, message string) EventTypeOption

func WithEventTypeDescription

func WithEventTypeDescription(description string) EventTypeOption

func WithEventTypeLabels

func WithEventTypeLabels(labels map[string]string) EventTypeOption

func WithEventTypeOwnerReference

func WithEventTypeOwnerReference(ownerRef metav1.OwnerReference) EventTypeOption

func WithEventTypeSource

func WithEventTypeSource(source *apis.URL) EventTypeOption

func WithEventTypeType

func WithEventTypeType(t string) EventTypeOption

type Listers

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

func NewListers

func NewListers(objs []runtime.Object) Listers

func (*Listers) GetAPIExtensionObjects

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

func (*Listers) GetAllObjects

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

func (*Listers) GetConfigMapLister

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

func (*Listers) GetCustomResourceDefinitionLister

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

func (*Listers) GetDeploymentLister

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

func (*Listers) GetEndpointsLister

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

func (*Listers) GetEventTypeLister

func (l *Listers) GetEventTypeLister() eventingv1beta1listers.EventTypeLister

func (*Listers) GetEventingObjects

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

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

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