strmsub

Documentation

Index

• type StreamSub
  • func NewStreamSub(biz streambiz.StreamBiz, serviceCtx srvctx.ServiceContext) *StreamSub
  • func (s *StreamSub) EndStream() subengine.ConsumerJob
  • func (s *StreamSub) StartStream() subengine.ConsumerJob
  • func (s *StreamSub) UpdateStreamViewCount() subengine.ConsumerJob
• type UpdateStreamViewCountData

Types

type StreamSub

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

func NewStreamSub

func NewStreamSub(biz streambiz.StreamBiz, serviceCtx srvctx.ServiceContext) *StreamSub

func (*StreamSub) EndStream

func (s *StreamSub) EndStream() subengine.ConsumerJob

func (*StreamSub) StartStream

func (s *StreamSub) StartStream() subengine.ConsumerJob

func (*StreamSub) UpdateStreamViewCount

func (s *StreamSub) UpdateStreamViewCount() subengine.ConsumerJob

type UpdateStreamViewCountData

type UpdateStreamViewCountData struct {
	Id        float64 `json:"id"`
	View      float64 `json:"view"`
	TimeStamp string  `json:"timeStamp"`
}