Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NSQConsumer ¶
type NSQConsumer struct {
// contains filtered or unexported fields
}
func NewNSQConsumer ¶
func NewNSQConsumer(addr string, topic string, channel string) (*NSQConsumer, error)
func (*NSQConsumer) Close ¶
func (C *NSQConsumer) Close()
type NSQConsumerHandler ¶
type NSQConsumerHandler struct {
// contains filtered or unexported fields
}
func (*NSQConsumerHandler) HandleMessage ¶
func (Q *NSQConsumerHandler) HandleMessage(message *Q.Message) error
type NSQProducer ¶
type NSQProducer struct {
// contains filtered or unexported fields
}
func NewNSQProducer ¶
func NewNSQProducer(addr string, topic string) (*NSQProducer, error)
func (*NSQProducer) Close ¶
func (Q *NSQProducer) Close()
func (*NSQProducer) Send ¶
func (Q *NSQProducer) Send(name string, data interface{}) error
Source Files
Click to show internal directories.
Click to hide internal directories.