Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Consumer ¶
type Consumer struct { // wait group is to make sure all consumers are closed during // a shutdown. sync.WaitGroup // mutex for updating consumer maxInFlight sync.Mutex // contains filtered or unexported fields }
type Option ¶
type Option struct { NSQdAddrs []string // connects via TCP only LookupdAddrs []string // connects via HTTP only // if nil then the default nsq logger is used Logger *log.Logger // default is nsq.LogLevelInfo. Only set if a // custom logger is provided. LogLvl gonsq.LogLevel }
Option is used for instantiating an NSQ Consumer or Producer. The Producer will ignore the Topic value.
Click to show internal directories.
Click to hide internal directories.