helpers

Documentation

Index

• func DoN1qlQuery(bucket *gocb.Bucket, query string, params []interface{}) (*uint64, error)
• func GetMaxTweetID(bucket *gocb.Bucket, handle string) (*uint64, error)
• func GetMinTweetID(bucket *gocb.Bucket, handle string) (*uint64, error)
• func GetTweets(bucket *gocb.Bucket, handle string) ([]string, error)
• func LoadAndStoreTweets(bucket *gocb.Bucket, api *anaconda.TwitterApi, handle string) (*uint32, error)
• func OpenBucket() (*gocb.Bucket, error)
• func OpenTwitterAPI() *anaconda.TwitterApi
• func QueryTweets(api *anaconda.TwitterApi, username string, count int64, maxID *uint64, ...) ([]anaconda.Tweet, error)
• type TweetDoc
  • func InsertTweets(bucket *gocb.Bucket, tweets []anaconda.Tweet) ([]*TweetDoc, error)

Functions

func DoN1qlQuery

func DoN1qlQuery(bucket *gocb.Bucket, query string, params []interface{}) (*uint64, error)

func GetMaxTweetID

func GetMaxTweetID(bucket *gocb.Bucket, handle string) (*uint64, error)

func GetMinTweetID

func GetMinTweetID(bucket *gocb.Bucket, handle string) (*uint64, error)

func GetTweets

func GetTweets(bucket *gocb.Bucket, handle string) ([]string, error)

func LoadAndStoreTweets

func LoadAndStoreTweets(bucket *gocb.Bucket, api *anaconda.TwitterApi, handle string) (*uint32, error)

func OpenBucket

func OpenBucket() (*gocb.Bucket, error)

func OpenTwitterAPI

func OpenTwitterAPI() *anaconda.TwitterApi

func QueryTweets

func QueryTweets(api *anaconda.TwitterApi, username string, count int64, maxID *uint64, sinceID *uint64) ([]anaconda.Tweet, error)

Types

type TweetDoc

type TweetDoc struct {
	*anaconda.Tweet
	Type string `json:"type"`
}

func InsertTweets

func InsertTweets(bucket *gocb.Bucket, tweets []anaconda.Tweet) ([]*TweetDoc, error)