jobs

Documentation

Index

• func Consumer(topic string) (kafkaConsumer kafka.Consumer)
• func Dispatch(data map[string]interface{}, jobFunc func(topic string))
• func SendSms(topic string)

Functions

func Consumer

func Consumer(topic string) (kafkaConsumer kafka.Consumer)

Consumer 调用消费者执行消费 @param topic string 消费主题 @return kafkaConsumer 返回kafka消费者结构体

func Dispatch

func Dispatch(data map[string]interface{}, jobFunc func(topic string))

Dispatch 消息队列 @param data 待消费数据 @param jobFunc 消费者函数 @return 返回一个闭包

func SendSms

func SendSms(topic string)

SendSms 发送短信队列 @param string topic 消息主题 @return void