yt

Documentation

Index

• type YTData
• type YTDataService
  • func NewYTDataService(conf1 *kafka.ConfigMap, producerPtr *kafka.Producer, playlistID string, ...) *YTDataService
  • func (y *YTDataService) GetYTData(ctx context.Context) ([]*YTData, error)

Types

type YTData

type YTData struct {
	VideoId           string `json:"video_id"`
	VideoTitle        string `json:"video_title"`
	VideoLikeCount    int    `json:"video_like_count"`
	VideoCommentCount int    `json:"video_comment_count"`
	ClientTelegramId  string `json:"client_telegram_id"`
}

type YTDataService

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

func NewYTDataService

func NewYTDataService(conf1 *kafka.ConfigMap, producerPtr *kafka.Producer, playlistID string, clientTelegramId string) *YTDataService

func (*YTDataService) GetYTData

func (y *YTDataService) GetYTData(ctx context.Context) ([]*YTData, error)