Versions in this module Expand all Collapse all v1 v1.2.21 Jul 26, 2025 Changes in this version + var DefaultConcurrentHandlers = 1 + func LogDebug(args ...interface{}) + func LogDebugf(format string, args ...interface{}) + func LogError(args ...interface{}) + func LogErrorf(format string, args ...interface{}) + func LogFatal(args ...interface{}) + func LogFatalf(format string, args ...interface{}) + func LogInfo(args ...interface{}) + func LogInfof(format string, args ...interface{}) + func LogWarn(args ...interface{}) + func LogWarnf(format string, args ...interface{}) + func NewBroker(opts ...broker.Option) broker.Broker + func WithAsyncPublish(doneChan chan *nsq.ProducerTransaction) broker.PublishOption + func WithConcurrentHandlers(n int) broker.SubscribeOption + func WithConsumerOptions(consumerOpts []string) broker.Option + func WithDeferredPublish(delay time.Duration) broker.PublishOption + func WithLookupdAddress(addrs []string) broker.Option + func WithMaxInFlight(n int) broker.SubscribeOption
Go to main page