nsq

package
v0.0.0-...-f5948c0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 23, 2023 License: MIT Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Consumer

type Consumer struct {
	*nsq.Consumer `init:"entity"`
	Conf          ConsumerConfig `init:"config"`
}

func (*Consumer) Close

func (c *Consumer) Close() error

func (*Consumer) Config

func (c *Consumer) Config() any

func (*Consumer) SetEntity

func (c *Consumer) SetEntity()

type ConsumerConfig

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

func (*ConsumerConfig) Build

func (conf *ConsumerConfig) Build() *nsq.Consumer

type Producer

type Producer struct {
	*nsq.Producer `init:"entity"`
	Conf          ProducerConfig `init:"config"`
}

func (*Producer) Close

func (p *Producer) Close() error

func (*Producer) Config

func (p *Producer) Config() any

func (*Producer) SetEntity

func (p *Producer) SetEntity(entity interface{})

type ProducerConfig

type ProducerConfig struct {
	Addr string
	*nsq.Config
}

func (*ProducerConfig) Build

func (conf *ProducerConfig) Build() *nsq.Producer

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL