mq

Documentation

Index

• func NewCommodityMQ(client *kafka.Kafka) repository.CommodityMQ
• type CommodityMQ
  • func (c *CommodityMQ) ConsumeCreateSpuInfo(ctx context.Context) <-chan *kafka.Message
  • func (c *CommodityMQ) ConsumeDeleteSpuInfo(ctx context.Context) <-chan *kafka.Message
  • func (c *CommodityMQ) ConsumeUpdateSpuInfo(ctx context.Context) <-chan *kafka.Message
  • func (c *CommodityMQ) Send(ctx context.Context, topic string, message []*kafka.Message) error
  • func (c *CommodityMQ) SendCreateSpuInfo(ctx context.Context, spu *model.Spu) error
  • func (c *CommodityMQ) SendDeleteSpuInfo(ctx context.Context, id int64) error
  • func (c *CommodityMQ) SendUpdateSpuInfo(ctx context.Context, spu *model.Spu) error

Functions

func NewCommodityMQ

func NewCommodityMQ(client *kafka.Kafka) repository.CommodityMQ

Types

type CommodityMQ

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

func (*CommodityMQ) ConsumeCreateSpuInfo

func (c *CommodityMQ) ConsumeCreateSpuInfo(ctx context.Context) <-chan *kafka.Message

func (*CommodityMQ) ConsumeDeleteSpuInfo

func (c *CommodityMQ) ConsumeDeleteSpuInfo(ctx context.Context) <-chan *kafka.Message

func (*CommodityMQ) ConsumeUpdateSpuInfo

func (c *CommodityMQ) ConsumeUpdateSpuInfo(ctx context.Context) <-chan *kafka.Message

func (*CommodityMQ) Send

func (c *CommodityMQ) Send(ctx context.Context, topic string, message []*kafka.Message) error

func (*CommodityMQ) SendCreateSpuInfo

func (c *CommodityMQ) SendCreateSpuInfo(ctx context.Context, spu *model.Spu) error

func (*CommodityMQ) SendDeleteSpuInfo

func (c *CommodityMQ) SendDeleteSpuInfo(ctx context.Context, id int64) error

func (*CommodityMQ) SendUpdateSpuInfo

func (c *CommodityMQ) SendUpdateSpuInfo(ctx context.Context, spu *model.Spu) error