message_queue

package

v0.1.1 Latest Latest Go to latest Published: Sep 27, 2019 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/axetroy/go-server

Links

Open Source Insights

Documentation ¶

Overview ¶

Index ¶

Variables
func CreateConsumer(topic Topic, channel Chanel, handler nsq.Handler) (c *nsq.Consumer, err error)
func Publish(topic Topic, message []byte) (err error)
func RunMessageQueueConsumer()
type Chanel
type SendActivationEmailBody
type Topic

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	TopicSendEmail  Topic       = "send_email"
	ChanelSendEmail Chanel      = "send_email"
	Address         string      // 消息队列地址
	Config          *nsq.Config // 消息队列的配置
)

Functions ¶

func CreateConsumer ¶

func CreateConsumer(topic Topic, channel Chanel, handler nsq.Handler) (c *nsq.Consumer, err error)

创建消费者

func Publish ¶

func Publish(topic Topic, message []byte) (err error)

发布消息

func RunMessageQueueConsumer ¶

func RunMessageQueueConsumer()

Types ¶

type Chanel ¶

type Chanel string

type SendActivationEmailBody ¶

type SendActivationEmailBody struct {
	Email string `json:"email"` // 要发送的邮箱
	Code  string `json:"code"`  // 发送的激活码
}

type Topic ¶

type Topic string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL