mq

Documentation

Index

• func BuildConsumer(consumers []Consumer)
• func InitNsq(rc *RootConfig)
• func SendMsg(topic, msg string) error
• type Consumer
• type MsgHandler
  • func (h MsgHandler) HandleMessage(message *nsq.Message) error
• type RootConfig
  • func NewConfig() *RootConfig

Functions

func BuildConsumer

func BuildConsumer(consumers []Consumer)

func InitNsq

func InitNsq(rc *RootConfig)

func SendMsg

func SendMsg(topic, msg string) error

Types

type Consumer

type Consumer struct {
	Topic       string
	Channel     string
	Concurrency int
	Handler     func(msg string) error
}

type MsgHandler

type MsgHandler struct {
	Handler func(msg string) error
}

func (MsgHandler) HandleMessage

func (h MsgHandler) HandleMessage(message *nsq.Message) error

type RootConfig

type RootConfig struct {
	Config nsqConfig `yaml:"nsq"`
}

func NewConfig

func NewConfig() *RootConfig