nsq

Documentation

Index

• Constants
• type Client
  • func New(nodeList []string) (Client, error)
• type ClientNsq
  • func (s *ClientNsq) ConsumerMsg(topic, channel string, lookUpAddrs []string, handler nsq.Handler) (*nsq.Consumer, error)
  • func (s *ClientNsq) StopProducerList()
  • func (s *ClientNsq) SyncSendMsg(topic string, data []byte, delay time.Duration) error

Constants

const (
	MaxInFlight = 9
	MaxAttempts = 65531
)

Types

type Client

type Client interface {
	// SyncSendMsg is used to send a message to the server
	SyncSendMsg(topic string, data []byte, delay time.Duration) error
	// ConsumerMsg is used to consume messages from the server
	ConsumerMsg(topic, channel string, lookUpAddrs []string,
		handler nsq.Handler) (*nsq.Consumer, error)
	// StopProducerList is used to stop the producer list gracefully
	StopProducerList()
}

Client is interface for nsq clusters

func New

func New(nodeList []string) (Client, error)

New creates a new nsq client

type ClientNsq

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

ClientNsq is the client for nsq clusters

func (*ClientNsq) ConsumerMsg

func (s *ClientNsq) ConsumerMsg(topic, channel string,
	lookUpAddrs []string, handler nsq.Handler) (*nsq.Consumer, error)

ConsumerMsg is used to consume messages from the server

func (*ClientNsq) StopProducerList

func (s *ClientNsq) StopProducerList()

StopProducerList is used to stop the producer list gracefully

func (*ClientNsq) SyncSendMsg

func (s *ClientNsq) SyncSendMsg(topic string, data []byte, delay time.Duration) error

SyncSendMsg is used to send a message to the server