Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PromotionKafkaManager ¶
type PromotionKafkaManager struct { workers.BaseWorker // contains filtered or unexported fields }
func NewPromotionKafkaManager ¶
func NewPromotionKafkaManager(reconciler workers.Reconciler, kafkaService services.KafkaService, kafkaConfig *config.KafkaConfig, quotaServiceFactory services.QuotaServiceFactory) *PromotionKafkaManager
func (*PromotionKafkaManager) Reconcile ¶
func (k *PromotionKafkaManager) Reconcile() []error
func (*PromotionKafkaManager) Start ¶
func (k *PromotionKafkaManager) Start()
Start initializes the kafka manager to reconcile kafka requests to be promoted.
func (*PromotionKafkaManager) Stop ¶
func (k *PromotionKafkaManager) Stop()
Stop causes the process for reconciling kafka requests to be promoted to stop.
Click to show internal directories.
Click to hide internal directories.