nsq

Documentation

Index

• Variables
• func NewConfig() *nsq.Config
• func NewProducer(lc fx.Lifecycle, params *ProducerParams) (producer.Producer, error)
• func RegisterConsumer(lc fx.Lifecycle, params *ConsumerParams) error
• type ConsumerParams
• type ProducerParams

Variables

var (
	// ConfigModule for fx.
	ConfigModule = fx.Options(fx.Provide(NewConfig))

	// Module for fx.
	Module = fx.Options(ConfigModule)
)

Functions

func NewConfig

func NewConfig() *nsq.Config

NewConfig for NSQ.

func NewProducer

func NewProducer(lc fx.Lifecycle, params *ProducerParams) (producer.Producer, error)

NewProducer for NSQ.

func RegisterConsumer

func RegisterConsumer(lc fx.Lifecycle, params *ConsumerParams) error

RegisterConsumer for NSQ.

Types

type ConsumerParams

type ConsumerParams struct {
	SystemConfig *config.Config
	NSQConfig    *nsq.Config
	Logger       *zap.Logger
	Topic        string
	Channel      string
	Handler      handler.Handler
}

ConsumerParams for NSQ.

type ProducerParams

type ProducerParams struct {
	SystemConfig *config.Config
	NSQConfig    *nsq.Config
	Logger       *zap.Logger
}

ProducerParams for NSQ.