bilibili-backup/app/service/bbq/video/dao/databus.go
2019-04-22 02:59:20 +00:00

20 lines
380 B
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
}