testing

Documentation

Index

• func MakeFactory(ctor Ctor, unstructured bool, logger *zap.SugaredLogger) Factory
• func NewScheme() *runtime.Scheme
• func ToUnstructured(t *testing.T, objs []runtime.Object) (us []runtime.Object)
• type Ctor
• type Listers
  • func NewListers(objs []runtime.Object) Listers
  • func (l *Listers) GetAllObjects() []runtime.Object
  • func (l *Listers) GetApiServerSourceLister() sourcelisters.ApiServerSourceLister
  • func (l *Listers) GetBindingLister() rabbitlisters.BindingLister
  • func (l *Listers) GetBrokerLister() eventinglisters.BrokerLister
  • func (l *Listers) GetConfigMapLister() corev1listers.ConfigMapLister
  • func (l *Listers) GetContainerSourceLister() sourcelisters.ContainerSourceLister
  • func (l *Listers) GetCustomResourceDefinitionLister() apiextensionsv1listers.CustomResourceDefinitionLister
  • func (l *Listers) GetDeploymentLister() appsv1listers.DeploymentLister
  • func (l *Listers) GetEndpointsLister() corev1listers.EndpointsLister
  • func (l *Listers) GetEventingObjects() []runtime.Object
  • func (l *Listers) GetExchangeLister() rabbitlisters.ExchangeLister
  • func (l *Listers) GetInMemoryChannelLister() messaginglisters.InMemoryChannelLister
  • func (l *Listers) GetK8sServiceLister() corev1listers.ServiceLister
  • func (l *Listers) GetKubeObjects() []runtime.Object
  • func (l *Listers) GetMessagingChannelLister() messaginglisters.ChannelLister
  • func (l *Listers) GetNamespaceLister() corev1listers.NamespaceLister
  • func (l *Listers) GetParallelLister() flowslisters.ParallelLister
  • func (l *Listers) GetQueueLister() rabbitlisters.QueueLister
  • func (l *Listers) GetRabbitObjects() []runtime.Object
  • func (l *Listers) GetRmqEventingObjects() []runtime.Object
  • func (l *Listers) GetRoleBindingLister() rbacv1listers.RoleBindingLister
  • func (l *Listers) GetSecretLister() corev1listers.SecretLister
  • func (l *Listers) GetSequenceLister() flowslisters.SequenceLister
  • func (l *Listers) GetServiceAccountLister() corev1listers.ServiceAccountLister
  • func (l *Listers) GetServiceLister() corev1listers.ServiceLister
  • func (l *Listers) GetSinkBindingLister() sourcelisters.SinkBindingLister
  • func (l *Listers) GetSubscriberObjects() []runtime.Object
  • func (l *Listers) GetSubscriptionLister() messaginglisters.SubscriptionLister
  • func (l *Listers) GetTriggerLister() eventinglisters.TriggerLister

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 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.

Types

type Ctor

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

Ctor functions create a k8s controller with given params.

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

func (l *Listers) GetApiServerSourceLister() sourcelisters.ApiServerSourceLister

func (*Listers) GetBindingLister

func (l *Listers) GetBindingLister() rabbitlisters.BindingLister

func (*Listers) GetBrokerLister

func (l *Listers) GetBrokerLister() eventinglisters.BrokerLister

func (*Listers) GetConfigMapLister

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

func (*Listers) GetContainerSourceLister

func (l *Listers) GetContainerSourceLister() sourcelisters.ContainerSourceLister

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

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

func (*Listers) GetExchangeLister

func (l *Listers) GetExchangeLister() rabbitlisters.ExchangeLister

func (*Listers) GetInMemoryChannelLister

func (l *Listers) GetInMemoryChannelLister() messaginglisters.InMemoryChannelLister

func (*Listers) GetK8sServiceLister

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

func (*Listers) GetKubeObjects

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

func (*Listers) GetMessagingChannelLister

func (l *Listers) GetMessagingChannelLister() messaginglisters.ChannelLister

func (*Listers) GetNamespaceLister

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

func (*Listers) GetParallelLister

func (l *Listers) GetParallelLister() flowslisters.ParallelLister

func (*Listers) GetQueueLister

func (l *Listers) GetQueueLister() rabbitlisters.QueueLister

func (*Listers) GetRabbitObjects

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

func (*Listers) GetRmqEventingObjects

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

func (*Listers) GetRoleBindingLister

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

func (*Listers) GetSecretLister

func (l *Listers) GetSecretLister() corev1listers.SecretLister

func (*Listers) GetSequenceLister

func (l *Listers) GetSequenceLister() flowslisters.SequenceLister

func (*Listers) GetServiceAccountLister

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

func (*Listers) GetServiceLister

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

func (*Listers) GetSinkBindingLister

func (l *Listers) GetSinkBindingLister() sourcelisters.SinkBindingLister

func (*Listers) GetSubscriberObjects

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

func (*Listers) GetSubscriptionLister

func (l *Listers) GetSubscriptionLister() messaginglisters.SubscriptionLister

func (*Listers) GetTriggerLister

func (l *Listers) GetTriggerLister() eventinglisters.TriggerLister