Documentation ¶ Index ¶ func InitializeConsumer(nsqconfig *NsqConfig, topic, channel string, back func(m *nsq.Message) error) type Nsq func InitializePublisher(nsqconfig *NsqConfig) *Nsq func (n *Nsq) Send(topic string, msg []byte) error func (n *Nsq) SendSync(topic string, msg []byte) error type NsqConfig Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func InitializeConsumer ¶ func InitializeConsumer(nsqconfig *NsqConfig, topic, channel string, back func(m *nsq.Message) error) Types ¶ type Nsq ¶ added in v0.0.21 type Nsq struct { Producer *nsq.Producer } func InitializePublisher ¶ func InitializePublisher(nsqconfig *NsqConfig) *Nsq func (*Nsq) Send ¶ added in v0.0.21 func (n *Nsq) Send(topic string, msg []byte) error func (*Nsq) SendSync ¶ added in v0.0.27 func (n *Nsq) SendSync(topic string, msg []byte) error type NsqConfig ¶ added in v0.0.4 type NsqConfig struct { Lookups []string `yaml:"nsqlookups"` NSQDs []string `yaml:"nsqds"` NSQD string `yaml:"nsqd"` } NsqConfig - Represents a Configuration Source Files ¶ View all Source files nsqManager.go Click to show internal directories. Click to hide internal directories.