message_queue

Documentation

Overview

For generate mocks on sarama interfaces

Index

• func NewKafkaClient(cfg KafkaConfig) (sarama.Client, error)
• type KafkaConfig
• type SaramaAsyncProducer

Functions

func NewKafkaClient

func NewKafkaClient(cfg KafkaConfig) (sarama.Client, error)

NewKafkaClient return new sarama.Client interface

Types

type KafkaConfig

type KafkaConfig struct {
	Brokers []string `mapstructure:"brokers"`
}

type SaramaAsyncProducer

type SaramaAsyncProducer interface {
	sarama.AsyncProducer
}