twitchchatscraper

package module

v0.0.0-...-82fd534 Latest Latest Go to latest Published: Feb 6, 2016 License: MIT Imports: 11 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/FireEater64/twitch-chat-scraper

Links

Open Source Insights

README ¶

twitch-chat-scraper

##FAQ

Documentation ¶

Index ¶

Constants
func SetConfig(givenConfig *Config)
type Config
type ElasticBroker
- func (e *ElasticBroker) Connect(givenUrl string) chan<- *irc.Message
type Locator
- func NewLocator() *Locator
- func (l *Locator) GetIrcServerAddress(givenChannelName string) []string
- func (l *Locator) GetTopNChannels(givenLimit int) []string
type Scraper
- func NewScraper() *Scraper
type TwitchMessage

Constants ¶

View Source

const (
	TWITCH_API_CHAT_PROPERTIES_ENDPOINT = "https://api.twitch.tv/api/channels/%s/chat_properties"
	TWITCH_API_TOP_STREAM_ENDPOINT      = "https://api.twitch.tv/kraken/streams?limit=%d&offset=%d&broadcaster_language=en" // TODO: Make language configurable
)

View Source

const (
	IRC_PASS_STRING              = "PASS %s"
	IRC_USER_STRING              = "NICK %s"
	IRC_JOIN_STRING              = "JOIN #%s"
	IRC_PART_STRING              = "PART #%s"
	TWITCH_CHAT_SERVER_ADDRESS   = "irc.twitch.tv:6667"
	TIME_TO_WAIT_FOR_CONNECTION  = time.Second * 5
	TIME_BETWEEN_CHANNEL_SCRAPES = time.Minute * 20
	CHANNELS_TO_GET_PER_SCRAPE   = 1000
)

Variables ¶

This section is empty.

Functions ¶

func SetConfig ¶

func SetConfig(givenConfig *Config)

Types ¶

type Config ¶

type Config struct {
	TwitchUsername   string `json:"twitch_username"`
	TwitchOAuthToken string `json:"twitch_oauth_token"`
}

var Configuration *Config

type ElasticBroker ¶

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

func (*ElasticBroker) Connect ¶

func (e *ElasticBroker) Connect(givenUrl string) chan<- *irc.Message

type Locator ¶

type Locator struct {
}

Locate the best chat server to connect to for a given twitch channel

func NewLocator ¶

func NewLocator() *Locator

Locator constructor

func (*Locator) GetIrcServerAddress ¶

func (l *Locator) GetIrcServerAddress(givenChannelName string) []string

func (*Locator) GetTopNChannels ¶

func (l *Locator) GetTopNChannels(givenLimit int) []string

type Scraper ¶

type Scraper struct {
	SubscribedTo map[string]bool
	// contains filtered or unexported fields
}

func NewScraper ¶

func NewScraper() *Scraper

func (*Scraper) Connect ¶

func (s *Scraper) Connect() (chan<- *string, <-chan *irc.Message)

func (*Scraper) Read ¶

func (s *Scraper) Read(givenChan chan<- *irc.Message)

func (*Scraper) StartMessages ¶

func (s *Scraper) StartMessages()

func (*Scraper) Write ¶

func (s *Scraper) Write(givenChan <-chan *string)

type TwitchMessage ¶

type TwitchMessage struct {
	Channel   string
	Message   string
	From      string
	Timestamp time.Time `json:"@timestamp"`
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
main

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL