consumer

Documentation

Index

• type MarketingConsumer
  • func NewMarketingConsumer(ch *amqp.Channel, couponsModel model.CouponsModel, ...) *MarketingConsumer
  • func (c *MarketingConsumer) Start(ctx context.Context) error
  • func (c *MarketingConsumer) Stop() error

Types

type MarketingConsumer

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

func NewMarketingConsumer

func NewMarketingConsumer(
	ch *amqp.Channel,
	couponsModel model.CouponsModel,
	userCouponsModel model.UserCouponsModel,
	promotionsModel model.PromotionsModel,
	userPointsModel model.UserPointsModel,
	pointsRecordModel model.PointsRecordsModel,
) *MarketingConsumer

func (*MarketingConsumer) Start

func (c *MarketingConsumer) Start(ctx context.Context) error

func (*MarketingConsumer) Stop

func (c *MarketingConsumer) Stop() error