mynsq

Documentation

Index

• Variables
• func Get(topic string, ch string, fn func([]byte, string))
• func InitNsq(server string) error
• func ReturnCon() *nsq.Producer
• func Send(topic string, msg []byte) error

Variables

var Server string

Functions

func Get

func Get(topic string, ch string, fn func([]byte, string))

func InitNsq

func InitNsq(server string) error

func ReturnCon

func ReturnCon() *nsq.Producer

func Send

func Send(topic string, msg []byte) error