testing

Documentation

Index

• func MakeFactory(ctor Ctor) Factory
• func NewKafkaChannel(name, namespace string, ncopt ...KafkaChannelOption) *v1alpha1.KafkaChannel
• func WithInitKafkaChannelConditions(nc *v1alpha1.KafkaChannel)
• func WithKafkaChannelReady(nc *v1alpha1.KafkaChannel)
• type Ctor
• type KafkaChannelOption
  • func WithKafkaChannelAddress(a string) KafkaChannelOption
  • func WithSubscriber(uid types.UID, uri string) KafkaChannelOption
  • func WithSubscriberReady(uid types.UID) 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) GetKafkaChannelLister() messaginglisters.KafkaChannelLister
  • func (l *Listers) GetKubeObjects() []runtime.Object
  • func (l *Listers) GetMessagingObjects() []runtime.Object
  • func (l *Listers) GetServiceLister() corev1listers.ServiceLister

Functions

func MakeFactory

func MakeFactory(ctor Ctor) 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 WithKafkaChannelReady

func WithKafkaChannelReady(nc *v1alpha1.KafkaChannel)

Types

type Ctor

type Ctor func(listers *Listers, kafkaClient versioned.Interface, eventRecorder record.EventRecorder) 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 WithSubscriber

func WithSubscriber(uid types.UID, uri string) KafkaChannelOption

func WithSubscriberReady

func WithSubscriberReady(uid types.UID) 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) 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