testing

Documentation

Index

• func MakeFactory(ctor Ctor) Factory
• func NewNatssChannel(name, namespace string, ncopt ...NatssChannelOption) *v1alpha1.NatssChannel
• func WithNatssChannelDeleted(nc *v1alpha1.NatssChannel)
• func WithNatssInitChannelConditions(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) 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
  • func (l *Listers) GetSharedObjects() []runtime.Object
• type 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 WithNatssChannelServiceReady() NatssChannelOption
  • func WithNatssChannelServicetNotReady(reason, message 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 WithNatssInitChannelConditions

func WithNatssInitChannelConditions(nc *v1alpha1.NatssChannel)

Types

type Ctor

type Ctor func(*Listers, reconciler.Options) 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) 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

func (*Listers) GetSharedObjects

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

type NatssChannelOption

type NatssChannelOption func(*v1alpha1.NatssChannel)

NatssChannelOption enables further configuration of a NatssChannel.

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 WithNatssChannelServiceReady

func WithNatssChannelServiceReady() NatssChannelOption

func WithNatssChannelServicetNotReady

func WithNatssChannelServicetNotReady(reason, message string) NatssChannelOption