Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NsqPublisher ¶
type NsqPublisher struct { Config *nsq.Config Producer *nsq.Producer }
func (*NsqPublisher) Emit ¶
func (pub *NsqPublisher) Emit(doormanId bson.ObjectId, doorman shared.AsDoormanUpdatePayloader) error
func (*NsqPublisher) Init ¶
func (pub *NsqPublisher) Init() error
func (*NsqPublisher) InitConfig ¶
func (pub *NsqPublisher) InitConfig()
func (*NsqPublisher) Stop ¶
func (pub *NsqPublisher) Stop() error
Click to show internal directories.
Click to hide internal directories.