testing

Documentation

Index

• func MakeFactory(ctor Ctor, logger *zap.Logger) Factory
• func NewKafkaChannel(name, namespace string, ncopt ...KafkaChannelOption) *v1alpha1.KafkaChannel
• func WithInitKafkaChannelConditions(nc *v1alpha1.KafkaChannel)
• func WithKafkaChannelDeleted(nc *v1alpha1.KafkaChannel)
• type Ctor
• type KafkaChannelOption
  • func WithKafkaChannelAddress(a string) KafkaChannelOption
  • func WithKafkaChannelChannelServiceReady() KafkaChannelOption
  • func WithKafkaChannelChannelServicetNotReady(reason, message string) KafkaChannelOption
  • func WithKafkaChannelConfigReady() KafkaChannelOption
  • func WithKafkaChannelDeploymentNotReady(reason, message string) KafkaChannelOption
  • func WithKafkaChannelDeploymentReady() KafkaChannelOption
  • func WithKafkaChannelEndpointsNotReady(reason, message string) KafkaChannelOption
  • func WithKafkaChannelEndpointsReady() KafkaChannelOption
  • func WithKafkaChannelServiceReady() KafkaChannelOption
  • func WithKafkaChannelServicetNotReady(reason, message string) KafkaChannelOption
  • func WithKafkaChannelTopicReady() KafkaChannelOption
  • func WithKafkaFinalizer(finalizerName string) KafkaChannelOption
• 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) GetKafkaChannelLister() messaginglisters.KafkaChannelLister
  • func (l *Listers) GetKubeObjects() []runtime.Object
  • func (l *Listers) GetLegacyObjects() []runtime.Object
  • func (l *Listers) GetMessagingObjects() []runtime.Object
  • func (l *Listers) GetServiceLister() corev1listers.ServiceLister

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

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

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

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

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

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

func (*Listers) GetMessagingObjects

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

func (*Listers) GetServiceLister

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