nsq

Documentation

Index

• type Consumer
  • func NewConsumer(topic, channel string) *Consumer
  • func (c *Consumer) Set(option string, value interface{})
  • func (c *Consumer) SetLogger(log logger, level nsq.LogLevel)
  • func (c *Consumer) SetMap(options map[string]interface{})
  • func (c *Consumer) Start(handler nsq.Handler) error
  • func (c *Consumer) Stop() error
• type Producer
  • func NewNsqProducer(addrs []string) *Producer
  • func (p *Producer) PubMsg(topic string, msg interface{}) error

Types

type Consumer

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

func NewConsumer

func NewConsumer(topic, channel string) *Consumer

初始化消费端

func (*Consumer) Set

func (c *Consumer) Set(option string, value interface{})

func (*Consumer) SetLogger

func (c *Consumer) SetLogger(log logger, level nsq.LogLevel)

func (*Consumer) SetMap

func (c *Consumer) SetMap(options map[string]interface{})

func (*Consumer) Start

func (c *Consumer) Start(handler nsq.Handler) error

func (*Consumer) Stop

func (c *Consumer) Stop() error

stop and wait

type Producer

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

func NewNsqProducer

func NewNsqProducer(addrs []string) *Producer

func (*Producer) PubMsg

func (p *Producer) PubMsg(topic string, msg interface{}) error