message_queue

Documentation

Overview

Copyright 2019-2020 Axetroy. All rights reserved. MIT license.

Copyright 2019-2020 Axetroy. All rights reserved. MIT license.

Copyright 2019-2020 Axetroy. All rights reserved. MIT license.

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() ([]*nsq.Consumer, error)
• type Chanel
• type SendActivationEmailBody
• type SendNotifyBody
  • func (c *SendNotifyBody) ToByte() ([]byte, error)
• type Topic

Variables

var (
	TopicSendEmail   Topic       = "send_email"
	ChanelSendEmail  Chanel      = "send_email"
	TopicPushNotify  Topic       = "push_notify"
	ChanelPushNotify Chanel      = "push_notify"
	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() ([]*nsq.Consumer, error)

Types

type Chanel

type Chanel string

type SendActivationEmailBody

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

type SendNotifyBody

type SendNotifyBody struct {
	Event   notify.SendNotifyEvent `json:"event" valid:"required~请输入事件"`    // 事件名称
	Payload interface{}            `json:"payload" valid:"required~请输入数据体"` // 数据体
}

func (*SendNotifyBody) ToByte

func (c *SendNotifyBody) ToByte() ([]byte, error)

type Topic

type Topic string