testing

package
v0.30.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 17, 2022 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeFactory 

func MakeFactory(ctor Ctor) Factory

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

func NewNatsJetStreamChannel added in v0.30.4 

func NewNatsJetStreamChannel(name, namespace string, ncopt ...NatsJetStreamChannelOption) *v1alpha1.NatsJetStreamChannel

NewNatsJetStreamChannel creates an NatsJetStreamChannel with NatsJetStreamChannelOptions.

func NewNatssChannel 

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

NewNatssChannel creates an NatssChannel with NatssChannelOptions.

func WithJetStreamReady added in v0.30.4 

func WithJetStreamReady(nc *v1alpha1.NatsJetStreamChannel)

WithReady marks a NatsJetStreamChannel 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

func WithNatsJetStreamChannelDeleted added in v0.30.4 

func WithNatsJetStreamChannelDeleted(nc *v1alpha1.NatsJetStreamChannel)

func WithNatsJetStreamChannelFinalizer added in v0.30.4 

func WithNatsJetStreamChannelFinalizer(nc *v1alpha1.NatsJetStreamChannel)

func WithNatsJetStreamInitChannelConditions added in v0.30.4 

func WithNatsJetStreamInitChannelConditions(nc *v1alpha1.NatsJetStreamChannel)

func WithNatssChannelDeleted 

func WithNatssChannelDeleted(nc *v1beta1.NatssChannel)

func WithNatssChannelFinalizer 

func WithNatssChannelFinalizer(nc *v1beta1.NatssChannel)

func WithNatssInitChannelConditions 

func WithNatssInitChannelConditions(nc *v1beta1.NatssChannel)

func WithReady 

func WithReady(nc *v1beta1.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) GetNatsJetstreamChannelLister added in v0.30.4 

func (l *Listers) GetNatsJetstreamChannelLister() jetstreamlisters.NatsJetStreamChannelLister

func (*Listers) GetNatssChannelLister 

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

func (*Listers) GetNatssObjects added in v0.19.0 

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

func (*Listers) GetRoleBindingLister added in v0.30.4 

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

func (*Listers) GetServiceAccountLister added in v0.30.4 

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

func (*Listers) GetServiceLister 

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

type NatsJetStreamChannelOption added in v0.30.4 

type NatsJetStreamChannelOption func(*v1alpha1.NatsJetStreamChannel)

NatsJetStreamChannelOption enables further configuration of a NatsJetStreamChannel.

func JetStreamAddressable added in v0.30.4 

func JetStreamAddressable() NatsJetStreamChannelOption

func WithJetStreamNotReady added in v0.30.4 

func WithJetStreamNotReady(reason, messageFormat string) NatsJetStreamChannelOption

func WithNatsJetStreamChannelAddress added in v0.30.4 

func WithNatsJetStreamChannelAddress(a string) NatsJetStreamChannelOption

func WithNatsJetStreamChannelChannelServiceReady added in v0.30.4 

func WithNatsJetStreamChannelChannelServiceReady() NatsJetStreamChannelOption

func WithNatsJetStreamChannelChannelServicetNotReady added in v0.30.4 

func WithNatsJetStreamChannelChannelServicetNotReady(reason, message string) NatsJetStreamChannelOption

func WithNatsJetStreamChannelDeploymentNotReady added in v0.30.4 

func WithNatsJetStreamChannelDeploymentNotReady(reason, message string) NatsJetStreamChannelOption

func WithNatsJetStreamChannelDeploymentReady added in v0.30.4 

func WithNatsJetStreamChannelDeploymentReady() NatsJetStreamChannelOption

func WithNatsJetStreamChannelDispatcherReady added in v0.30.4 

func WithNatsJetStreamChannelDispatcherReady() NatsJetStreamChannelOption

func WithNatsJetStreamChannelEndpointsNotReady added in v0.30.4 

func WithNatsJetStreamChannelEndpointsNotReady(reason, message string) NatsJetStreamChannelOption

func WithNatsJetStreamChannelEndpointsReady added in v0.30.4 

func WithNatsJetStreamChannelEndpointsReady() NatsJetStreamChannelOption

func WithNatsJetStreamChannelReadySubscriber added in v0.30.4 

func WithNatsJetStreamChannelReadySubscriber(uid string) NatsJetStreamChannelOption

func WithNatsJetStreamChannelReadySubscriberAndGeneration added in v0.30.4 

func WithNatsJetStreamChannelReadySubscriberAndGeneration(uid string, observedGeneration int64) NatsJetStreamChannelOption

func WithNatsJetStreamChannelServiceNotReady added in v0.30.4 

func WithNatsJetStreamChannelServiceNotReady(reason, message string) NatsJetStreamChannelOption

func WithNatsJetStreamChannelServiceReady added in v0.30.4 

func WithNatsJetStreamChannelServiceReady() NatsJetStreamChannelOption

func WithNatsJetStreamChannelStreamNotReady added in v0.30.4 

func WithNatsJetStreamChannelStreamNotReady(reason, message string) NatsJetStreamChannelOption

func WithNatsJetStreamChannelStreamReady added in v0.30.4 

func WithNatsJetStreamChannelStreamReady() NatsJetStreamChannelOption

func WithNatsJetStreamChannelSubscribableStatus added in v0.30.4 

func WithNatsJetStreamChannelSubscribableStatus(ready corev1.ConditionStatus, message string) NatsJetStreamChannelOption

func WithNatsJetStreamChannelSubscriber added in v0.30.4 

func WithNatsJetStreamChannelSubscriber(t *testing.T, subscriberURI string) NatsJetStreamChannelOption

func WithNatsJetStreamChannelSubscribers added in v0.30.4 

func WithNatsJetStreamChannelSubscribers(subscribers []duckv1.SubscriberSpec) NatsJetStreamChannelOption

type NatssChannelOption 

type NatssChannelOption func(*v1beta1.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 WithNatssChannelReadySubscriber added in v0.19.1 

func WithNatssChannelReadySubscriber(uid string) NatssChannelOption

func WithNatssChannelReadySubscriberAndGeneration added in v0.19.1 

func WithNatssChannelReadySubscriberAndGeneration(uid string, observedGeneration int64) 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 WithNatssChannelSubscriber added in v0.19.1 

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

func WithNatssChannelSubscribers 

func WithNatssChannelSubscribers(subscribers []duckv1.SubscriberSpec) NatssChannelOption

func WithNotReady 

func WithNotReady(reason, messageFormat string) NatssChannelOption

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.