testing

Documentation

Index

• func MakeFactory(ctor Ctor, logger *zap.Logger) Factory
• func NewCamelSource(name, namespace string, generation int64, ncopt ...CamelSourceOption) *v1alpha1.CamelSource
• func NewIntegration(name, namespace string, src *v1alpha1.CamelSource, ...) *v1.Integration
• func WithCamelSourceDeleted(nc *v1alpha1.CamelSource)
• func WithInitCamelSource(nc *v1alpha1.CamelSource)
• type CamelSourceOption
  • func WithCamelSourceDeployed() CamelSourceOption
  • func WithCamelSourceDeploying() CamelSourceOption
  • func WithCamelSourceIntegrationUpdated() CamelSourceOption
  • func WithCamelSourceSink(uri string) CamelSourceOption
  • func WithCamelSourceSinkNotFound() CamelSourceOption
  • func WithCamelSourceSpec(spec v1alpha1.CamelSourceSpec) CamelSourceOption
• type CamelkIntegrationOption
  • func WithIntegrationStatus(status v1.IntegrationStatus) CamelkIntegrationOption
• type Ctor
• type Listers
  • func NewListers(objs []runtime.Object) Listers
  • func (l *Listers) GetAddressableObjects() []runtime.Object
  • func (l *Listers) GetAllObjects() []runtime.Object
  • func (l *Listers) GetCamelSourcesLister() sourceslisters.CamelSourceLister
  • func (l *Listers) GetCamelkIntegrationLister() camellisters.IntegrationLister
  • func (l *Listers) GetCamelkObjects() []runtime.Object
  • func (l *Listers) GetSourceObjects() []runtime.Object

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 NewCamelSource

func NewCamelSource(name, namespace string, generation int64, ncopt ...CamelSourceOption) *v1alpha1.CamelSource

NewCamelSource creates an CamelSource with CamelSourceOptions.

func NewIntegration

func NewIntegration(name, namespace string, src *v1alpha1.CamelSource, ncopt ...CamelkIntegrationOption) *v1.Integration

NewIntegration creates an CamelSource with CamelkIntegrationOption.

func WithCamelSourceDeleted

func WithCamelSourceDeleted(nc *v1alpha1.CamelSource)

func WithInitCamelSource

func WithInitCamelSource(nc *v1alpha1.CamelSource)

Types

type CamelSourceOption

type CamelSourceOption func(*v1alpha1.CamelSource)

CamelSourceOption enables further configuration of a CamelSource.

func WithCamelSourceDeployed

func WithCamelSourceDeployed() CamelSourceOption

func WithCamelSourceDeploying

func WithCamelSourceDeploying() CamelSourceOption

func WithCamelSourceIntegrationUpdated

func WithCamelSourceIntegrationUpdated() CamelSourceOption

func WithCamelSourceSink

func WithCamelSourceSink(uri string) CamelSourceOption

func WithCamelSourceSinkNotFound

func WithCamelSourceSinkNotFound() CamelSourceOption

func WithCamelSourceSpec

func WithCamelSourceSpec(spec v1alpha1.CamelSourceSpec) CamelSourceOption

type CamelkIntegrationOption

type CamelkIntegrationOption func(*v1.Integration)

CamelkIntegrationOption enables further configuration of a Integration.

func WithIntegrationStatus

func WithIntegrationStatus(status v1.IntegrationStatus) CamelkIntegrationOption

type Ctor

type Ctor func(context.Context, *Listers, configmap.Watcher) 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) GetAddressableObjects

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

func (*Listers) GetAllObjects

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

func (*Listers) GetCamelSourcesLister

func (l *Listers) GetCamelSourcesLister() sourceslisters.CamelSourceLister

func (*Listers) GetCamelkIntegrationLister

func (l *Listers) GetCamelkIntegrationLister() camellisters.IntegrationLister

func (*Listers) GetCamelkObjects

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

func (*Listers) GetSourceObjects

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