testing

package
v0.14.2 Latest Latest
Warning

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

Go to latest
Published: Apr 30, 2020 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeFactory

func MakeFactory(ctor Ctor, logger *zap.Logger) Factory

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

func NewKafkaChannel

func NewKafkaChannel(name, namespace string, ncopt ...KafkaChannelOption) *v1alpha1.KafkaChannel

NewKafkaChannel creates an KafkaChannel with KafkaChannelOptions.

func WithInitKafkaChannelConditions

func WithInitKafkaChannelConditions(nc *v1alpha1.KafkaChannel)

func WithKafkaChannelDeleted

func WithKafkaChannelDeleted(nc *v1alpha1.KafkaChannel)

Types

type Ctor

Ctor functions create a k8s controller with given params.

type KafkaChannelOption

type KafkaChannelOption func(*v1alpha1.KafkaChannel)

KafkaChannelOption enables further configuration of a KafkaChannel.

func WithKafkaChannelAddress

func WithKafkaChannelAddress(a string) KafkaChannelOption

func WithKafkaChannelChannelServiceReady

func WithKafkaChannelChannelServiceReady() KafkaChannelOption

func WithKafkaChannelChannelServicetNotReady

func WithKafkaChannelChannelServicetNotReady(reason, message string) KafkaChannelOption

func WithKafkaChannelConfigReady added in v0.13.0

func WithKafkaChannelConfigReady() KafkaChannelOption

func WithKafkaChannelDeploymentNotReady

func WithKafkaChannelDeploymentNotReady(reason, message string) KafkaChannelOption

func WithKafkaChannelDeploymentReady

func WithKafkaChannelDeploymentReady() KafkaChannelOption

func WithKafkaChannelEndpointsNotReady

func WithKafkaChannelEndpointsNotReady(reason, message string) KafkaChannelOption

func WithKafkaChannelEndpointsReady

func WithKafkaChannelEndpointsReady() KafkaChannelOption

func WithKafkaChannelServiceReady

func WithKafkaChannelServiceReady() KafkaChannelOption

func WithKafkaChannelServicetNotReady

func WithKafkaChannelServicetNotReady(reason, message string) KafkaChannelOption

func WithKafkaChannelTopicReady

func WithKafkaChannelTopicReady() KafkaChannelOption

func WithKafkaFinalizer

func WithKafkaFinalizer(finalizerName string) KafkaChannelOption

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 added in v0.11.0

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

func (*Listers) GetEventsObjects

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

func (*Listers) GetKafkaChannelLister

func (l *Listers) GetKafkaChannelLister() messaginglisters.KafkaChannelLister

func (*Listers) GetKubeObjects

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

func (*Listers) GetMessagingObjects

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

func (*Listers) GetServiceLister

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL