nsq

Documentation

Index

• type MessageHandler
  • func NewMessageHandler(nsqServer string, channel string) (mh *MessageHandler, err error)
  • func (m *MessageHandler) Registry(topic string, ch chan []byte)
  • func (m *MessageHandler) SetMaxInFlight(val int)
  • func (m *MessageHandler) SetMsgTimeout(d time.Duration)
• type Producer
  • func NewProducer(addr string) (producer *Producer, err error)
  • func (m *Producer) Publish(topic string, data []byte) (err error)

Types

type MessageHandler

type MessageHandler struct {
	Channel string
	// contains filtered or unexported fields
}

MessageHandler MessageHandler

func NewMessageHandler

func NewMessageHandler(nsqServer string, channel string) (mh *MessageHandler, err error)

NewMessageHandler return new MessageHandler

func (*MessageHandler) Registry

func (m *MessageHandler) Registry(topic string, ch chan []byte)

Registry register nsq topic

func (*MessageHandler) SetMaxInFlight

func (m *MessageHandler) SetMaxInFlight(val int)

SetMaxInFlight set nsq consumer MaxInFlight

func (*MessageHandler) SetMsgTimeout

func (m *MessageHandler) SetMsgTimeout(d time.Duration)

SetMsgTimeout set nsq consumer MsgTimeout

type Producer

type Producer struct {
	P *gnsq.Producer
}

func NewProducer

func NewProducer(addr string) (producer *Producer, err error)

NewProducer init

return producer

func (*Producer) Publish

func (m *Producer) Publish(topic string, data []byte) (err error)

Publish topic

return error