Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeMessages ¶
func MakeMessages(topicName string, messageCount, messageValueLength int) ([]*sarama.ProducerMessage, error)
func NewWorkerPool ¶
func NewWorkerPool(log *logrus.Entry, workerCount int, producer sarama.SyncProducer) (*sync.WaitGroup, chan MessagesAndBatchID)
Types ¶
type MessagesAndBatchID ¶
type MessagesAndBatchID struct { Messages []*sarama.ProducerMessage ID int }
Click to show internal directories.
Click to hide internal directories.