Documentation
¶
Index ¶
- func MakeFactory(ctor Ctor) 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 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 (l *Listers) GetAllObjects() []runtime.Object
- func (l *Listers) GetDeploymentLister() appsv1listers.DeploymentLister
- func (l *Listers) GetEndpointsLister() corev1listers.EndpointsLister
- func (l *Listers) GetEventsObjects() []runtime.Object
- func (l *Listers) GetKafkaChannelLister() messaginglisters.KafkaChannelLister
- func (l *Listers) GetKubeObjects() []runtime.Object
- func (l *Listers) GetMessagingObjects() []runtime.Object
- func (l *Listers) GetServiceLister() corev1listers.ServiceLister
- func (l *Listers) GetSharedObjects() []runtime.Object
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 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(*Listers, reconciler.Options) 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 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 (*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) GetServiceLister ¶
func (l *Listers) GetServiceLister() corev1listers.ServiceLister
Click to show internal directories.
Click to hide internal directories.