consumer

Documentation

Index

• func Conn(c Configs) (err error)
• func Start(f nsq.HandlerFunc) error
• func States() *nsq.ConsumerStats
• func Stop()
• type Configs

Functions

func Conn

func Conn(c Configs) (err error)

Conn -

func Start

func Start(f nsq.HandlerFunc) error

Start -

func States

func States() *nsq.ConsumerStats

States -

func Stop

func Stop()

Stop -

Types

type Configs

type Configs struct {
	LogLevel   nsq.LogLevel
	Topic      string
	Channel    string
	Nsqlookupd string
}

Configs -

var (
	Logger         = log.New(os.Stderr, "", log.Flags())
	ConsumerConfig Configs
)