api

Documentation

Index

• type Message
  • func NewMessage(m *nsq.Message, c []byte) *Message
  • func (m *Message) Body() []byte
  • func (m *Message) OnError(err error)
  • func (m *Message) OnSuccess()
• type OutMessage
• type OutUser

Types

type Message

type Message struct {
	*nsq.Message
	// logger  *log.Logger
	Content []byte
}

func NewMessage

func NewMessage(m *nsq.Message, c []byte) *Message

func (*Message) Body

func (m *Message) Body() []byte

func (*Message) OnError

func (m *Message) OnError(err error)

func (*Message) OnSuccess

func (m *Message) OnSuccess()

type OutMessage

type OutMessage struct {
	// From *OutUser `json:"from"`
	ID           string `json:"id"`
	FromID       uint   `json:"from_id"`
	FromName     string `json:"from_name"`
	FromImageURL string `json:"from_image_url"`
	Dst          uint   `json:"dst"`
	DstType      string `json:"dst_type"` // "group" | "personal"
	Content      string `json:"content"`
	Timestamp    int64  `json:"timestamp"`
}

type OutUser

type OutUser struct {
	model.Base
	Username    string `json:"username"`
	Displayname string `json:"displayname"`
}