nsqproducerb

package module

v0.0.0-...-0c17725 Latest Latest Go to latest Published: Dec 21, 2017 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

using balance load for nsqproducer

This section is empty.

This section is empty.

func SetMaxRetryTimes(tm int)

SetMaxRetryTimes set the retry times if producer connection is break

type INSQProducerb interface {
	Stop()
	Publish(topic string, body []byte) error
	SetLogger(l logger, lvl nsq.LogLevel)
	Shutdown()
}

INSQProducerb is an interface to export

func NewNSQProducer(nsqlookupdAddrs []string, config *nsq.Config, l logger, loglvl nsq.LogLevel) (INSQProducerb, error)

NewNSQProducer return a NSQProducer instance

@param1 nsqlookupAddr

func NewNSQProducerByAdminAddress(adminAddr string, config *nsq.Config, l logger, loglvl nsq.LogLevel) (INSQProducerb, error)

NewNSQProducerByAdminAddress initialize a producer instance by getting nsqlookupd info from nsq admin