producer

Documentation

Index

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

Types

type Producer

type Producer interface {
	Start()
	Close()
}

func NewKafkaProducer

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