Documentation
¶
Overview ¶
Package nsq provides an NSQ broker
Index ¶
- Variables
- func NewBroker(opts ...broker.Option) broker.Broker
- func WithAsyncPublish(doneChan chan *nsq.ProducerTransaction) broker.PublishOption
- func WithConcurrentHandlers(n int) broker.SubscribeOption
- func WithConsumerOpts(consumerOpts []string) broker.Option
- func WithDeferredPublish(delay time.Duration) broker.PublishOption
- func WithLookupdAddrs(addrs []string) broker.Option
- func WithMaxInFlight(n int) broker.SubscribeOption
Constants ¶
This section is empty.
Variables ¶
View Source
var (
DefaultConcurrentHandlers = 1
)
Functions ¶
func WithAsyncPublish ¶ added in v0.12.0
func WithAsyncPublish(doneChan chan *nsq.ProducerTransaction) broker.PublishOption
func WithConcurrentHandlers ¶ added in v0.12.0
func WithConcurrentHandlers(n int) broker.SubscribeOption
func WithConsumerOpts ¶ added in v0.12.0
func WithDeferredPublish ¶ added in v0.12.0
func WithDeferredPublish(delay time.Duration) broker.PublishOption
func WithLookupdAddrs ¶ added in v0.12.0
func WithMaxInFlight ¶ added in v0.12.0
func WithMaxInFlight(n int) broker.SubscribeOption
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.