nsqlib

Documentation

Index

• func Init(param NSQLibParam) error
• func Publish(topic string, value interface{}) error
• func RegisterConsumer(handler NSQHandler, topic, channel string, concurrency int) error
• type NSQHandler
• type NSQLibParam

Functions

func Init

func Init(param NSQLibParam) error

func Publish

func Publish(topic string, value interface{}) error

func RegisterConsumer

func RegisterConsumer(handler NSQHandler, topic, channel string, concurrency int) error

Types

type NSQHandler

type NSQHandler func(message *nsq.Message) error

type NSQLibParam

type NSQLibParam struct {
	NsqLookupdAddrs []string
	NsqdAddr        string
}