nsqhelper

package
v0.0.0-...-dbefbc8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 13, 2022 License: MIT Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Prod = []string{"nsqlookupd1.nsq.svc.cluster.local:4161", "nsqlookupd2.nsq.svc.cluster.local:4161"}
	Test = []string{"localhost:4161"}
)

Functions

func NewNSQConsumer

func NewNSQConsumer(topicName, channelName string, maxInFlight int) (*nsq.Consumer, error)

func NewNSQProducer

func NewNSQProducer() (*nsq.Producer, error)

func NewTestNSQProducer

func NewTestNSQProducer() (*nsq.Producer, error)

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL