Documentation ¶
Index ¶
- func KeyConsumer(topic, subName string) string
- type Handler
- type Nsq
- func (s *Nsq) ConsumerDelayTopic(confInfoList []*cc.ProducerConfInfo)
- func (s *Nsq) ConsumerProcessorTopic(confInfoList []*cc.ProcessorConfInfo)
- func (s *Nsq) Stop() error
- func (s *Nsq) WatchDelayTopic(c *cc.ProducerConfInfo, eventType int32) error
- func (s *Nsq) WatchProcessorTopic(c *cc.ProcessorConfInfo, eventType int32) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Nsq ¶
type Nsq struct { NsqClient nsq.Client Opts *options.Options Handler *handler.Handler RedisPool *redigo.Pool // contains filtered or unexported fields }
Nsq is a type of connector
func (*Nsq) ConsumerDelayTopic ¶
func (s *Nsq) ConsumerDelayTopic(confInfoList []*cc.ProducerConfInfo)
ConsumerDelayTopic is the subject of the subscription latency processor
func (*Nsq) ConsumerProcessorTopic ¶
func (s *Nsq) ConsumerProcessorTopic(confInfoList []*cc.ProcessorConfInfo)
ConsumerProcessorTopic is the topic of the subscription processor
func (*Nsq) WatchDelayTopic ¶
func (s *Nsq) WatchDelayTopic(c *cc.ProducerConfInfo, eventType int32) error
WatchDelayTopic watch the topic of the latency processor
func (*Nsq) WatchProcessorTopic ¶
func (s *Nsq) WatchProcessorTopic(c *cc.ProcessorConfInfo, eventType int32) error
WatchProcessorTopic watch the topic of the processor
Click to show internal directories.
Click to hide internal directories.