nsq

Documentation

Index

• type Client
  • func NewClient(address string) *Client
  • func (client Client) Listen(param Param, handler nsq.Handler) error
  • func (client Client) NewProducer() (*nsq.Producer, error)
• type Param

Types

type Client

type Client struct {
	Address string
}

func NewClient

func NewClient(address string) *Client

NewClient

func (Client) Listen

func (client Client) Listen(param Param, handler nsq.Handler) error

Listen make topic listener

func (Client) NewProducer

func (client Client) NewProducer() (*nsq.Producer, error)

NewProducer return nsq producer instance with error

type Param

type Param struct {
	Topic               string
	Channel             string
	Debug               bool
	LookupdPollInterval int // reconnect time interval
}