queue

Documentation

Index

• func Init(ctx context.Context, config Config) (interface{}, error)
• func InitKafkaConsumer(brokerList []string) (*sarama.Consumer, error)
• func InitKafkaConsumerGroup(brokerList []string, groupId string) (*sarama.ConsumerGroup, error)
• func InitKafkaProducer(brokerList []string) (*sarama.AsyncProducer, error)
• type Config

Functions

func Init

func Init(ctx context.Context, config Config) (interface{}, error)

func InitKafkaConsumer

func InitKafkaConsumer(brokerList []string) (*sarama.Consumer, error)

func InitKafkaConsumerGroup

func InitKafkaConsumerGroup(brokerList []string, groupId string) (*sarama.ConsumerGroup, error)

func InitKafkaProducer

func InitKafkaProducer(brokerList []string) (*sarama.AsyncProducer, error)

Types

type Config

type Config struct {
	Driver  string
	Host    string
	Kind    string
	GroupId string
}