nsq

Documentation

Index

• type Consumer
  • func (c *Consumer) Close() error
  • func (c *Consumer) Config() any
  • func (c *Consumer) Init() error
• type ConsumerConfig
  • func (c *ConsumerConfig) BeforeInject()
  • func (c *ConsumerConfig) Build() (*nsq.Consumer, error)
  • func (c *ConsumerConfig) Init()
• type Producer
  • func (p *Producer) Close() error
  • func (p *Producer) Config() any
  • func (p *Producer) Init() error
• type ProducerConfig
  • func (c *ProducerConfig) BeforeInject()
  • func (c *ProducerConfig) Build() (*nsq.Producer, error)
  • func (c *ProducerConfig) Init()

Types

type Consumer

type Consumer struct {
	*nsq.Consumer
	Conf ConsumerConfig
}

func (*Consumer) Close

func (c *Consumer) Close() error

func (*Consumer) Config

func (c *Consumer) Config() any

func (*Consumer) Init

func (c *Consumer) Init() error

type ConsumerConfig

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

func (*ConsumerConfig) BeforeInject

func (c *ConsumerConfig) BeforeInject()

func (*ConsumerConfig) Build

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

func (*ConsumerConfig) Init

func (c *ConsumerConfig) Init()

type Producer

type Producer struct {
	*nsq.Producer
	Conf ProducerConfig
}

func (*Producer) Close

func (p *Producer) Close() error

func (*Producer) Config

func (p *Producer) Config() any

func (*Producer) Init

func (p *Producer) Init() error

type ProducerConfig

type ProducerConfig struct {
	Addr string
	*nsq.Config
}

func (*ProducerConfig) BeforeInject

func (c *ProducerConfig) BeforeInject()

func (*ProducerConfig) Build

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

func (*ProducerConfig) Init

func (c *ProducerConfig) Init()