Versions in this module Expand all Collapse all v0 v0.0.5 Nov 22, 2022 Changes in this version + func NewConsumer(c *config.Config, logger log.Logger) (mq.Consumer, error) + func NewNsqConfigWithConfig(c *config.Config) *nsq.Config + func NewProducer(c *config.Config, logger log.Logger) (mq.Producer, error) + type ConsumerImpl struct + func (x *ConsumerImpl) Close(ctx context.Context) error + func (x *ConsumerImpl) Subscribe(ctx context.Context, topic string, channel string) (<-chan mq.Message, error) + type ProducerImpl struct + func (x *ProducerImpl) Close(ctx context.Context) error + func (x *ProducerImpl) Publish(ctx context.Context, topic string, message mq.Message) error Other modules containing this package github.com/Ccheers/kratos-mq
Go to main page