Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var UUID = uuid.New()
Functions ¶
This section is empty.
Types ¶
type NSQMessage ¶
type NSQMessage struct {
*nsq.Message
}
func (*NSQMessage) Body ¶
func (m *NSQMessage) Body() []byte
func (*NSQMessage) Timestamp ¶
func (m *NSQMessage) Timestamp() int64
type NSQSubscriber ¶
type NSQSubscriber struct {
NSQLookupURL string
}
func (*NSQSubscriber) Subscribe ¶
func (sub *NSQSubscriber) Subscribe(doormanId string, update shared.UpdateHandlerFunc) error
Source Files
Click to show internal directories.
Click to hide internal directories.