producer

Documentation

Overview

Package producer provides kafka producer

Index

• type Producer
  • func NewKafkaProducer(n uint64, sender sender.EventSender, events <-chan model.PackageEvent, ...) Producer

Types

type Producer

type Producer interface {
	Start()
	Stop()
}

Producer читает из канала событий и отправляет в кафку, в n потоков

func NewKafkaProducer

func NewKafkaProducer(
	n uint64,
	sender sender.EventSender,
	events <-chan model.PackageEvent,
	repo repo.EventRepo,
	workerPool *workerpool.WorkerPool,
) Producer

NewKafkaProducer конструктор