//
pkg.gl
Category
github.com/go-baa/common
modules
nsq
package
0.1.0
Repository:
https://github.com/go-baa/common.git
Documentation:
pkg.go.dev
Overview
Versions
1
Dependencies
17
Dependents
0
Files
339 SLOC
#
Functions
DefaultConfig
DefaultConfig 默认配置.
NewConsumer
NewConsumer creates a new instance of Consumer.
NewProducer
NewProducer creates a new instance of Producer.
#
Constants
DefaultMaxInFlight
DefaultMaxInFlight 默认MaxInFlight配置,根据nsqd服务数可以动态调整.
LookupdPollInterval
LookupdPollInterval ...
#
Structs
Consumer
Consumer ...
Handler
Handler consumer handler.
Producer
Producer nsq producer manager.