Versions in this module Expand all Collapse all v0 v0.8.2 Aug 15, 2019 v0.8.1 Aug 8, 2019 v0.8.0 Aug 6, 2019 Changes in this version + const ReconcilerName + func NewController(opt reconciler.Options, kafkaDispatcher *dispatcher.KafkaDispatcher, ...) *controller.Impl + type Reconciler struct + func (r *Reconciler) Reconcile(ctx context.Context, key string) error