testing

Documentation

Index

• func MakeFactory(ctor Ctor) Factory
• func NewNatssChannel(name, namespace string, ncopt ...NatssChannelOption) *v1alpha1.NatssChannel
• func WithNatssChannelDeleted(nc *v1alpha1.NatssChannel)
• func WithNatssChannelFinalizer(nc *v1alpha1.NatssChannel)
• func WithNatssInitChannelConditions(nc *v1alpha1.NatssChannel)
• func WithReady(nc *v1alpha1.NatssChannel)
• type Ctor
• type Listers
  • func NewListers(objs []runtime.Object) Listers
  • func (l *Listers) GetAllObjects() []runtime.Object
  • func (l *Listers) GetDeploymentLister() appsv1listers.DeploymentLister
  • func (l *Listers) GetEndpointsLister() corev1listers.EndpointsLister
  • func (l *Listers) GetEventingObjects() []runtime.Object
  • func (l *Listers) GetEventsObjects() []runtime.Object
  • func (l *Listers) GetKubeObjects() []runtime.Object
  • func (l *Listers) GetMessagingObjects() []runtime.Object
  • func (l *Listers) GetNatssChannelLister() messaginglisters.NatssChannelLister
  • func (l *Listers) GetServiceLister() corev1listers.ServiceLister
• type NatssChannelOption
  • func Addressable() NatssChannelOption
  • func WithNatssChannelAddress(a string) NatssChannelOption
  • func WithNatssChannelChannelServiceReady() NatssChannelOption
  • func WithNatssChannelChannelServicetNotReady(reason, message string) NatssChannelOption
  • func WithNatssChannelDeploymentNotReady(reason, message string) NatssChannelOption
  • func WithNatssChannelDeploymentReady() NatssChannelOption
  • func WithNatssChannelEndpointsNotReady(reason, message string) NatssChannelOption
  • func WithNatssChannelEndpointsReady() NatssChannelOption
  • func WithNatssChannelServiceNotReady(reason, message string) NatssChannelOption
  • func WithNatssChannelServiceReady() NatssChannelOption
  • func WithNatssChannelSubscribableStatus(ready corev1.ConditionStatus, message string) NatssChannelOption
  • func WithNatssChannelSubscribers(t *testing.T, subscriberURI string) NatssChannelOption
  • func WithNotReady(reason, messageFormat string) NatssChannelOption

Functions

func MakeFactory

func MakeFactory(ctor Ctor) Factory

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

func NewNatssChannel

func NewNatssChannel(name, namespace string, ncopt ...NatssChannelOption) *v1alpha1.NatssChannel

NewNatssChannel creates an NatssChannel with NatssChannelOptions.

func WithNatssChannelDeleted

func WithNatssChannelDeleted(nc *v1alpha1.NatssChannel)

func WithNatssChannelFinalizer

func WithNatssChannelFinalizer(nc *v1alpha1.NatssChannel)

func WithNatssInitChannelConditions

func WithNatssInitChannelConditions(nc *v1alpha1.NatssChannel)

func WithReady

func WithReady(nc *v1alpha1.NatssChannel)

WithReady marks a NatssChannel as being ready The dispatcher reconciler does not set the ready status, instead the controller reconciler does For testing, we need to be able to set the status to ready

Types

type Ctor

type Ctor func(context.Context, *Listers) 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) 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) GetEventsObjects

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

func (*Listers) GetKubeObjects

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

func (*Listers) GetMessagingObjects

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

func (*Listers) GetNatssChannelLister

func (l *Listers) GetNatssChannelLister() messaginglisters.NatssChannelLister

func (*Listers) GetServiceLister

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

type NatssChannelOption

type NatssChannelOption func(*v1alpha1.NatssChannel)

NatssChannelOption enables further configuration of a NatssChannel.

func Addressable

func Addressable() NatssChannelOption

func WithNatssChannelAddress

func WithNatssChannelAddress(a string) NatssChannelOption

func WithNatssChannelChannelServiceReady

func WithNatssChannelChannelServiceReady() NatssChannelOption

func WithNatssChannelChannelServicetNotReady

func WithNatssChannelChannelServicetNotReady(reason, message string) NatssChannelOption

func WithNatssChannelDeploymentNotReady

func WithNatssChannelDeploymentNotReady(reason, message string) NatssChannelOption

func WithNatssChannelDeploymentReady

func WithNatssChannelDeploymentReady() NatssChannelOption

func WithNatssChannelEndpointsNotReady

func WithNatssChannelEndpointsNotReady(reason, message string) NatssChannelOption

func WithNatssChannelEndpointsReady

func WithNatssChannelEndpointsReady() NatssChannelOption

func WithNatssChannelServiceNotReady

func WithNatssChannelServiceNotReady(reason, message string) NatssChannelOption

func WithNatssChannelServiceReady

func WithNatssChannelServiceReady() NatssChannelOption

func WithNatssChannelSubscribableStatus

func WithNatssChannelSubscribableStatus(ready corev1.ConditionStatus, message string) NatssChannelOption

func WithNatssChannelSubscribers

func WithNatssChannelSubscribers(t *testing.T, subscriberURI string) NatssChannelOption

func WithNotReady

func WithNotReady(reason, messageFormat string) NatssChannelOption