Versions in this module Expand all Collapse all v0 v0.7.1 Jul 2, 2019 v0.7.0 Jun 25, 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