collector

Documentation

Index

• type Collector
  • 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
  • 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 Verbose(verbose bool) Option

Types

type Collector

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

func NewCollector

func NewCollector(apiKeys []string, databasePath string, opts ...Option) (*Collector, error)

func (*Collector) GetArchiveLiveChat

func (c *Collector) GetArchiveLiveChat(request *pb.GetArchiveLiveChatRequest) (*pb.GetArchiveLiveChatResponse, error)

func (*Collector) GetCachedActiveLiveChat

func (c *Collector) GetCachedActiveLiveChat(request *pb.GetCachedActiveLiveChatRequest) (*pb.GetCachedActiveLiveChatResponse, error)

func (*Collector) GetVideo

func (c *Collector) GetVideo(request *pb.GetVideoRequest) (*pb.GetVideoResponse, error)

func (*Collector) Start

func (c *Collector) Start() error

func (*Collector) StartCollectionActiveLiveChat

func (c *Collector) StartCollectionActiveLiveChat(request *pb.StartCollectionActiveLiveChatRequest) (*pb.StartCollectionActiveLiveChatResponse, error)

func (*Collector) StartCollectionArchiveLiveChat

func (c *Collector) StartCollectionArchiveLiveChat(request *pb.StartCollectionArchiveLiveChatRequest) (*pb.StartCollectionArchiveLiveChatResponse, error)

func (*Collector) Stop

func (c *Collector) Stop()

func (*Collector) SubscribeActiveLiveChat

func (c *Collector) SubscribeActiveLiveChat(videoId string) (*subscribeActiveLiveChatParams, error)

func (*Collector) UnsubscribeActiveLiveChat

func (c *Collector) UnsubscribeActiveLiveChat(subscribeActiveLiveChatParams *subscribeActiveLiveChatParams)

type DatabaseOperator

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

func NewDatabaseOperator

func NewDatabaseOperator(databasePath string, opts ...Option) (*DatabaseOperator, error)

func (*DatabaseOperator) Close

func (d *DatabaseOperator) Close()

func (*DatabaseOperator) CountArchiveLiveChatMessagesByVideoId

func (d *DatabaseOperator) CountArchiveLiveChatMessagesByVideoId(videoId string) (int, error)

func (*DatabaseOperator) DeleteActiveLiveChatMessagesByLastUpdate

func (d *DatabaseOperator) DeleteActiveLiveChatMessagesByLastUpdate(lastUpdate int) error

func (*DatabaseOperator) DeleteArchiveLiveChatMessagesByLastUpdate

func (d *DatabaseOperator) DeleteArchiveLiveChatMessagesByLastUpdate(lastUpdate int) error

func (*DatabaseOperator) DeleteVideoByLastUpdate

func (d *DatabaseOperator) DeleteVideoByLastUpdate(lastUpdate int) error

func (*DatabaseOperator) GetActiveLiveChatMessagesByVideoIdAndToken

func (d *DatabaseOperator) GetActiveLiveChatMessagesByVideoIdAndToken(videoId string, offset int64, count int64) ([]*pb.ActiveLiveChatMessage, error)

func (*DatabaseOperator) GetArchiveLiveChatMessagesByVideoIdAndToken

func (d *DatabaseOperator) GetArchiveLiveChatMessagesByVideoIdAndToken(videoId string, offset int64, count int64) ([]*pb.ArchiveLiveChatMessage, error)

func (*DatabaseOperator) GetVideoByVideoId

func (d *DatabaseOperator) GetVideoByVideoId(videoId string) (*pb.Video, bool, error)

func (*DatabaseOperator) Open

func (d *DatabaseOperator) Open() error

func (*DatabaseOperator) UpdateActiveLiveChatMessages

func (d *DatabaseOperator) UpdateActiveLiveChatMessages(activeLiveChatMessages []*pb.ActiveLiveChatMessage) error

func (*DatabaseOperator) UpdateArchiveLiveChatMessages

func (d *DatabaseOperator) UpdateArchiveLiveChatMessages(archiveLiveChatMessages []*pb.ArchiveLiveChatMessage) error

func (*DatabaseOperator) UpdateVideo

func (d *DatabaseOperator) UpdateVideo(video *pb.Video) error

type Option

type Option func(*options)

func Verbose

func Verbose(verbose bool) Option