openbilibili/app/service/bbq/video/dao/databus.go

package dao

import (
	"context"
	"go-common/app/service/bbq/video/model"
	"go-common/library/log"
)

const (
	keyOnBoard = "OnboardVideo"
)

// CmsPub pub cms data into databus.
func (d *Dao) CmsPub(c context.Context, data *model.DataTopicCmsData) (err error) {
	if err = d.cmsPub.Send(c, keyOnBoard, data); err != nil {
		log.Error("d.databus.Send error(%v)", err)
	}
	return
}