nsq

Documentation

Index

• Variables
• func ConcurrentHandlerCount(n int) broker.SubscribeOption
• func MaxInFlight(n int) broker.Option
• func New(opts ...broker.Option) broker.Broker

Variables

var (
	Config = &nsqConfig{
		done: make(chan struct{}),
	}
)

Config ...

var (
	DefaultConcurrentHandlerCount = 1
)

DefaultConcurrentHandlerCount ...

Functions

func ConcurrentHandlerCount

func ConcurrentHandlerCount(n int) broker.SubscribeOption

ConcurrentHandlerCount ...

func MaxInFlight

func MaxInFlight(n int) broker.Option

MaxInFlight ...

func New

func New(opts ...broker.Option) broker.Broker

New ...