consumer

type Consumer ¶

type Consumer interface {
	Start()
	Stop()
}

Consumer читает из базы данных события в n потоков и отправляет их в канал

func NewDbConsumer(
	n uint64,
	batchSize uint64,
	consumerTimeout time.Duration,
	repo repo.EventRepo,
	events chan<- model.PackageEvent) Consumer