Documentation
¶
Index ¶
- type ConsumerService
- func (s *ConsumerService) DanmuCountStatistics(ctx context.Context, msg *databus.Message) (err error)
- func (s *ConsumerService) GiftCount(ctx context.Context, msg *databus.Message) (err error)
- func (s *ConsumerService) GuardBuyStatistics(ctx context.Context, msg *databus.Message) (err error)
- func (s *ConsumerService) LiveMessageContent(ctx context.Context)
- func (s *ConsumerService) LiveRankList(ctx context.Context, msg *databus.Message) (err error)
- func (s *ConsumerService) LiveRoomTag(ctx context.Context, msg *databus.Message) (err error)
- func (s *ConsumerService) PopularityStatistics(ctx context.Context, msg *databus.Message) (err error)
- func (s *ConsumerService) ValidDaysStatistics(ctx context.Context, msg *databus.Message) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerService ¶
type ConsumerService struct {
// contains filtered or unexported fields
}
ConsumerService struct
func NewConsumerService ¶
func NewConsumerService(c *conf.Config) (s *ConsumerService)
NewConsumerService init 统计类数据同步落地,实时数据异步落地
func (*ConsumerService) DanmuCountStatistics ¶
func (s *ConsumerService) DanmuCountStatistics(ctx context.Context, msg *databus.Message) (err error)
DanmuCountStatistics 弹幕数统计
func (*ConsumerService) GuardBuyStatistics ¶
func (*ConsumerService) LiveMessageContent ¶
func (s *ConsumerService) LiveMessageContent(ctx context.Context)
LiveMessageContent ...
func (*ConsumerService) LiveRankList ¶
LiveRoomTag 房间实时标签,同步落地
func (*ConsumerService) LiveRoomTag ¶
LiveRoomTag 房间实时标签,同步落地
func (*ConsumerService) PopularityStatistics ¶
func (s *ConsumerService) PopularityStatistics(ctx context.Context, msg *databus.Message) (err error)
PopularityStatistics 离线人气相关统计,同步落地
func (*ConsumerService) ValidDaysStatistics ¶
func (s *ConsumerService) ValidDaysStatistics(ctx context.Context, msg *databus.Message) (err error)
ValidDaysStatistics 有效天数相关数据(同步落地)
Click to show internal directories.
Click to hide internal directories.