mq

Documentation

Index

• func InitRabbitMQ(svcCtx *svc.ServiceContext)
• func InitVFPublisher(core *utils.RabbitmqCore)
• func StartVFConsumer(conn *amqp.Connection)
• type RabbitMQLogic
  • func NewRabbitMQLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RabbitMQLogic
  • func (l *RabbitMQLogic) FavoriteCancelCheck(vfMsg *utils.VFMessage)
  • func (l *RabbitMQLogic) FavoriteCheck(vfMsg *utils.VFMessage)
  • func (l *RabbitMQLogic) FavoriteUpdatePublisher(videoId, userId int64, isCancel int8)

Functions

func InitRabbitMQ

func InitRabbitMQ(svcCtx *svc.ServiceContext)

func InitVFPublisher

func InitVFPublisher(core *utils.RabbitmqCore)

func StartVFConsumer

func StartVFConsumer(conn *amqp.Connection)

Types

type RabbitMQLogic

type RabbitMQLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

var (
	RabbitMQ *RabbitMQLogic
	Json     = jsoniter.ConfigCompatibleWithStandardLibrary
)

func NewRabbitMQLogic

func NewRabbitMQLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RabbitMQLogic

func (*RabbitMQLogic) FavoriteCancelCheck

func (l *RabbitMQLogic) FavoriteCancelCheck(vfMsg *utils.VFMessage)

func (*RabbitMQLogic) FavoriteCheck

func (l *RabbitMQLogic) FavoriteCheck(vfMsg *utils.VFMessage)

func (*RabbitMQLogic) FavoriteUpdatePublisher

func (l *RabbitMQLogic) FavoriteUpdatePublisher(videoId, userId int64, isCancel int8)