mq

Documentation

Index

• type KafkaAdapter
  • func NewKafkaAdapter(mq *kafka.Kafka) *KafkaAdapter
  • func (c *KafkaAdapter) ConsumeAddGoods(ctx context.Context) <-chan *kafka.Message
  • func (c *KafkaAdapter) SendAddGoods(ctx context.Context, uid int64, goods *model.GoodInfo) error

Types

type KafkaAdapter

type KafkaAdapter struct {
	// contains filtered or unexported fields
}

KafkaAdapter 这里不是mqAdapter的原因是我们调用的是在pkg封装的kafka

func NewKafkaAdapter

func NewKafkaAdapter(mq *kafka.Kafka) *KafkaAdapter

func (*KafkaAdapter) ConsumeAddGoods

func (c *KafkaAdapter) ConsumeAddGoods(ctx context.Context) <-chan *kafka.Message

func (*KafkaAdapter) SendAddGoods

func (c *KafkaAdapter) SendAddGoods(ctx context.Context, uid int64, goods *model.GoodInfo) error

SendAddGoods 将goodsInfo传递到mq