controller

Documentation

Index

• func Find(list []string, item string) bool
• func NewController(ctx context.Context, cmw configmap.Watcher) *controller.Impl
• type ConsumerGroupHandler
• type ConsumerGroupWatcher
  • func NewConsumerGroupWatcher(ctx context.Context, ac kafka.AdminClient, pollDuration time.Duration) ConsumerGroupWatcher
• type Matcher
• type Reconciler
  • func (r *Reconciler) FinalizeKind(ctx context.Context, kc *v1beta1.KafkaChannel) pkgreconciler.Event
  • func (r *Reconciler) ReconcileKind(ctx context.Context, kc *v1beta1.KafkaChannel) pkgreconciler.Event
• type WatcherImpl
  • 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

Functions

func Find

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

func NewController

func NewController(
	ctx context.Context,
	cmw configmap.Watcher,
) *controller.Impl

NewController initializes the controller and is called by the generated code. Registers event handlers to enqueue events.

Types

type ConsumerGroupHandler

type ConsumerGroupHandler func()

type ConsumerGroupWatcher

type ConsumerGroupWatcher interface {
	// Start instructs the watcher to start polling for the consumer groups and
	// notify any observers on the event of any changes
	Start() error

	// Terminate instructs the watcher to stop polling and clear the watchers cache
	Terminate()

	// Watch registers callback on the event of any changes observed
	// on the consumer groups. watcherID is an arbitrary string the user provides
	// that will be used to identify his callbacks when provided to Forget(watcherID).
	//
	// To ensure this is event-triggered, level-driven,
	// we don't pass the updates to the callback, instead the observer is expected
	// to use List() to get the updated list of ConsumerGroups.
	Watch(watcherID string, callback ConsumerGroupHandler) error

	// Forget removes all callbacks that correspond to the watcherID
	Forget(watcherID string)

	// List returns all the cached consumer groups that match matcher.
	// It will return an empty slice if none matched or the cache is empty
	List(matcher Matcher) []string
}

func NewConsumerGroupWatcher

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

type Matcher

type Matcher func(string) bool

type Reconciler

type Reconciler struct {
	KubeClientSet kubernetes.Interface

	EventingClientSet eventingclientset.Interface
	// contains filtered or unexported fields
}

Reconciler reconciles Kafka Channels.

func (*Reconciler) FinalizeKind

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

func (*Reconciler) ReconcileKind

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

type WatcherImpl

type WatcherImpl struct {
	// contains filtered or unexported fields
}

func (*WatcherImpl) Forget

func (w *WatcherImpl) Forget(watcherID string)

func (*WatcherImpl) List

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

func (*WatcherImpl) Start

func (w *WatcherImpl) Start() error

func (*WatcherImpl) Terminate

func (w *WatcherImpl) Terminate()

func (*WatcherImpl) Watch

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

TODO explore returning a channel instead of a taking callback