broker

Documentation

Index

• func Publish(ctx context.Context, in *Message) error
• func Subscribe(ctx context.Context, topic string, handler mBroker.Handler, ...)
• type Message
  • func NewMessage(topic string, payload interface{}) *Message
  • func (m *Message) SetOptions(options map[string]interface{}) *Message
  • func (m *Message) SetPayload(payload interface{}) *Message
  • func (m *Message) SetTimestamp(timestamp int64) *Message
  • func (m *Message) SetTopic(topic string) *Message
  • func (m *Message) SetUID(uid int64) *Message

Functions

func Publish

func Publish(ctx context.Context, in *Message) error

func Subscribe

func Subscribe(ctx context.Context, topic string, handler mBroker.Handler, opts ...mBroker.SubscribeOption)

Types

type Message

type Message struct {
	UID       int64                  `json:"uid"`       // 用户ID
	Topic     string                 `json:"topic"`     // 主题名称
	Options   map[string]interface{} `json:"options"`   // 额外参数
	Payload   interface{}            `json:"payload"`   // 自定义数据
	Timestamp int64                  `json:"timestamp"` // 秒时间戳
}

func NewMessage

func NewMessage(topic string, payload interface{}) *Message

func (*Message) SetOptions

func (m *Message) SetOptions(options map[string]interface{}) *Message

func (*Message) SetPayload

func (m *Message) SetPayload(payload interface{}) *Message

func (*Message) SetTimestamp

func (m *Message) SetTimestamp(timestamp int64) *Message

func (*Message) SetTopic

func (m *Message) SetTopic(topic string) *Message

func (*Message) SetUID

func (m *Message) SetUID(uid int64) *Message