Versions in this module Expand all Collapse all v0 v0.0.1 May 9, 2021 Changes in this version + type Collector struct + func NewCollector(apiKeys []string, databasePath string, opts ...Option) (*Collector, error) + func (c *Collector) GetArchiveLiveChat(request *pb.GetArchiveLiveChatRequest) (*pb.GetArchiveLiveChatResponse, error) + func (c *Collector) GetCachedActiveLiveChat(request *pb.GetCachedActiveLiveChatRequest) (*pb.GetCachedActiveLiveChatResponse, error) + func (c *Collector) GetVideo(request *pb.GetVideoRequest) (*pb.GetVideoResponse, error) + func (c *Collector) Start() error + func (c *Collector) StartCollectionActiveLiveChat(request *pb.StartCollectionActiveLiveChatRequest) (*pb.StartCollectionActiveLiveChatResponse, error) + func (c *Collector) StartCollectionArchiveLiveChat(request *pb.StartCollectionArchiveLiveChatRequest) (*pb.StartCollectionArchiveLiveChatResponse, error) + func (c *Collector) Stop() + func (c *Collector) SubscribeActiveLiveChat(videoId string) (*subscribeActiveLiveChatParams, error) + func (c *Collector) UnsubscribeActiveLiveChat(subscribeActiveLiveChatParams *subscribeActiveLiveChatParams) + type DatabaseOperator struct + func NewDatabaseOperator(databasePath string, opts ...Option) (*DatabaseOperator, error) + func (d *DatabaseOperator) Close() + func (d *DatabaseOperator) CountArchiveLiveChatMessagesByVideoId(videoId string) (int, error) + func (d *DatabaseOperator) DeleteActiveLiveChatMessagesByLastUpdate(lastUpdate int) error + func (d *DatabaseOperator) DeleteArchiveLiveChatMessagesByLastUpdate(lastUpdate int) error + func (d *DatabaseOperator) DeleteVideoByLastUpdate(lastUpdate int) error + func (d *DatabaseOperator) GetActiveLiveChatMessagesByVideoIdAndToken(videoId string, offset int64, count int64) ([]*pb.ActiveLiveChatMessage, error) + func (d *DatabaseOperator) GetArchiveLiveChatMessagesByVideoIdAndToken(videoId string, offset int64, count int64) ([]*pb.ArchiveLiveChatMessage, error) + func (d *DatabaseOperator) GetVideoByVideoId(videoId string) (*pb.Video, bool, error) + func (d *DatabaseOperator) Open() error + func (d *DatabaseOperator) UpdateActiveLiveChatMessages(activeLiveChatMessages []*pb.ActiveLiveChatMessage) error + func (d *DatabaseOperator) UpdateArchiveLiveChatMessages(archiveLiveChatMessages []*pb.ArchiveLiveChatMessage) error + func (d *DatabaseOperator) UpdateVideo(video *pb.Video) error + type Option func(*options) + func Verbose(verbose bool) Option
Go to main page