trigger

type FlagsHolder struct {
	Flags     feature.Flags
	FlagsLock sync.RWMutex
}

type NamespacedReconciler struct {
	*base.Reconciler
	*FlagsHolder

	BrokerLister         eventinglisters.BrokerLister
	ConfigMapLister      corelisters.ConfigMapLister
	ServiceAccountLister corelisters.ServiceAccountLister
	EventingClient       eventingclientset.Interface
	Resolver             *resolver.URIResolver

	Env *config.Env

	GetKafkaClusterAdmin clientpool.GetKafkaClusterAdminFunc
	GetKafkaClient       clientpool.GetKafkaClientFunc
	InitOffsetsFunc      kafka.InitOffsetsFunc
	KafkaFeatureFlags    *apisconfig.KafkaFeatureFlags
}

type Reconciler struct {
	*base.Reconciler
	*FlagsHolder

	BrokerLister         eventinglisters.BrokerLister
	ConfigMapLister      corelisters.ConfigMapLister
	ServiceAccountLister corelisters.ServiceAccountLister
	EventingClient       eventingclientset.Interface
	Resolver             *resolver.URIResolver

	Env *config.Env

	BrokerClass string

	DataPlaneConfigMapLabeler base.ConfigMapOption

	KafkaFeatureFlags *apisconfig.KafkaFeatureFlags

	// GetKafkaClusterAdmin creates new sarama ClusterAdmin. It's convenient to add this as Reconciler field so that we can
	// mock the function used during the reconciliation loop.
	GetKafkaClusterAdmin clientpool.GetKafkaClusterAdminFunc
	// GetKafkaClient creates new sarama Client. It's convenient to add this as Reconciler field so that we can
	// mock the function used during the reconciliation loop.
	GetKafkaClient clientpool.GetKafkaClientFunc
	// InitOffsetsFunc initialize offsets for a provided set of topics and a provided consumer group id.
	// It's convenient to add this as Reconciler field so that we can mock the function used during the
	// reconciliation loop.
	InitOffsetsFunc kafka.InitOffsetsFunc
}