mq

Documentation

Index

• Constants
• func Publish(topic string, msg *Message, delay ...time.Duration)
• func RegisterTopic(topic string, handler func(*Message))
• type IssueAssignedMessage
• type Message
• type TaskMemberAddedMessage

Constants

const (
	TopicTaskMemberAdded = "task_member_added"
	TopicIssueAssigned   = "issue_assigned"
)

Functions

func Publish

func Publish(topic string, msg *Message, delay ...time.Duration)

Publish publishes a message to a topic.

func RegisterTopic

func RegisterTopic(topic string, handler func(*Message))

RegisterTopic registers a topic and its handler.

Types

type IssueAssignedMessage

type IssueAssignedMessage struct {
	IssueId    uint64
	OperatorId uint64
	AssigneeId uint64
}

type Message

type Message struct {
	Topic string
	Data  interface{}
}

type TaskMemberAddedMessage

type TaskMemberAddedMessage struct {
	TaskId       uint64
	MemberIdList []uint64
}