Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type Comet ¶
type Comet struct {
// contains filtered or unexported fields
}
Comet is a comet.
func (*Comet) Broadcast ¶
func (c *Comet) Broadcast(arg *comet.BroadcastReq) (err error)
Broadcast broadcast a message.
func (*Comet) BroadcastRoom ¶
func (c *Comet) BroadcastRoom(arg *comet.BroadcastRoomReq) (err error)
BroadcastRoom broadcast a room message.
type NsqHandler ¶
type NsqHandler struct {
// contains filtered or unexported fields
}
NsqHandler 结构
func NewNsqConsumer ¶
func NewNsqConsumer(cnsq *conf.Nsq, job *Job) (*NsqHandler, error)
NewNsqConsumer 创建 nsq consumer
func (*NsqHandler) HandleMessage ¶
func (nh *NsqHandler) HandleMessage(msg *nsq.Message) error
HandleMessage 处理消息
Click to show internal directories.
Click to hide internal directories.