controller

Dec 1, 2020

Changes in this version

+ func Find(list []string, item string) bool

+ type ConsumerGroupHandler func()

+ type ConsumerGroupWatcher interface

+ Forget func(watcherID string)

+ List func(matcher Matcher) []string

+ Start func() error

+ Terminate func()

+ Watch func(watcherID string, callback ConsumerGroupHandler) error

+ func NewConsumerGroupWatcher(ctx context.Context, ac kafka.AdminClient, pollDuration time.Duration) ConsumerGroupWatcher

+ type Matcher func(string) bool

+ type WatcherImpl struct

+ func (w *WatcherImpl) Forget(watcherID string)

+ func (w *WatcherImpl) List(matcher Matcher) []string

+ func (w *WatcherImpl) Start() error

+ func (w *WatcherImpl) Terminate()

+ func (w *WatcherImpl) Watch(watcherID string, cb ConsumerGroupHandler) error

Apr 14, 2020

Changes in this version

type Reconciler

+ EventingClientSet eventingclientset.Interface

+ KubeClientSet kubernetes.Interface

+ func (r *Reconciler) FinalizeKind(ctx context.Context, kc *v1alpha1.KafkaChannel) pkgreconciler.Event

+ func (r *Reconciler) ReconcileKind(ctx context.Context, kc *v1alpha1.KafkaChannel) pkgreconciler.Event

Aug 6, 2019

Changes in this version

+ const ReconcilerName

+ func NewController(opt reconciler.Options, kafkaConfig *utils.KafkaConfig, ...) *controller.Impl

+ type Reconciler struct

+ func (r *Reconciler) OnAdd(obj interface{})

+ func (r *Reconciler) OnDelete(obj interface{})

+ func (r *Reconciler) OnUpdate(old, new interface{})

+ func (r *Reconciler) Reconcile(ctx context.Context, key string) error