tweetmap

Documentation

Index

• Constants
• func InitPublisher(connStr string, tweetChan chan *prototweet.Tweet, errorChan chan error)
• func InitReceiver(connStr string, doneChan chan bool) (chan *prototweet.Tweet, chan error)
• func ListenToTwitter(cfg TwitterAPIConfig, filterFunc TweetFilter, doneChan chan bool) (chan *prototweet.Tweet, chan error)
• func ToProtoTweet(in *twitterstream.Tweet) (out *prototweet.Tweet, err error)
• type Database
  • func NewDatabase() (*Database, error)
  • func (Db *Database) Disconnect()
  • func (Db *Database) Query(queryType int, args ...interface{}) ([]byte, error)
• type ProtoTweetError
  • func (e *ProtoTweetError) Error() string
• type TweetFilter
• type TwitterAPIConfig

Constants

const (
	TWEETS_PAST_24HRS       int = iota
	TWEETS_BY_WARD          int = iota
	HASH_BY_WARD_PAST_24HRS int = iota
	TOP_HASH_PAST_24HRS     int = iota
)

Query types

Functions

func InitPublisher

func InitPublisher(connStr string, tweetChan chan *prototweet.Tweet, errorChan chan error)

Initializes ZMQ as a publisher Returns a channel for incoming tweets that need to be pushed out and an error channel used for outcoming publishing or tweet marshalling errors Goroutine exits on closing of the tweet channel

func InitReceiver

func InitReceiver(connStr string, doneChan chan bool) (chan *prototweet.Tweet, chan error)

Initializes ZMQ as a receiver Returns a channel for incoming tweets and a channel for errors. Takes a connection string, and a boolean channel to signal when to stop receiving tweets. Goroutine exits when any value is passed to the done channel

func ListenToTwitter

func ListenToTwitter(cfg TwitterAPIConfig, filterFunc TweetFilter, doneChan chan bool) (chan *prototweet.Tweet, chan error)

Listens starts up the twitterstream Takes a API configuration, a filter function, and a "done" channel Returns a tweet channel, and an error channel

func ToProtoTweet

func ToProtoTweet(in *twitterstream.Tweet) (out *prototweet.Tweet, err error)

Takes an input tweet from the twitterstream and transform it into a prototweet - a type suitable for transmission over ZMQ and JSON serialization

Types

type Database

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

func NewDatabase

func NewDatabase() (*Database, error)

func (*Database) Disconnect

func (Db *Database) Disconnect()

Wrapper for DB.Close()

func (*Database) Query

func (Db *Database) Query(queryType int, args ...interface{}) ([]byte, error)

Query Returns the result of a query, in marshalled JSON, which then can be served to the client

type ProtoTweetError

type ProtoTweetError struct{}

Prototweet Error Type

func (*ProtoTweetError) Error

func (e *ProtoTweetError) Error() string

type TweetFilter

type TweetFilter func(t *twitterstream.Tweet) bool

Filter type Functions take a tweet and return true if it should continue being processed

type TwitterAPIConfig

type TwitterAPIConfig struct {
	ConsumerKey    string
	ConsumerSecret string
	AccessToken    string
	AccessSecret   string
	SouthEast      twitterstream.Point
	NorthWest      twitterstream.Point
}

API keys and extent bounding box coordinates