notify

Documentation

Index

• Constants
• func InitPublish(hosts []string)
• func Processor(ctx context.Context)
• type Message
  • func (m Message) Publish(ctx context.Context) (string, error)

Constants

const ConsumerGroup = "notify-consumer"

const Topic string = "notify"

Functions

func InitPublish

func InitPublish(hosts []string)

func Processor

func Processor(ctx context.Context)

Processor 消息处理器

Types

type Message

type Message struct {
	User string `json:"user"`
}

func (Message) Publish

func (m Message) Publish(ctx context.Context) (string, error)