nsq

Oct 28, 2021

Changes in this version

type Config

+ UserAgent string

May 12, 2021

Changes in this version

+ type Config struct

+ Config *nsq.Config

+ Host string

+ LookupHost string

type ConsumerParams

+ Config *Config

type ProducerParams

+ Config *Config

May 8, 2021

Changes in this version

+ var ConfigModule = fx.Options(fx.Provide(NewConfig))

+ var Module = fx.Options(ConfigModule)

+ func NewConfig() *nsq.Config

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

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

+ type ConsumerParams struct

+ Channel string

+ Handler handler.Handler

+ Logger *zap.Logger

+ NSQConfig *nsq.Config

+ SystemConfig *config.Config

+ Topic string

+ type ProducerParams struct

+ Logger *zap.Logger

+ NSQConfig *nsq.Config

+ SystemConfig *config.Config