producer

Documentation

Index

• type Config
• type Producer
  • func NewKafkaProducer(cfg *Config, eventSender sender.EventSender, cleaner repo.EventCleaner, ...) Producer

Types

type Config

type Config struct {
	MaxProducers uint64        `yaml:"maxProducers"`
	BatchSize    uint64        `yaml:"batchSize"`
	Timeout      time.Duration `yaml:"timeout"`
}

Config object to store producer configurations into.

type Producer

type Producer interface {
	Start(ctx context.Context)
	Close()
}

Producer is the interface not to be used directly.

See Retranslator.

func NewKafkaProducer

func NewKafkaProducer(
	cfg *Config,
	eventSender sender.EventSender,
	cleaner repo.EventCleaner,
	updater repo.EventUpdater,
	events <-chan model.BasketEvent,
	workerPool *workerpool.WorkerPool,
	logger *zap.Logger,
) Producer

NewKafkaProducer returns a new Kafka producer.