mq

Documentation

Index

• func DeferPubAsync(topic string, delay time.Duration, body []byte) error
• func Init(opts ...OptionFunc) (e error)
• func PubAsync(topic string, body []byte) error
• func StopConsumers()
• func StopProducer()
• func Sub(topic, channel string, handler nsq.Handler) (e error)
• type OptionFunc
  • func Lookupd(addr string) OptionFunc
  • func Nsqd(addr string) OptionFunc
  • func Writer(writer io.Writer) OptionFunc
• type Options
• type Route

Functions

func DeferPubAsync

func DeferPubAsync(topic string, delay time.Duration, body []byte) error

func Init

func Init(opts ...OptionFunc) (e error)

func PubAsync

func PubAsync(topic string, body []byte) error

func StopConsumers

func StopConsumers()

func StopProducer

func StopProducer()

func Sub

func Sub(topic, channel string, handler nsq.Handler) (e error)

Types

type OptionFunc

type OptionFunc func(*Options)

func Lookupd

func Lookupd(addr string) OptionFunc

func Nsqd

func Nsqd(addr string) OptionFunc

func Writer

func Writer(writer io.Writer) OptionFunc

type Options

type Options struct {
	// contains filtered or unexported fields
}

type Route

type Route struct {
	// contains filtered or unexported fields
}