Documentation
¶
Index ¶
- func LatestMsg(m *model.Message, uid int64) *base.LatestMsg
- func LatestMsgs(ml []*model.Message, uid int64) []*base.LatestMsg
- func Message(m *model.Message) *base.Message
- func Messages(m []*model.Message) []*base.Message
- func SubscribeRoutine(subscriber *Subscriber, dao *dao.Message)
- type Publisher
- type Subscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LatestMsgs ¶
LatestMsgs batch coverts Message list model to LatestMsg list.
func SubscribeRoutine ¶
func SubscribeRoutine(subscriber *Subscriber, dao *dao.Message)
Types ¶
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
Publisher implements an amqp publisher.
func NewPublisher ¶
func NewPublisher(conn *amqp.Connection, exchange string) (*Publisher, error)
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
Subscriber implements an amqp subscriber.
func NewSubscriber ¶
func NewSubscriber(conn *amqp.Connection, exchange string) (*Subscriber, error)
NewSubscriber creates an amqp subscriber.
func (*Subscriber) Subscribe ¶
func (s *Subscriber) Subscribe(c context.Context) (chan *chat.DouyinMessageActionRequest, func(), error)
Subscribe subscribes and returns a channel with CarEntity data.
func (*Subscriber) SubscribeRaw ¶
SubscribeRaw subscribes and returns a channel with raw amqp delivery.
Source Files
Click to show internal directories.
Click to hide internal directories.