nsq

package

v0.7.13 Latest Latest Go to latest Published: Apr 15, 2025 License: MIT Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Consumer struct {
	*nsq.Consumer
	Conf ConsumerConfig
}

func (c *Consumer) Close() error

func (c *Consumer) Config() any

func (c *Consumer) Init() error

type ConsumerConfig struct {
	NSQLookupdAddrs []string
	NSQdAddrs       []string
	Topic           string
	Channel         string
	*nsq.Config
}

func (c *ConsumerConfig) AfterInject()

func (c *ConsumerConfig) BeforeInject()

func (c *ConsumerConfig) Build() (*nsq.Consumer, error)

func (c *ConsumerConfig) Init()

type Producer struct {
	*nsq.Producer
	Conf ProducerConfig
}

func (p *Producer) Close() error

func (p *Producer) Config() any

func (p *Producer) Init() error

type ProducerConfig struct {
	Addr string
	*nsq.Config
}

func (c *ProducerConfig) AfterInject()

func (c *ProducerConfig) BeforeInject()

func (c *ProducerConfig) Build() (*nsq.Producer, error)

func (c *ProducerConfig) Init()