beater

Documentation

Index

• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• func RunBot(bt *twitchatbeat, b *beat.Beat)
• func StreamStatusFields(b *beat.Beat, status *helix.ChannelData) common.MapStr
• type CacheStreamStatus
• type ElasticLogger
  • func NewElasticLogger(b *beat.Beat, bt *twitchatbeat) ElasticLogger
  • func (l *ElasticLogger) GetAvailableLogsForUser(channelID, userID string) ([]filelog.UserLogFile, error)
  • func (l *ElasticLogger) GetLastLogYearAndMonthForUser(channelID, userID string) (int, int, error)
  • func (l *ElasticLogger) LogClearchatMessageForChannel(message twitch.ClearChatMessage) error
  • func (l *ElasticLogger) LogClearchatMessageForUser(userID string, message twitch.ClearChatMessage) error
  • func (l *ElasticLogger) LogPrivateMessageForChannel(message twitch.PrivateMessage) error
  • func (l *ElasticLogger) LogPrivateMessageForUser(user twitch.User, message twitch.PrivateMessage) error
  • func (l *ElasticLogger) LogUserNoticeMessageForChannel(message twitch.UserNoticeMessage) error
  • func (l *ElasticLogger) LogUserNoticeMessageForUser(userID string, message twitch.UserNoticeMessage) error
  • func (l *ElasticLogger) ReadLogForChannel(channelID string, year int, month int, day int) ([]string, error)
  • func (l *ElasticLogger) ReadLogForUser(channelID, userID string, year string, month string) ([]string, error)
  • func (l *ElasticLogger) ReadRandomMessageForChannel(channelID string) (string, error)
  • func (l *ElasticLogger) ReadRandomMessageForUser(channelID, userID string) (string, error)

Functions

func New

func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)

New creates an instance of twitchatbeat.

func RunBot

func RunBot(bt *twitchatbeat, b *beat.Beat)

func StreamStatusFields

func StreamStatusFields(b *beat.Beat, status *helix.ChannelData) common.MapStr

Types

type CacheStreamStatus

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

type ElasticLogger

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

func NewElasticLogger

func NewElasticLogger(b *beat.Beat, bt *twitchatbeat) ElasticLogger

func (*ElasticLogger) GetAvailableLogsForUser

func (l *ElasticLogger) GetAvailableLogsForUser(channelID, userID string) ([]filelog.UserLogFile, error)

func (*ElasticLogger) GetLastLogYearAndMonthForUser

func (l *ElasticLogger) GetLastLogYearAndMonthForUser(channelID, userID string) (int, int, error)

func (*ElasticLogger) LogClearchatMessageForChannel

func (l *ElasticLogger) LogClearchatMessageForChannel(message twitch.ClearChatMessage) error

func (*ElasticLogger) LogClearchatMessageForUser

func (l *ElasticLogger) LogClearchatMessageForUser(userID string, message twitch.ClearChatMessage) error

func (*ElasticLogger) LogPrivateMessageForChannel

func (l *ElasticLogger) LogPrivateMessageForChannel(message twitch.PrivateMessage) error

func (*ElasticLogger) LogPrivateMessageForUser

func (l *ElasticLogger) LogPrivateMessageForUser(user twitch.User, message twitch.PrivateMessage) error

func (*ElasticLogger) LogUserNoticeMessageForChannel

func (l *ElasticLogger) LogUserNoticeMessageForChannel(message twitch.UserNoticeMessage) error

func (*ElasticLogger) LogUserNoticeMessageForUser

func (l *ElasticLogger) LogUserNoticeMessageForUser(userID string, message twitch.UserNoticeMessage) error

func (*ElasticLogger) ReadLogForChannel

func (l *ElasticLogger) ReadLogForChannel(channelID string, year int, month int, day int) ([]string, error)

func (*ElasticLogger) ReadLogForUser

func (l *ElasticLogger) ReadLogForUser(channelID, userID string, year string, month string) ([]string, error)

ReadLogForUser fetch logs

func (*ElasticLogger) ReadRandomMessageForChannel

func (l *ElasticLogger) ReadRandomMessageForChannel(channelID string) (string, error)

func (*ElasticLogger) ReadRandomMessageForUser

func (l *ElasticLogger) ReadRandomMessageForUser(channelID, userID string) (string, error)